A B C D E F G H I J K L M N O P R S T U V W Z

A

add(InsertQuery) - Method in class ai.grakn.engine.loader.Loader

Add an insert query to the queue

addJobCasting(String, Set<String>) - Method in class ai.grakn.engine.postprocessing.Cache

addJobResource(String, Set<String>) - Method in class ai.grakn.engine.postprocessing.Cache

addUser(Json) - Method in class ai.grakn.engine.user.SystemKeyspaceUsers

Add a new user.

addUser(Json) - Method in class ai.grakn.engine.user.UsersHandler

ai.grakn.engine - package ai.grakn.engine

ai.grakn.engine.backgroundtasks - package ai.grakn.engine.backgroundtasks

ai.grakn.engine.backgroundtasks.config - package ai.grakn.engine.backgroundtasks.config

ai.grakn.engine.backgroundtasks.distributed - package ai.grakn.engine.backgroundtasks.distributed

ai.grakn.engine.backgroundtasks.standalone - package ai.grakn.engine.backgroundtasks.standalone

ai.grakn.engine.backgroundtasks.taskstorage - package ai.grakn.engine.backgroundtasks.taskstorage

ai.grakn.engine.controller - package ai.grakn.engine.controller

ai.grakn.engine.loader - package ai.grakn.engine.loader

ai.grakn.engine.postprocessing - package ai.grakn.engine.postprocessing

ai.grakn.engine.session - package ai.grakn.engine.session

ai.grakn.engine.user - package ai.grakn.engine.user

ai.grakn.engine.util - package ai.grakn.engine.util

ai.grakn.factory - package ai.grakn.factory

allUsers(int, int) - Method in class ai.grakn.engine.user.SystemKeyspaceUsers

Retrieve the list of all users with all their properties.

allUsers(int, int) - Method in class ai.grakn.engine.user.UsersHandler

AuthController - Class in ai.grakn.engine.controller

AuthController() - Constructor for class ai.grakn.engine.controller.AuthController

B

BackgroundTask - Interface in ai.grakn.engine.backgroundtasks

Interface which all tasks that wish to be scheduled for later execution as background tasks must implement.

BATCH_SIZE_PROPERTY - Static variable in class ai.grakn.engine.util.ConfigProperties

C

Cache - Class in ai.grakn.engine.postprocessing

checkpoint(String) - Method in class ai.grakn.engine.backgroundtasks.TaskState

checkpoint() - Method in class ai.grakn.engine.backgroundtasks.TaskState

checkpoint(String) - Method in class ai.grakn.engine.backgroundtasks.taskstorage.SynchronizedState

checkpoint() - Method in class ai.grakn.engine.backgroundtasks.taskstorage.SynchronizedState

childEvent(CuratorFramework, TreeCacheEvent) - Method in class ai.grakn.engine.backgroundtasks.distributed.TaskFailover

client() - Static method in class ai.grakn.engine.backgroundtasks.config.ConfigHelper

clone() - Method in class ai.grakn.engine.backgroundtasks.TaskState

close() - Method in class ai.grakn.engine.backgroundtasks.distributed.DistributedTaskManager

close() - Method in class ai.grakn.engine.backgroundtasks.distributed.Scheduler

close() - Method in class ai.grakn.engine.backgroundtasks.distributed.TaskFailover

close() - Method in class ai.grakn.engine.backgroundtasks.distributed.TaskRunner

Stop the main loop, causing run() to exit.

close() - Method in class ai.grakn.engine.backgroundtasks.standalone.StandaloneTaskManager

close() - Method in class ai.grakn.engine.backgroundtasks.taskstorage.SynchronizedStateStorage

ClusterManager - Class in ai.grakn.engine.backgroundtasks.distributed

Scheduler will be constantly running on the "Leader" machine.

CommitLogController - Class in ai.grakn.engine.controller

A controller which core submits commit logs to so we can post-process jobs for cleanup.

CommitLogController() - Constructor for class ai.grakn.engine.controller.CommitLogController

completableFuture(String) - Method in class ai.grakn.engine.backgroundtasks.distributed.DistributedTaskManager

completableFuture(String) - Method in class ai.grakn.engine.backgroundtasks.standalone.StandaloneTaskManager

completableFuture(String) - Method in interface ai.grakn.engine.backgroundtasks.TaskManager

Return a future that allows registering asynchronous callbacks triggered when a task is completed.

CONFIG_FILE_SYSTEM_PROPERTY - Static variable in class ai.grakn.engine.util.ConfigProperties

ConfigHelper - Class in ai.grakn.engine.backgroundtasks.config

ConfigHelper() - Constructor for class ai.grakn.engine.backgroundtasks.config.ConfigHelper

