| Package | Description |
|---|---|
| ai.grakn.engine.tasks | |
| ai.grakn.engine.tasks.mock |
| Modifier and Type | Method and Description |
|---|---|
TaskCheckpoint |
TaskState.checkpoint() |
static TaskCheckpoint |
TaskCheckpoint.of(mjson.Json checkpoint) |
| Modifier and Type | Method and Description |
|---|---|
TaskState |
TaskState.checkpoint(TaskCheckpoint taskCheckpoint) |
boolean |
BackgroundTask.resume(TaskCheckpoint lastCheckpoint)
This method may be called when resuming from a paused state or recovering from a crash or failure of any kind.
|
void |
BackgroundTask.saveCheckpoint(TaskCheckpoint checkpoint) |
| 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 |
|---|---|
protected void |
ShortExecutionMockTask.executeResumeInner(TaskCheckpoint checkpoint) |
protected abstract void |
MockBackgroundTask.executeResumeInner(TaskCheckpoint checkpoint) |
protected void |
LongExecutionMockTask.executeResumeInner(TaskCheckpoint checkpoint) |
protected void |
FailingMockTask.executeResumeInner(TaskCheckpoint checkpoint) |
protected void |
EndlessExecutionMockTask.executeResumeInner(TaskCheckpoint checkpoint) |
boolean |
MockBackgroundTask.resume(TaskCheckpoint lastCheckpoint) |
| Modifier and Type | Method and Description |
|---|---|
static void |
MockBackgroundTask.whenTaskResumes(java.util.function.Consumer<TaskCheckpoint> onTaskResume) |
Copyright © 2017 Grakn Labs Ltd. All rights reserved.