| Package | Description |
|---|---|
| ai.grakn.client |
The loader client - use this Java API to access the REST endpoint.
|
| ai.grakn.engine |
Implements the REST controllers, task management and post processing features.
|
| ai.grakn.engine.tasks | |
| ai.grakn.engine.tasks.manager | |
| ai.grakn.engine.tasks.manager.singlequeue | |
| ai.grakn.engine.tasks.mock | |
| ai.grakn.engine.tasks.storage | |
| ai.grakn.exception |
Grakn exception definitions.
|
| Modifier and Type | Method and Description |
|---|---|
TaskId |
TaskClient.sendTask(Class<?> taskClass,
String creator,
java.time.Instant runAt,
java.time.Duration interval,
mjson.Json configuration)
Submit a task to run on an Grakn Engine server
|
| Modifier and Type | Method and Description |
|---|---|
protected String |
Client.convert(String uri,
TaskId id) |
TaskStatus |
TaskClient.getStatus(TaskId id)
Get the status of a given task on the server
|
boolean |
TaskClient.stopTask(TaskId id)
Stop a task using the given ID.
|
| Modifier and Type | Method and Description |
|---|---|
static TaskId |
TaskId.generate() |
static TaskId |
TaskId.of(String value) |
| Modifier and Type | Method and Description |
|---|---|
TaskId |
TaskState.getId() |
TaskId |
TaskStateStorage.newState(TaskState state)
Create a new task state and store it, returning an ID to later access this task state.
|
| Modifier and Type | Method and Description |
|---|---|
boolean |
TaskStateStorage.containsTask(TaskId id)
Returns whether the storage contains the given task
|
TaskState |
TaskStateStorage.getState(TaskId id)
This is a copy of the internal TaskState object.
|
void |
TaskManager.stopTask(TaskId id)
Stop a Scheduled, Paused or Running task.
|
| Modifier and Type | Method and Description |
|---|---|
void |
StandaloneTaskManager.stopTask(TaskId id) |
| Modifier and Type | Method and Description |
|---|---|
boolean |
SingleQueueTaskRunner.stopTask(TaskId taskId)
Stop the task if it is executing on this machine
|
void |
SingleQueueTaskManager.stopTask(TaskId id)
Stop a task from running.
|
| Modifier and Type | Method and Description |
|---|---|
static com.google.common.collect.ImmutableMultiset<TaskId> |
MockBackgroundTask.cancelledTasks() |
static com.google.common.collect.ImmutableMultiset<TaskId> |
MockBackgroundTask.completedTasks() |
| Modifier and Type | Method and Description |
|---|---|
protected void |
ShortExecutionMockTask.executeStartInner(TaskId id) |
protected abstract void |
MockBackgroundTask.executeStartInner(TaskId id) |
protected void |
LongExecutionMockTask.executeStartInner(TaskId id) |
protected void |
FailingMockTask.executeStartInner(TaskId id) |
protected void |
EndlessExecutionMockTask.executeStartInner(TaskId id) |
| Modifier and Type | Method and Description |
|---|---|
static void |
MockBackgroundTask.whenTaskFinishes(java.util.function.Consumer<TaskId> onTaskFinish) |
static void |
MockBackgroundTask.whenTaskStarts(java.util.function.Consumer<TaskId> beforeTaskStarts) |
| Modifier and Type | Method and Description |
|---|---|
TaskId |
TaskStateZookeeperStore.newState(TaskState task)
Creates a new task state in Zookeeper
|
TaskId |
TaskStateInMemoryStore.newState(TaskState state) |
| Modifier and Type | Method and Description |
|---|---|
boolean |
TaskStateZookeeperStore.containsTask(TaskId id) |
boolean |
TaskStateInMemoryStore.containsTask(TaskId id) |
TaskState |
TaskStateZookeeperStore.getState(TaskId id)
Retrieve the TaskState associated with the given ID.
|
TaskState |
TaskStateInMemoryStore.getState(TaskId id) |
| Modifier and Type | Method and Description |
|---|---|
static GraknBackendException |
GraknBackendException.stateStorageMissingId(TaskId id)
Thrown when a task id is missing from the task state storage
|
Copyright © 2017 Grakn Labs Ltd. All rights reserved.