ConfigProperties - Class in ai.grakn.engine.util

Singleton class used to read config file and make all the settings available to the Grakn Engine classes.

configuration(JSONObject) - Method in class ai.grakn.engine.backgroundtasks.TaskState

configuration() - Method in class ai.grakn.engine.backgroundtasks.TaskState

connection() - Method in class ai.grakn.engine.backgroundtasks.taskstorage.SynchronizedStateStorage

CREATED_BY - Static variable in interface ai.grakn.engine.util.SystemOntologyElements

creator(String) - Method in class ai.grakn.engine.backgroundtasks.TaskState

creator() - Method in class ai.grakn.engine.backgroundtasks.TaskState

CURRENT_DIR_SYSTEM_PROPERTY - Static variable in class ai.grakn.engine.util.ConfigProperties

D

debug(String) - Method in class ai.grakn.engine.backgroundtasks.distributed.KafkaLogger

DEFAULT_CONFIG_FILE - Static variable in class ai.grakn.engine.util.ConfigProperties

DEFAULT_KEYSPACE_PROPERTY - Static variable in class ai.grakn.engine.util.ConfigProperties

DEFAULT_LOG_CONFIG_FILE - Static variable in class ai.grakn.engine.util.ConfigProperties

deleteJobCasting(String, String) - Method in class ai.grakn.engine.postprocessing.Cache

deleteJobResource(String, String) - Method in class ai.grakn.engine.postprocessing.Cache

deserialize(String) - Static method in class ai.grakn.engine.backgroundtasks.taskstorage.SynchronizedState

DistributedTaskManager - Class in ai.grakn.engine.backgroundtasks.distributed

Class to manage tasks distributed using Kafka.

DistributedTaskManager() - Constructor for class ai.grakn.engine.backgroundtasks.distributed.DistributedTaskManager

E

ENGINE_ID - Static variable in interface ai.grakn.engine.util.SystemOntologyElements

engineID(String) - Method in class ai.grakn.engine.backgroundtasks.TaskState

engineID() - Method in class ai.grakn.engine.backgroundtasks.TaskState

engineID(String) - Method in class ai.grakn.engine.backgroundtasks.taskstorage.SynchronizedState

engineID() - Method in class ai.grakn.engine.backgroundtasks.taskstorage.SynchronizedState

EngineID - Class in ai.grakn.engine.util

error(String) - Method in class ai.grakn.engine.backgroundtasks.distributed.KafkaLogger

error(String, Throwable) - Method in class ai.grakn.engine.backgroundtasks.distributed.KafkaLogger

exception(String) - Method in class ai.grakn.engine.backgroundtasks.TaskState

exception() - Method in class ai.grakn.engine.backgroundtasks.TaskState

ExceptionWrapper - Class in ai.grakn.engine.util

Utility class to execute a Runnable and log any exceptions thrown without propagating them further.

ExceptionWrapper() - Constructor for class ai.grakn.engine.util.ExceptionWrapper

extractUserFromJWT(String) - Static method in class ai.grakn.engine.util.JWTHandler

F

flush() - Method in class ai.grakn.engine.loader.Loader

Load any remaining batches in the queue.

G

getAcceptType(Request) - Static method in class ai.grakn.engine.controller.Utilities

getAsList(String, String) - Static method in class ai.grakn.engine.controller.Utilities

getAsString(String, String) - Static method in class ai.grakn.engine.controller.Utilities

getAvailableThreads() - Method in class ai.grakn.engine.util.ConfigProperties

getBatchSize() - Method in class ai.grakn.engine.loader.Loader

getBytes(String) - Static method in class ai.grakn.engine.user.Password

getCastingJobs(String) - Method in class ai.grakn.engine.postprocessing.Cache

getGraph(String) - Method in class ai.grakn.factory.GraphFactory

getInstance() - Static method in class ai.grakn.engine.backgroundtasks.distributed.ClusterManager

getInstance() - Static method in class ai.grakn.engine.backgroundtasks.distributed.DistributedTaskManager

getInstance() - Static method in class ai.grakn.engine.backgroundtasks.distributed.KafkaLogger

getInstance() - Static method in class ai.grakn.engine.backgroundtasks.distributed.TaskFailover

getInstance() - Static method in class ai.grakn.engine.backgroundtasks.standalone.StandaloneTaskManager

getInstance() - Static method in class ai.grakn.engine.backgroundtasks.taskstorage.InMemoryStateStorage

getInstance() - Static method in class ai.grakn.engine.backgroundtasks.taskstorage.SynchronizedStateStorage

getInstance() - Static method in class ai.grakn.engine.postprocessing.Cache

