| Package | Description |
|---|---|
| ai.grakn.engine |
Implements the REST controllers, task management and post processing features.
|
| ai.grakn.engine.controller |
Implementation of Grakn server REST endpoints.
|
| ai.grakn.engine.factory | |
| ai.grakn.engine.postprocessing | |
| ai.grakn.engine.tasks | |
| ai.grakn.engine.tasks.manager | |
| ai.grakn.engine.tasks.manager.singlequeue | |
| ai.grakn.engine.user |
Implements graph user management.
|
| Modifier and Type | Method and Description |
|---|---|
EngineGraknGraphFactory |
GraknEngineServer.factory() |
| Constructor and Description |
|---|
SystemKeyspace(EngineGraknGraphFactory factory) |
| Constructor and Description |
|---|
ConceptController(EngineGraknGraphFactory factory,
spark.Service spark) |
DashboardController(EngineGraknGraphFactory factory,
spark.Service spark) |
GraqlController(EngineGraknGraphFactory factory,
spark.Service spark) |
SystemController(EngineGraknGraphFactory factory,
spark.Service spark) |
| Modifier and Type | Method and Description |
|---|---|
static EngineGraknGraphFactory |
EngineGraknGraphFactory.create(Properties properties) |
| Modifier and Type | Method and Description |
|---|---|
static void |
GraphMutators.runBatchMutationWithRetry(EngineGraknGraphFactory factory,
String keyspace,
int maxRetry,
java.util.function.Consumer<GraknGraph> mutatingFunction) |
| Modifier and Type | Method and Description |
|---|---|
EngineGraknGraphFactory |
BackgroundTask.factory() |
| 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 |
|---|
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 |
|---|---|
static UsersHandler |
UsersHandler.create(String adminPassword,
EngineGraknGraphFactory factory) |
Copyright © 2017 Grakn Labs Ltd. All rights reserved.