A C D E G H I L M N P Q R S T V W

A

ai.grakn.redisq - package ai.grakn.redisq

ai.grakn.redisq.consumer - package ai.grakn.redisq.consumer

ai.grakn.redisq.exceptions - package ai.grakn.redisq.exceptions

ai.grakn.redisq.util - package ai.grakn.redisq.util

C

cancel(boolean) - Method in class ai.grakn.redisq.StateFuture

close() - Method in interface ai.grakn.redisq.Queue

Sets a flag and waits for all the running threads to terminate

close() - Method in class ai.grakn.redisq.Redisq

contentKeyFromId(String) - Method in class ai.grakn.redisq.util.Names

createRedisq() - Method in class ai.grakn.redisq.RedisqBuilder

D

DeserializationException - Exception in ai.grakn.redisq.exceptions

DeserializationException(String, String, Throwable) - Constructor for exception ai.grakn.redisq.exceptions.DeserializationException

deserialize(String) - Method in class ai.grakn.redisq.consumer.Mapper

Document - Interface in ai.grakn.redisq

Document stored in the queue.

E

equals(Object) - Method in class ai.grakn.redisq.StateFuture

ExtendedStateInfo - Class in ai.grakn.redisq

ExtendedStateInfo() - Constructor for class ai.grakn.redisq.ExtendedStateInfo

ExtendedStateInfo(String, StateInfo) - Constructor for class ai.grakn.redisq.ExtendedStateInfo

G

get() - Method in class ai.grakn.redisq.StateFuture

get(long, TimeUnit) - Method in class ai.grakn.redisq.StateFuture

getConsumer() - Method in interface ai.grakn.redisq.Queue

Getter for the consumer being used

getConsumer() - Method in class ai.grakn.redisq.Redisq

getElement() - Method in class ai.grakn.redisq.consumer.TimedWrap

getElement() - Method in exception ai.grakn.redisq.exceptions.DeserializationException

getElement() - Method in exception ai.grakn.redisq.exceptions.SerializationException

getFutureForDocumentStateWait(Set<State>, String) - Method in interface ai.grakn.redisq.Queue

It returns a future that waits for a document to reach a certain state Note that this works for DONE and FAILED since they are terminal states.

getFutureForDocumentStateWait(Set<State>, String, long, TimeUnit, Pool<Jedis>) - Method in interface ai.grakn.redisq.Queue

getFutureForDocumentStateWait(Set<State>, String) - Method in class ai.grakn.redisq.Redisq

getFutureForDocumentStateWait(Set<State>, String, long, TimeUnit, Pool<Jedis>) - Method in class ai.grakn.redisq.Redisq

getId() - Method in class ai.grakn.redisq.ExtendedStateInfo

getIdAsString() - Method in interface ai.grakn.redisq.Document

It returns the id of the document

getInfo() - Method in class ai.grakn.redisq.StateInfo

getLastProcessed() - Method in class ai.grakn.redisq.StateInfo

getName() - Method in interface ai.grakn.redisq.Queue

Getter for the name of the queue

getName() - Method in class ai.grakn.redisq.Redisq

getNames() - Method in class ai.grakn.redisq.Redisq

getRandomString() - Static method in class ai.grakn.redisq.util.Names

getState(String) - Method in interface ai.grakn.redisq.Queue

Retrieves the state for the given id

getState(String) - Method in class ai.grakn.redisq.Redisq

getState() - Method in class ai.grakn.redisq.StateInfo

getStateInfo() - Method in class ai.grakn.redisq.ExtendedStateInfo

getStates() - Method in interface ai.grakn.redisq.Queue

Retrieves all the states.

getStates() - Method in class ai.grakn.redisq.Redisq

getTimestampMs() - Method in class ai.grakn.redisq.consumer.TimedWrap

H

hashCode() - Method in class ai.grakn.redisq.StateFuture

I

inFlightQueueNameFor(String) - Method in class ai.grakn.redisq.util.Names

isCancelled() - Method in class ai.grakn.redisq.StateFuture

isDone() - Method in class ai.grakn.redisq.StateFuture

isFinal() - Method in enum ai.grakn.redisq.State

L

lockKeyFromId(String) - Method in class ai.grakn.redisq.util.Names

M

Mapper<T> - Class in ai.grakn.redisq.consumer

Utility class that factors Jackson serialise/deserialise logic

Mapper(JavaType) - Constructor for class ai.grakn.redisq.consumer.Mapper

Mapper(Class<T>) - Constructor for class ai.grakn.redisq.consumer.Mapper

N

Names - Class in ai.grakn.redisq.util

Names() - Constructor for class ai.grakn.redisq.util.Names

P

process(T) - Method in interface ai.grakn.redisq.consumer.QueueConsumer

This method implements the logic for consuming documents from the queue.

process(T) - Method in class ai.grakn.redisq.consumer.RedisqConsumer

push(T) - Method in interface ai.grakn.redisq.Queue

Put a document in the queue

push(T) - Method in class ai.grakn.redisq.Redisq