getInstance() - Static method in class ai.grakn.engine.postprocessing.PostProcessing

getInstance() - Static method in class ai.grakn.engine.user.UsersHandler

getInstance() - Static method in class ai.grakn.engine.util.ConfigProperties

getInstance() - Static method in class ai.grakn.engine.util.EngineID

getInstance() - Static method in class ai.grakn.factory.GraphFactory

getKeyspace(Request) - Static method in class ai.grakn.engine.controller.Utilities

getKeyspaces() - Method in class ai.grakn.engine.postprocessing.Cache

getLastTimeJobAdded() - Method in class ai.grakn.engine.postprocessing.Cache

getLogFilePath() - Method in class ai.grakn.engine.util.ConfigProperties

getNextSalt(GraknGraph) - Static method in class ai.grakn.engine.user.Password

Returns a random salt to be used to hash a password.

getPath(String) - Method in class ai.grakn.engine.util.ConfigProperties

getProperties() - Method in class ai.grakn.engine.util.ConfigProperties

getProperty(String) - Method in class ai.grakn.engine.util.ConfigProperties

getProperty(String, String) - Method in class ai.grakn.engine.util.ConfigProperties

getPropertyAsBool(String) - Method in class ai.grakn.engine.util.ConfigProperties

getPropertyAsInt(String) - Method in class ai.grakn.engine.util.ConfigProperties

getPropertyAsLong(String) - Method in class ai.grakn.engine.util.ConfigProperties

getResourceJobs(String) - Method in class ai.grakn.engine.postprocessing.Cache

getScheduler() - Method in class ai.grakn.engine.backgroundtasks.distributed.ClusterManager

Get the scheduler object

getState(String) - Method in class ai.grakn.engine.backgroundtasks.distributed.DistributedTaskManager

getState(String) - Method in interface ai.grakn.engine.backgroundtasks.StateStorage

This is a copy of the internal TaskState object.

getState(String) - Method in class ai.grakn.engine.backgroundtasks.taskstorage.GraknStateStorage

getState(String) - Method in class ai.grakn.engine.backgroundtasks.taskstorage.InMemoryStateStorage

getState(String) - Method in class ai.grakn.engine.backgroundtasks.taskstorage.SynchronizedStateStorage

getString(byte[]) - Static method in class ai.grakn.engine.user.Password

getTasks(TaskStatus, String, String, int, int) - Method in interface ai.grakn.engine.backgroundtasks.StateStorage

Return a Set of Pairs of tasks that match any of the criteria.

getTasks(TaskStatus, String, String, int, int) - Method in class ai.grakn.engine.backgroundtasks.taskstorage.GraknStateStorage

getTasks(TaskStatus, String, String, int, int, Boolean) - Method in class ai.grakn.engine.backgroundtasks.taskstorage.GraknStateStorage

getTasks(TaskStatus, String, String, int, int) - Method in class ai.grakn.engine.backgroundtasks.taskstorage.InMemoryStateStorage

getUser(String) - Method in class ai.grakn.engine.user.SystemKeyspaceUsers

Return the user with the specified name as a JSON object where the properties have the same names as the Grakn resource types.

getUser(String) - Method in class ai.grakn.engine.user.UsersHandler

GRAKN_ASCII - Static variable in class ai.grakn.engine.util.ConfigProperties

GraknEngineServer - Class in ai.grakn.engine

Main class in charge to start a web server and all the REST controllers.

GraknEngineServer() - Constructor for class ai.grakn.engine.GraknEngineServer

GraknStateStorage - Class in ai.grakn.engine.backgroundtasks.taskstorage

GraknStateStorage() - Constructor for class ai.grakn.engine.backgroundtasks.taskstorage.GraknStateStorage

GRAPH_COMPUTER_CONFIG_PROPERTY - Static variable in class ai.grakn.engine.util.ConfigProperties

GRAPH_CONFIG_PROPERTY - Static variable in class ai.grakn.engine.util.ConfigProperties

GraphFactory - Class in ai.grakn.factory

GraphFactoryController - Class in ai.grakn.engine.controller

REST controller used by GraknGraphFactoryImpl to retrieve graph configuration for a given graph name.

GraphFactoryController() - Constructor for class ai.grakn.engine.controller.GraphFactoryController

H

HAL_DEGREE_PROPERTY - Static variable in class ai.grakn.engine.util.ConfigProperties

hash(char[], byte[]) - Static method in class ai.grakn.engine.user.Password

Returns a salted and hashed password using the provided hash.
Note - side effect: the password is destroyed (the char[] is filled with zeros)

I

id() - Method in class ai.grakn.engine.util.EngineID

ImportController - Class in ai.grakn.engine.controller

