| Interface | Description |
|---|---|
| TaskManager |
The base TaskManager interface.
|
| TaskStateStorage |
The base StateStorage interface.
|
| TaskSubmitter |
Submits Background Tasks for processing
|
| Class | Description |
|---|---|
| BackgroundTask |
Interface which all tasks that wish to be scheduled for later execution as background tasks must implement.
|
| ExternalOffsetStorage |
Store Kakfa offsets externally in Zookeeper for exactly once processing
|
| TaskCheckpoint |
Internal checkpoint used to keep track of task execution
|
| TaskConfiguration |
Internal checkpoint used to keep track of task execution
|
| TaskConfigurationDeserializer |
Implementation of
Deserializer that allows usage of TaskId as
kafka queue keys |
| TaskConfigurationSerializer |
Implementation of
Serializer that allows usage of TaskId as
kafka queue keys |
| TaskSchedule |
Scheduling information for tasks, contained within a
TaskState. |
| TaskState |
Internal task state model used to keep track of scheduled tasks.
|
| TaskStateDeserializer |
Implementation of
Serializer that allows usage of TaskState as
kafka queue values |
| TaskStateSerializer |
Implementation of
Serializer that allows usage of TaskState as
kafka queue values |
| Enum | Description |
|---|---|
| TaskState.Priority |
The priority of the task which decides which queue the task should go into
|
Copyright © 2017 Grakn Labs Ltd. All rights reserved.