| Package | Description |
|---|---|
| ai.grakn.engine.tasks | |
| ai.grakn.engine.tasks.manager | |
| ai.grakn.engine.tasks.manager.singlequeue | |
| ai.grakn.engine.tasks.storage | |
| ai.grakn.engine.util |
Implementation of internal engine utilities.
|
| Modifier and Type | Method and Description |
|---|---|
EngineID |
TaskState.engineID() |
| 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.
|
TaskState |
TaskState.markRunning(EngineID engineID) |
| Constructor and Description |
|---|
StandaloneTaskManager(EngineID engineId,
GraknEngineConfig config,
RedisConnection redis,
EngineGraknGraphFactory factory) |
| Constructor and Description |
|---|
SingleQueueTaskManager(EngineID engineId,
GraknEngineConfig config,
RedisConnection redis,
EngineGraknGraphFactory factory)
Create a
SingleQueueTaskManager
The SingleQueueTaskManager implementation must:
+ Instantiate a connection to zookeeper
+ Configure and instance of TaskStateStorage
+ Create and run an instance of SingleQueueTaskRunner
+ Add oneself to the leader elector by instantiating failoverelector |
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 |
|---|---|
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 |
|---|---|
static EngineID |
EngineID.me() |
static EngineID |
EngineID.of(String value) |
Copyright © 2017 Grakn Labs Ltd. All rights reserved.