ImportController() - Constructor for class ai.grakn.engine.controller.ImportController

info(String) - Method in class ai.grakn.engine.backgroundtasks.distributed.KafkaLogger

InMemoryStateStorage - Class in ai.grakn.engine.backgroundtasks.taskstorage

interval(long) - Method in class ai.grakn.engine.backgroundtasks.TaskState

interval() - Method in class ai.grakn.engine.backgroundtasks.TaskState

isExpectedPassword(char[], byte[], byte[]) - Static method in class ai.grakn.engine.user.Password

Returns true if the given password and salt match the hashed value, false otherwise.
Note - side effect: the password is destroyed (the char[] is filled with zeros)

isPasswordProtected - Static variable in class ai.grakn.engine.GraknEngineServer

isRecurring(Boolean) - Method in class ai.grakn.engine.backgroundtasks.TaskState

isRecurring() - Method in class ai.grakn.engine.backgroundtasks.TaskState

isRunning() - Static method in class ai.grakn.engine.GraknEngineServer

Check if Grakn Engine has been started

isSaveInProgress() - Method in class ai.grakn.engine.postprocessing.Cache

J

JWT_SECRET_PROPERTY - Static variable in class ai.grakn.engine.util.ConfigProperties

JWTHandler - Class in ai.grakn.engine.util

JWTHandler() - Constructor for class ai.grakn.engine.util.JWTHandler

K

KAFKA_BATCH_SIZE - Static variable in class ai.grakn.engine.util.ConfigProperties

KAFKA_BOOTSTRAP_SERVERS - Static variable in class ai.grakn.engine.util.ConfigProperties

KAFKA_BUFFER_MEM - Static variable in class ai.grakn.engine.util.ConfigProperties

KAFKA_LINGER_MS - Static variable in class ai.grakn.engine.util.ConfigProperties

KAFKA_RETRIES - Static variable in class ai.grakn.engine.util.ConfigProperties

KAFKA_SESSION_TIMEOUT - Static variable in class ai.grakn.engine.util.ConfigProperties

kafkaConsumer(String) - Static method in class ai.grakn.engine.backgroundtasks.config.ConfigHelper

KafkaLogger - Class in ai.grakn.engine.backgroundtasks.distributed

kafkaProducer() - Static method in class ai.grakn.engine.backgroundtasks.config.ConfigHelper

KafkaTerms - Interface in ai.grakn.engine.backgroundtasks.config

L

Loader - Class in ai.grakn.engine.loader

Manage loading tasks in the Task Manager

Loader(String) - Constructor for class ai.grakn.engine.loader.Loader

LOADER_REPEAT_COMMITS - Static variable in class ai.grakn.engine.util.ConfigProperties

LoaderTask - Class in ai.grakn.engine.loader

Task that will load data into the graph

LoaderTask() - Constructor for class ai.grakn.engine.loader.LoaderTask

LOG_FILE_CONFIG_SYSTEM_PROPERTY - Static variable in class ai.grakn.engine.util.ConfigProperties

LOG_FILE_OUTPUT_SYSTEM_PROPERTY_MAIN - Static variable in class ai.grakn.engine.util.ConfigProperties

LOG_FILE_OUTPUT_SYSTEM_PROPERTY_POST_PROCESSING - Static variable in class ai.grakn.engine.util.ConfigProperties

LOG_LEVEL_SYSTEM_PROPERTY - Static variable in class ai.grakn.engine.util.ConfigProperties

LOG_NAME_POSTPROCESSING_DEFAULT - Static variable in class ai.grakn.engine.util.ConfigProperties

LOG_NAME_POSTPROCESSING_PROPERTY - Static variable in class ai.grakn.engine.util.ConfigProperties

LOG_TOPIC - Static variable in interface ai.grakn.engine.backgroundtasks.config.KafkaTerms

LOGGING_FILE_PATH_MAIN - Static variable in class ai.grakn.engine.util.ConfigProperties

LOGGING_FILE_PATH_POST_PROCESSING - Static variable in class ai.grakn.engine.util.ConfigProperties

LOGGING_LEVEL - Static variable in class ai.grakn.engine.util.ConfigProperties

M

main(String[]) - Static method in class ai.grakn.engine.GraknEngineServer

N

NEW_TASKS_TOPIC - Static variable in interface ai.grakn.engine.backgroundtasks.config.KafkaTerms

newState(String, String, Date, Boolean, long, JSONObject) - Method in interface ai.grakn.engine.backgroundtasks.StateStorage

Create a new task state and store it, returning an ID to later access this task state.

newState(String, String, Date, Boolean, long, JSONObject) - Method in class ai.grakn.engine.backgroundtasks.taskstorage.GraknStateStorage

