| Package | Description |
|---|---|
| ai.grakn.engine |
Implements the REST controllers, task management and post processing features.
|
| 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 |
|---|---|
static GraknEngineConfig |
GraknEngineConfig.create() |
static GraknEngineConfig |
GraknEngineConfig.read(String path) |
| Modifier and Type | Method and Description |
|---|---|
static void |
GraknEngineServer.configureSpark(spark.Service spark,
GraknEngineConfig prop,
JWTHandler jwtHandler) |
static GraknEngineServer |
GraknEngineServer.start(GraknEngineConfig prop) |
| Modifier and Type | Method and Description |
|---|---|
GraknEngineConfig |
BackgroundTask.engineConfiguration() |
| 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. |
| Constructor and Description |
|---|
ZookeeperConnection(GraknEngineConfig config)
Start the connection to zookeeper.
|
| 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.