| Package | Description |
|---|---|
| ai.grakn.redisq |
| Modifier and Type | Method and Description |
|---|---|
State |
StateInfo.getState() |
static State |
State.valueOf(String name)
Returns the enum constant of this type with the specified name.
|
static State[] |
State.values()
Returns an array containing the constants of this enum type, in
the order they are declared.
|
| Modifier and Type | Method and Description |
|---|---|
void |
Redisq.setState(redis.clients.jedis.Jedis jedis,
long timestampMs,
String id,
State state,
String info) |
default void |
Queue.setState(String id,
State state) |
void |
Redisq.setState(String id,
State state,
String info) |
void |
Queue.setState(String id,
State state,
String info)
Sets a state "manually"
|
| Modifier and Type | Method and Description |
|---|---|
Future<Void> |
Redisq.getFutureForDocumentStateWait(Set<State> state,
String id) |
Future<Void> |
Queue.getFutureForDocumentStateWait(Set<State> state,
String id)
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.
|
Future<Void> |
Redisq.getFutureForDocumentStateWait(Set<State> state,
String id,
long timeout,
TimeUnit unit,
redis.clients.util.Pool<redis.clients.jedis.Jedis> pool) |
Future<Void> |
Queue.getFutureForDocumentStateWait(Set<State> state,
String id,
long timeout,
TimeUnit unit,
redis.clients.util.Pool<redis.clients.jedis.Jedis> pool) |
| Constructor and Description |
|---|
StateInfo(State state,
long lastProcessed,
String info) |
Copyright © 2017. All rights reserved.