newState(String, String, Date, Boolean, long, JSONObject) - Method in class ai.grakn.engine.backgroundtasks.taskstorage.InMemoryStateStorage

newState(String, TaskStatus, String, String) - Method in class ai.grakn.engine.backgroundtasks.taskstorage.SynchronizedStateStorage

noThrow(Runnable, String) - Static method in class ai.grakn.engine.util.ExceptionWrapper

NUM_THREADS_PROPERTY - Static variable in class ai.grakn.engine.util.ConfigProperties

O

onClose(Session, int, String) - Method in class ai.grakn.engine.session.RemoteSession

onConnect(Session) - Method in class ai.grakn.engine.session.RemoteSession

onMessage(Session, String) - Method in class ai.grakn.engine.session.RemoteSession

onPartitionsAssigned(Collection<TopicPartition>) - Method in class ai.grakn.engine.backgroundtasks.distributed.RebalanceListener

onPartitionsRevoked(Collection<TopicPartition>) - Method in class ai.grakn.engine.backgroundtasks.distributed.RebalanceListener

open() - Method in class ai.grakn.engine.backgroundtasks.distributed.DistributedTaskManager

open() - Method in class ai.grakn.engine.backgroundtasks.distributed.Scheduler

open(CuratorFramework, TreeCache) - Method in class ai.grakn.engine.backgroundtasks.distributed.TaskFailover

open() - Method in class ai.grakn.engine.backgroundtasks.distributed.TaskRunner

open() - Method in class ai.grakn.engine.backgroundtasks.standalone.StandaloneTaskManager

open() - Method in interface ai.grakn.engine.backgroundtasks.TaskManager

P

Password - Class in ai.grakn.engine.user

A helper class for generating secure passwords based on random salts The algorithm used is PBKDF2WithHmacSHA1 recommended by NIST .

PASSWORD_PROTECTED_PROPERTY - Static variable in class ai.grakn.engine.util.ConfigProperties

pause() - Method in interface ai.grakn.engine.backgroundtasks.BackgroundTask

Called to suspend the execution of a currently running task.

pause() - Method in class ai.grakn.engine.loader.LoaderTask

pause() - Method in class ai.grakn.engine.postprocessing.PostProcessingTask

POLLING_FREQUENCY_PROPERTY - Static variable in class ai.grakn.engine.util.ConfigProperties

POST_PROCESSING_DELAY - Static variable in class ai.grakn.engine.util.ConfigProperties

PostProcessing - Class in ai.grakn.engine.postprocessing

PostProcessingTask - Class in ai.grakn.engine.postprocessing

PostProcessingTask() - Constructor for class ai.grakn.engine.postprocessing.PostProcessingTask

printLoaderState() - Method in class ai.grakn.engine.loader.Loader

Method that logs the current taskstorage of loading tasks

PROJECT_VERSION - Static variable in class ai.grakn.engine.util.ConfigProperties

R

RebalanceListener - Class in ai.grakn.engine.backgroundtasks.distributed

RebalanceListener(KafkaConsumer) - Constructor for class ai.grakn.engine.backgroundtasks.distributed.RebalanceListener

RECUR_INTERVAL - Static variable in interface ai.grakn.engine.util.SystemOntologyElements

RECURRING - Static variable in interface ai.grakn.engine.util.SystemOntologyElements

refershConnections() - Method in class ai.grakn.factory.GraphFactory

RemoteSession - Class in ai.grakn.engine.session

Web socket for running a Graql shell

RemoteSession() - Constructor for class ai.grakn.engine.session.RemoteSession

RemoteSession(Function<String, GraknGraph>) - Constructor for class ai.grakn.engine.session.RemoteSession

removeUser(String) - Method in class ai.grakn.engine.user.SystemKeyspaceUsers

Removes a user with the given username.

removeUser(String) - Method in class ai.grakn.engine.user.UsersHandler

reset() - Method in class ai.grakn.engine.postprocessing.PostProcessing

resume(Consumer<String>, String) - Method in interface ai.grakn.engine.backgroundtasks.BackgroundTask

This method may be called when resuming from a paused state or recovering from a crash or failure of any kind.

resume(Consumer<String>, String) - Method in class ai.grakn.engine.loader.LoaderTask

resume(Consumer<String>, String) - Method in class ai.grakn.engine.postprocessing.PostProcessingTask

run() - Method in class ai.grakn.engine.backgroundtasks.distributed.Scheduler

run() - Method in class ai.grakn.engine.backgroundtasks.distributed.TaskRunner

Start the main loop, this will block until a call to stop().

