| Modifier and Type | Method and Description |
|---|---|
static TaskState |
UpdatingInstanceCountTask.createTask(Class creator)
Helper method which creates PP Task States.
|
static TaskState |
PostProcessingTask.createTask(Class creator,
int delay)
Helper method which creates PP Task States.
|
| Modifier and Type | Method and Description |
|---|---|
TaskState |
TaskState.checkpoint(TaskCheckpoint taskCheckpoint) |
TaskState |
TaskState.copy() |
TaskState |
TaskStateDeserializer.deserialize(String topic,
byte[] data) |
static TaskState |
TaskStateDeserializer.deserializeFromString(String data) |
TaskState |
TaskStateStorage.getState(TaskId id)
This is a copy of the internal TaskState object.
|
TaskState |
TaskState.markCompleted() |
TaskState |
TaskState.markFailed(Throwable exception) |
TaskState |
TaskState.markRunning(EngineID engineID) |
TaskState |
TaskState.markScheduled() |
TaskState |
TaskState.markStopped() |
static TaskState |
TaskState.of(Class<?> taskClass,
String creator,
TaskSchedule schedule,
TaskState.Priority priority) |
TaskState |
TaskState.schedule(TaskSchedule schedule) |
| Modifier and Type | Method and Description |
|---|---|
Set<TaskState> |
TaskStateStorage.getTasks(TaskStatus taskStatus,
String taskClassName,
String createdBy,
EngineID runningOnEngine,
int limit,
int offset)
Return a Set of Pairs of tasks that match any of the criteria.
|
| Modifier and Type | Method and Description |
|---|---|
void |
TaskSubmitter.addTask(TaskState taskState,
TaskConfiguration configuration)
Schedule a
BackgroundTask for execution. |
void |
BackgroundTask.addTask(TaskState taskState,
TaskConfiguration configuration)
Submit a new task for execution
|
TaskId |
TaskStateStorage.newState(TaskState state)
Create a new task state and store it, returning an ID to later access this task state.
|
byte[] |
TaskStateSerializer.serialize(String topic,
TaskState data) |
static String |
TaskStateSerializer.serializeToString(TaskState data) |
Boolean |
TaskStateStorage.updateState(TaskState state)
Used to update task state.
|
| Modifier and Type | Method and Description |
|---|---|
static org.apache.kafka.clients.consumer.Consumer<TaskState,TaskConfiguration> |
ConfigHelper.kafkaConsumer(String groupId,
Properties properties) |
static org.apache.kafka.clients.producer.Producer<TaskState,TaskConfiguration> |
ConfigHelper.kafkaProducer(Properties properties) |
| Modifier and Type | Method and Description |
|---|---|
void |
StandaloneTaskManager.addTask(TaskState taskState,
TaskConfiguration configuration) |
| Modifier and Type | Method and Description |
|---|---|
void |
SingleQueueTaskManager.addTask(TaskState taskState,
TaskConfiguration configuration)
Serialize and send the given task to the given kafka queue
|
| Constructor and Description |
|---|
SingleQueueTaskRunner(SingleQueueTaskManager manager,
EngineID engineID,
GraknEngineConfig config,
RedisConnection redis,
EngineGraknGraphFactory factory,
ExternalOffsetStorage offsetStorage,
org.apache.kafka.clients.consumer.Consumer<TaskState,TaskConfiguration> consumer)
Create a
SingleQueueTaskRunner which retrieves tasks from the given and uses the given
to store and retrieve information about tasks. |
| Modifier and Type | Method and Description |
|---|---|
TaskState |
TaskStateZookeeperStore.getState(TaskId id)
Retrieve the TaskState associated with the given ID.
|
TaskState |
TaskStateInMemoryStore.getState(TaskId id) |
| Modifier and Type | Method and Description |
|---|---|
Set<TaskState> |
TaskStateZookeeperStore.getTasks(TaskStatus taskStatus,
String taskClassName,
String createdBy,
EngineID engineRunningOn,
int limit,
int offset)
This implementation will fetch all of the tasks from zookeeper and then
filer them out.
|
Set<TaskState> |
TaskStateInMemoryStore.getTasks(TaskStatus taskStatus,
String taskClassName,
String createdBy,
EngineID engineRunningOn,
int limit,
int offset) |
| Modifier and Type | Method and Description |
|---|---|
TaskId |
TaskStateZookeeperStore.newState(TaskState task)
Creates a new task state in Zookeeper
|
TaskId |
TaskStateInMemoryStore.newState(TaskState state) |
Boolean |
TaskStateZookeeperStore.updateState(TaskState task)
Writes a new state to Zookeeper.
|
Boolean |
TaskStateInMemoryStore.updateState(TaskState state) |
Copyright © 2017 Grakn Labs Ltd. All rights reserved.