Package | Description |
---|---|
com.nirmata.workflow | |
com.nirmata.workflow.admin | |
com.nirmata.workflow.details | |
com.nirmata.workflow.models | |
com.nirmata.workflow.queue | |
com.nirmata.workflow.queue.zookeeper |
Modifier and Type | Method and Description |
---|---|
WorkflowManagerBuilder |
WorkflowManagerBuilder.addingTaskExecutor(TaskExecutor taskExecutor,
int qty,
TaskType taskType)
Adds a pool of task executors for a given task type to this instance of
the workflow.
|
Modifier and Type | Method and Description |
---|---|
TaskType |
TaskDetails.getTaskType() |
Constructor and Description |
---|
TaskDetails(TaskId taskId,
TaskType taskType,
Map<String,String> metaData) |
Modifier and Type | Method and Description |
---|---|
static String |
ZooKeeperConstants.getQueueLockPath(TaskType taskType) |
static String |
ZooKeeperConstants.getQueuePath(TaskType taskType) |
Constructor and Description |
---|
TaskExecutorSpec(TaskExecutor taskExecutor,
int qty,
TaskType taskType) |
Modifier and Type | Method and Description |
---|---|
TaskType |
Task.getTaskType() |
TaskType |
ExecutableTask.getTaskType() |
Constructor and Description |
---|
ExecutableTask(RunId runId,
TaskId taskId,
TaskType taskType,
Map<String,String> metaData,
boolean isExecutable) |
Task(TaskId taskId,
TaskType taskType) |
Task(TaskId taskId,
TaskType taskType,
List<Task> childrenTasks) |
Task(TaskId taskId,
TaskType taskType,
List<Task> childrenTasks,
Map<String,String> metaData) |
Modifier and Type | Method and Description |
---|---|
Queue |
QueueFactory.createQueue(WorkflowManagerImpl workflowManager,
TaskType taskType) |
QueueConsumer |
QueueFactory.createQueueConsumer(WorkflowManagerImpl workflowManager,
TaskRunner taskRunner,
TaskType taskType) |
Modifier and Type | Method and Description |
---|---|
Queue |
ZooKeeperSimpleQueueFactory.createQueue(WorkflowManagerImpl workflowManager,
TaskType taskType) |
QueueConsumer |
ZooKeeperSimpleQueueFactory.createQueueConsumer(WorkflowManagerImpl workflowManager,
TaskRunner taskRunner,
TaskType taskType) |
Copyright © 2014–2018 Nirmata. All rights reserved.