run() - Method in class ai.grakn.engine.postprocessing.PostProcessing

RUN_AT - Static variable in interface ai.grakn.engine.util.SystemOntologyElements

runAt(Date) - Method in class ai.grakn.engine.backgroundtasks.TaskState

runAt() - Method in class ai.grakn.engine.backgroundtasks.TaskState

RUNNERS_STATE - Static variable in interface ai.grakn.engine.backgroundtasks.config.ZookeeperPaths

RUNNERS_WATCH - Static variable in interface ai.grakn.engine.backgroundtasks.config.ZookeeperPaths

S

SCHEDULED_TASK - Static variable in interface ai.grakn.engine.util.SystemOntologyElements

SCHEDULER - Static variable in interface ai.grakn.engine.backgroundtasks.config.ZookeeperPaths

Scheduler - Class in ai.grakn.engine.backgroundtasks.distributed

Handle execution of recurring tasks.

Scheduler() - Constructor for class ai.grakn.engine.backgroundtasks.distributed.Scheduler

SCHEDULER_POLLING_FREQ - Static variable in class ai.grakn.engine.util.ConfigProperties

SCHEDULERS_GROUP - Static variable in interface ai.grakn.engine.backgroundtasks.config.KafkaTerms

scheduleTask(BackgroundTask, String, Date, long, JSONObject) - Method in class ai.grakn.engine.backgroundtasks.distributed.DistributedTaskManager

scheduleTask(BackgroundTask, String, Date, long, JSONObject) - Method in class ai.grakn.engine.backgroundtasks.standalone.StandaloneTaskManager

scheduleTask(BackgroundTask, String, Date, long, JSONObject) - Method in interface ai.grakn.engine.backgroundtasks.TaskManager

Schedule a single shot/one off BackgroundTask to run after a @delay in milliseconds.

sendQueriesToLoader(Collection<InsertQuery>) - Method in class ai.grakn.engine.loader.Loader

Method to load data into the graph.

SERVER_HOST_NAME - Static variable in class ai.grakn.engine.util.ConfigProperties

SERVER_PORT_NUMBER - Static variable in class ai.grakn.engine.util.ConfigProperties

setBatchSize(int) - Method in class ai.grakn.engine.loader.Loader

Set the size of the each transaction in terms of number of vars.

setConfigProperty(String, String) - Method in class ai.grakn.engine.util.ConfigProperties

setQueueSize(int) - Method in class ai.grakn.engine.loader.Loader

Set the size of the queue- this is equivalent to the size of the semaphore.

signJWT(String) - Static method in class ai.grakn.engine.util.JWTHandler

STACK_TRACE - Static variable in interface ai.grakn.engine.util.SystemOntologyElements

stackTrace(String) - Method in class ai.grakn.engine.backgroundtasks.TaskState

stackTrace() - Method in class ai.grakn.engine.backgroundtasks.TaskState

StandaloneTaskManager - Class in ai.grakn.engine.backgroundtasks.standalone

start(Consumer<String>, JSONObject) - Method in interface ai.grakn.engine.backgroundtasks.BackgroundTask

Called to start execution of the task, may be called on a newly scheduled or previously stopped task.

start() - Method in class ai.grakn.engine.backgroundtasks.distributed.ClusterManager

start(Consumer<String>, JSONObject) - Method in class ai.grakn.engine.loader.LoaderTask

start(Consumer<String>, JSONObject) - Method in class ai.grakn.engine.postprocessing.PostProcessingTask

Run postprocessing only if enough time has passed since the last job was added

startCluster() - Static method in class ai.grakn.engine.GraknEngineServer

startHTTP() - Static method in class ai.grakn.engine.GraknEngineServer

StateStorage - Interface in ai.grakn.engine.backgroundtasks

STATIC_FILES_PATH - Static variable in class ai.grakn.engine.util.ConfigProperties

status(TaskStatus) - Method in class ai.grakn.engine.backgroundtasks.TaskState

status() - Method in class ai.grakn.engine.backgroundtasks.TaskState

status(TaskStatus) - Method in class ai.grakn.engine.backgroundtasks.taskstorage.SynchronizedState

status() - Method in class ai.grakn.engine.backgroundtasks.taskstorage.SynchronizedState

STATUS - Static variable in interface ai.grakn.engine.util.SystemOntologyElements

STATUS_CHANGE_BY - Static variable in interface ai.grakn.engine.util.SystemOntologyElements

STATUS_CHANGE_TIME - Static variable in interface ai.grakn.engine.util.SystemOntologyElements

statusChangedBy(String) - Method in class ai.grakn.engine.backgroundtasks.TaskState

statusChangedBy() - Method in class ai.grakn.engine.backgroundtasks.TaskState