pushAndWait(T, long, TimeUnit) - Method in interface ai.grakn.redisq.Queue

Same as push but it waits for the state of the document to be DONE i.e.

pushAndWait(T, long, TimeUnit) - Method in class ai.grakn.redisq.Redisq

Q

Queue<T> - Interface in ai.grakn.redisq

QueueConsumer<T> - Interface in ai.grakn.redisq.consumer

Interface for queue consumers.

queueNameFor(String) - Method in class ai.grakn.redisq.util.Names

R

Redisq<T extends Document> - Class in ai.grakn.redisq

Redisq(String, Duration, Duration, Duration, Duration, Consumer<T>, Class<T>, Pool<Jedis>, ExecutorService, MetricRegistry) - Constructor for class ai.grakn.redisq.Redisq

RedisqBuilder<T extends Document> - Class in ai.grakn.redisq

RedisqBuilder() - Constructor for class ai.grakn.redisq.RedisqBuilder

RedisqConsumer<T extends Document> - Class in ai.grakn.redisq.consumer

TODO: docs

RedisqConsumer(Consumer<T>, Pool<Jedis>, Redisq<T>) - Constructor for class ai.grakn.redisq.consumer.RedisqConsumer

TODO: docs

RedisqException - Exception in ai.grakn.redisq.exceptions

RedisqException(String, Exception) - Constructor for exception ai.grakn.redisq.exceptions.RedisqException

RedisqException(String) - Constructor for exception ai.grakn.redisq.exceptions.RedisqException

S

SerializationException - Exception in ai.grakn.redisq.exceptions

SerializationException(String, Object) - Constructor for exception ai.grakn.redisq.exceptions.SerializationException

SerializationException(String, Object, Throwable) - Constructor for exception ai.grakn.redisq.exceptions.SerializationException

serialize(T) - Method in class ai.grakn.redisq.consumer.Mapper

setConsumer(Consumer<T>) - Method in class ai.grakn.redisq.RedisqBuilder

setDiscardTime(Duration) - Method in class ai.grakn.redisq.RedisqBuilder

setDocumentClass(Class<T>) - Method in class ai.grakn.redisq.RedisqBuilder

setJedisPool(Pool<Jedis>) - Method in class ai.grakn.redisq.RedisqBuilder

setLockTime(Duration) - Method in class ai.grakn.redisq.RedisqBuilder

setMetricRegistry(MetricRegistry) - Method in class ai.grakn.redisq.RedisqBuilder

setName(String) - Method in class ai.grakn.redisq.RedisqBuilder

setState(String, State) - Method in interface ai.grakn.redisq.Queue

setState(String, State, String) - Method in interface ai.grakn.redisq.Queue

Sets a state "manually"

setState(String, State, String) - Method in class ai.grakn.redisq.Redisq

setState(Jedis, long, String, State, String) - Method in class ai.grakn.redisq.Redisq

setThreadPool(ExecutorService) - Method in class ai.grakn.redisq.RedisqBuilder

setTimeout(Duration) - Method in class ai.grakn.redisq.RedisqBuilder

setTtlStateInfo(Duration) - Method in class ai.grakn.redisq.RedisqBuilder

startConsumer() - Method in interface ai.grakn.redisq.Queue

Starts the comsumer for this queue.

startConsumer() - Method in class ai.grakn.redisq.Redisq

State - Enum in ai.grakn.redisq

stateChannelKeyFromId(String) - Method in class ai.grakn.redisq.util.Names

StateFuture - Class in ai.grakn.redisq

StateFutureInitializationException - Exception in ai.grakn.redisq.exceptions

StateFutureInitializationException(String, InterruptedException) - Constructor for exception ai.grakn.redisq.exceptions.StateFutureInitializationException

StateInfo - Class in ai.grakn.redisq

StateInfo() - Constructor for class ai.grakn.redisq.StateInfo

StateInfo(State, long, String) - Constructor for class ai.grakn.redisq.StateInfo

stateKeyFromId(String) - Method in class ai.grakn.redisq.util.Names

SubscriptionInterruptedException - Exception in ai.grakn.redisq.exceptions

SubscriptionInterruptedException(String, Exception) - Constructor for exception ai.grakn.redisq.exceptions.SubscriptionInterruptedException

T

TimedWrap<T> - Class in ai.grakn.redisq.consumer

TimedWrap() - Constructor for class ai.grakn.redisq.consumer.TimedWrap

TimedWrap(T, long) - Constructor for class ai.grakn.redisq.consumer.TimedWrap

toString() - Method in class ai.grakn.redisq.ExtendedStateInfo

toString() - Method in class ai.grakn.redisq.StateInfo

V

valueOf(String) - Static method in enum ai.grakn.redisq.State

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

values() - Static method in enum ai.grakn.redisq.State

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

W

WaitException - Exception in ai.grakn.redisq.exceptions

WaitException(String, Exception) - Constructor for exception ai.grakn.redisq.exceptions.WaitException

A C D E G H I L M N P Q R S T V W