| Package | Description |
|---|---|
| ai.grakn.engine.tasks | |
| ai.grakn.engine.tasks.connection | |
| ai.grakn.engine.tasks.manager | |
| ai.grakn.engine.tasks.manager.singlequeue |
| Modifier and Type | Method and Description |
|---|---|
RedisConnection |
BackgroundTask.redis() |
| Modifier and Type | Method and Description |
|---|---|
void |
BackgroundTask.initialize(java.util.function.Consumer<TaskCheckpoint> saveCheckpoint,
TaskConfiguration configuration,
TaskSubmitter taskSubmitter,
GraknEngineConfig engineConfig,
RedisConnection redis,
EngineGraknGraphFactory factory)
Initialize the
BackgroundTask. |
| Modifier and Type | Method and Description |
|---|---|
static RedisConnection |
RedisConnection.create(String url,
int port) |
| 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. |
Copyright © 2017 Grakn Labs Ltd. All rights reserved.