statusChangeTime(Date) - Method in class ai.grakn.engine.backgroundtasks.TaskState

statusChangeTime() - Method in class ai.grakn.engine.backgroundtasks.TaskState

StatusController - Class in ai.grakn.engine.controller

StatusController() - Constructor for class ai.grakn.engine.controller.StatusController

stop() - Method in interface ai.grakn.engine.backgroundtasks.BackgroundTask

Called to stop execution of the task, may be called on a running or paused task.

stop() - Method in class ai.grakn.engine.backgroundtasks.distributed.ClusterManager

stop() - Method in class ai.grakn.engine.loader.LoaderTask

stop() - Method in class ai.grakn.engine.postprocessing.PostProcessing

stop() - Method in class ai.grakn.engine.postprocessing.PostProcessingTask

stopCluster() - Static method in class ai.grakn.engine.GraknEngineServer

stopHTTP() - Static method in class ai.grakn.engine.GraknEngineServer

stopTask(String, String) - Method in class ai.grakn.engine.backgroundtasks.distributed.DistributedTaskManager

stopTask(String, String) - Method in class ai.grakn.engine.backgroundtasks.standalone.StandaloneTaskManager

stopTask(String, String) - Method in interface ai.grakn.engine.backgroundtasks.TaskManager

Stop a Scheduled, Paused or Running task.

storage() - Method in class ai.grakn.engine.backgroundtasks.distributed.DistributedTaskManager

storage() - Method in class ai.grakn.engine.backgroundtasks.standalone.StandaloneTaskManager

storage() - Method in interface ai.grakn.engine.backgroundtasks.TaskManager

Return the StateStorage instance that is used by this class.

SynchronizedState - Class in ai.grakn.engine.backgroundtasks.taskstorage

State to be stored in Zookeeper

SynchronizedState(TaskStatus) - Constructor for class ai.grakn.engine.backgroundtasks.taskstorage.SynchronizedState

SynchronizedStateStorage - Class in ai.grakn.engine.backgroundtasks.taskstorage

Manages the state of background BackgroundTask in a synchronized manner withing a cluster.

SystemKeyspaceUsers - Class in ai.grakn.engine.user

A DAO for managing users in the Grakn system keyspace.

SystemKeyspaceUsers() - Constructor for class ai.grakn.engine.user.SystemKeyspaceUsers

SystemOntologyElements - Interface in ai.grakn.engine.util

T

takeLeadership(CuratorFramework) - Method in class ai.grakn.engine.backgroundtasks.distributed.ClusterManager

When you take over leadership start a new Scheduler instance and wait for it to complete.

TASK_CHECKPOINT - Static variable in interface ai.grakn.engine.util.SystemOntologyElements

TASK_CLASS_NAME - Static variable in interface ai.grakn.engine.util.SystemOntologyElements

TASK_CONFIGURATION - Static variable in interface ai.grakn.engine.util.SystemOntologyElements

TASK_EXCEPTION - Static variable in interface ai.grakn.engine.util.SystemOntologyElements

TASK_LOCK_SUFFIX - Static variable in interface ai.grakn.engine.backgroundtasks.config.ZookeeperPaths

TASK_MANAGER_INSTANCE - Static variable in class ai.grakn.engine.util.ConfigProperties

TASK_RUNNER_GROUP - Static variable in interface ai.grakn.engine.backgroundtasks.config.KafkaTerms

TASK_RUNNERS - Static variable in interface ai.grakn.engine.backgroundtasks.config.ZookeeperPaths

TASK_STATE_SUFFIX - Static variable in interface ai.grakn.engine.backgroundtasks.config.ZookeeperPaths

taskClassName() - Method in class ai.grakn.engine.backgroundtasks.TaskState

TaskFailover - Class in ai.grakn.engine.backgroundtasks.distributed

TaskFailover() - Constructor for class ai.grakn.engine.backgroundtasks.distributed.TaskFailover

TaskManager - Interface in ai.grakn.engine.backgroundtasks

TaskRunner - Class in ai.grakn.engine.backgroundtasks.distributed

TASKRUNNER_POLLING_FREQ - Static variable in class ai.grakn.engine.util.ConfigProperties

TASKS_NAMESPACE - Static variable in interface ai.grakn.engine.backgroundtasks.config.ZookeeperPaths

TASKS_PATH_PREFIX - Static variable in interface ai.grakn.engine.backgroundtasks.config.ZookeeperPaths

TasksController - Class in ai.grakn.engine.controller

TasksController() - Constructor for class ai.grakn.engine.controller.TasksController

TaskState - Class in ai.grakn.engine.backgroundtasks

Internal task state model used to keep track of scheduled tasks.

TaskState(String) - Constructor for class ai.grakn.engine.backgroundtasks.TaskState

TaskStatus - Enum in ai.grakn.engine.backgroundtasks

TEST_CONFIG_FILE - Static variable in class ai.grakn.engine.util.ConfigProperties

TIME_LAPSE - Static variable in class ai.grakn.engine.util.ConfigProperties

toString() - Method in class ai.grakn.engine.backgroundtasks.TaskState

U

updateState(String, TaskStatus, String, String, Throwable, String, JSONObject) - Method in interface ai.grakn.engine.backgroundtasks.StateStorage

Used to update task state.

updateState(String, TaskStatus, String, String, Throwable, String, JSONObject) - Method in class ai.grakn.engine.backgroundtasks.taskstorage.GraknStateStorage

updateState(String, TaskStatus, String, String, Throwable, String, JSONObject) - Method in class ai.grakn.engine.backgroundtasks.taskstorage.InMemoryStateStorage

updateState(String, TaskStatus, String, String) - Method in class ai.grakn.engine.backgroundtasks.taskstorage.SynchronizedStateStorage

updateUser(Json) - Method in class ai.grakn.engine.user.SystemKeyspaceUsers

Update a given user.

updateUser(Json) - Method in class ai.grakn.engine.user.UsersHandler

User - Class in ai.grakn.engine.user

User() - Constructor for class ai.grakn.engine.user.User

USER_EMAIL - Static variable in class ai.grakn.engine.user.UsersHandler

USER_ENTITY - Static variable in class ai.grakn.engine.user.UsersHandler

USER_FIRST_NAME - Static variable in class ai.grakn.engine.user.UsersHandler

USER_IS_ADMIN - Static variable in class ai.grakn.engine.user.UsersHandler

USER_LAST_NAME - Static variable in class ai.grakn.engine.user.UsersHandler

USER_NAME - Static variable in class ai.grakn.engine.user.UsersHandler

USER_PASSWORD - Static variable in class ai.grakn.engine.user.UsersHandler

USER_SALT - Static variable in class ai.grakn.engine.user.UsersHandler

UserController - Class in ai.grakn.engine.controller

UserController() - Constructor for class ai.grakn.engine.controller.UserController

userExists(String) - Method in class ai.grakn.engine.user.SystemKeyspaceUsers

Return true if the user with the specified name exists and false otherwise.

userExists(String) - Method in class ai.grakn.engine.user.UsersHandler

UsersHandler - Class in ai.grakn.engine.user

UsersHandler() - Constructor for class ai.grakn.engine.user.UsersHandler

Utilities - Class in ai.grakn.engine.controller

Methods that will be used by all of the controllers.

Utilities() - Constructor for class ai.grakn.engine.controller.Utilities

V

validateUser(String, String) - Method in class ai.grakn.engine.user.SystemKeyspaceUsers

validateUser(String, String) - Method in class ai.grakn.engine.user.UsersHandler

valueOf(String) - Static method in enum ai.grakn.engine.backgroundtasks.TaskStatus

Returns the enum constant of this type with the specified name.

values() - Static method in enum ai.grakn.engine.backgroundtasks.TaskStatus

Returns an array containing the constants of this enum type, in the order they are declared.

verifyJWT(String) - Static method in class ai.grakn.engine.util.JWTHandler

VisualiserController - Class in ai.grakn.engine.controller

VisualiserController() - Constructor for class ai.grakn.engine.controller.VisualiserController

W

waitToFinish() - Method in class ai.grakn.engine.loader.Loader

Wait for all tasks to finish for one minute.

waitToFinish(int) - Method in class ai.grakn.engine.loader.Loader

Wait for all tasks to finish.

warn(String) - Method in class ai.grakn.engine.backgroundtasks.distributed.KafkaLogger

WORK_QUEUE_TOPIC - Static variable in interface ai.grakn.engine.backgroundtasks.config.KafkaTerms

Z

ZK_BACKOFF_BASE_SLEEP_TIME - Static variable in class ai.grakn.engine.util.ConfigProperties

ZK_BACKOFF_MAX_RETRIES - Static variable in class ai.grakn.engine.util.ConfigProperties

ZK_CONNECTION_TIMEOUT - Static variable in class ai.grakn.engine.util.ConfigProperties

ZK_SERVERS - Static variable in class ai.grakn.engine.util.ConfigProperties

ZK_SESSION_TIMEOUT - Static variable in class ai.grakn.engine.util.ConfigProperties

ZookeeperPaths - Interface in ai.grakn.engine.backgroundtasks.config

A B C D E F G H I J K L M N O P R S T U V W Z