Modifier and Type | Method and Description |
---|---|
ThrowingConsumer<Context> |
OpProcessor.select(Context ctx)
Given the context (which contains the RequestMessage), return back a Consumer function that will be
executed with the context.
|
Modifier and Type | Method and Description |
---|---|
ThrowingConsumer<Context> |
OpProcessor.select(Context ctx)
Given the context (which contains the RequestMessage), return back a Consumer function that will be
executed with the context.
|
Modifier and Type | Class and Description |
---|---|
class |
SessionTask
A
SessionTask equates to a particular incoming request to the UnifiedHandler and is analogous to
a Context in the OpProcessor approach to handling requests to the server. |
Modifier and Type | Method and Description |
---|---|
abstract ThrowingConsumer<Context> |
AbstractEvalOpProcessor.getEvalOp()
Provides an operation for evaluating a Gremlin script.
|
ThrowingConsumer<Context> |
AbstractEvalOpProcessor.select(Context ctx) |
abstract Optional<ThrowingConsumer<Context>> |
AbstractEvalOpProcessor.selectOther(Context ctx)
A sub-class may have additional "ops" that it will service.
|
protected Optional<ThrowingConsumer<Context>> |
AbstractEvalOpProcessor.validateEvalMessage(RequestMessage message) |
Modifier and Type | Method and Description |
---|---|
protected void |
AbstractEvalOpProcessor.evalOpInternal(Context ctx,
Supplier<GremlinExecutor> gremlinExecutorSupplier,
AbstractEvalOpProcessor.BindingSupplier bindingsSupplier)
A generalized implementation of the "eval" operation.
|
protected void |
AbstractOpProcessor.handleIterator(Context context,
Iterator itty)
Provides a generic way of iterating a result set back to the client.
|
protected static Frame |
AbstractOpProcessor.makeFrame(Context ctx,
RequestMessage msg,
MessageSerializer<?> serializer,
boolean useBinary,
List<Object> aggregate,
ResponseStatusCode code,
Map<String,Object> responseMetaData,
Map<String,Object> statusAttributes) |
ThrowingConsumer<Context> |
AbstractEvalOpProcessor.select(Context ctx) |
abstract Optional<ThrowingConsumer<Context>> |
AbstractEvalOpProcessor.selectOther(Context ctx)
A sub-class may have additional "ops" that it will service.
|
Modifier and Type | Method and Description |
---|---|
protected Function<Context,AbstractEvalOpProcessor.BindingSupplier> |
SessionOpProcessor.getBindingMaker(Session session)
A useful method for those extending this class, where the means for binding construction can be supplied
to this class.
|
ThrowingConsumer<Context> |
SessionOpProcessor.getEvalOp() |
Optional<ThrowingConsumer<Context>> |
SessionOpProcessor.selectOther(Context ctx)
Older versions of session-based requests accepted a "close" operator in addition to "eval".
|
protected Optional<ThrowingConsumer<Context>> |
SessionOpProcessor.validateEvalMessage(RequestMessage message) |
Modifier and Type | Method and Description |
---|---|
protected void |
SessionOpProcessor.beforeProcessing(Graph graph,
Context ctx) |
protected void |
SessionOpProcessor.evalOp(Context context) |
protected static Session |
SessionOpProcessor.getSession(Context context,
RequestMessage msg)
Examines the
RequestMessage and extracts the session token. |
protected void |
SessionOpProcessor.handleGraphOperation(Bytecode bytecode,
Graph graph,
Context context)
If
Bytecode is detected to contain a "graph operation" then it gets processed by this method. |
protected void |
SessionOpProcessor.handleIterator(Context context,
Iterator itty,
Graph graph) |
protected void |
SessionOpProcessor.onError(Graph graph,
Context ctx) |
protected void |
SessionOpProcessor.onTraversalSuccess(Graph graph,
Context ctx) |
Optional<ThrowingConsumer<Context>> |
SessionOpProcessor.selectOther(Context ctx)
Older versions of session-based requests accepted a "close" operator in addition to "eval".
|
Constructor and Description |
---|
Session(String session,
Context context,
ConcurrentHashMap<String,Session> sessions) |
Modifier and Type | Field and Description |
---|---|
protected Function<Context,AbstractEvalOpProcessor.BindingSupplier> |
StandardOpProcessor.bindingMaker |
Modifier and Type | Method and Description |
---|---|
protected Function<Context,AbstractEvalOpProcessor.BindingSupplier> |
StandardOpProcessor.getBindingMaker()
A useful method for those extending this class, where the means for binding construction can be supplied
to this class.
|
ThrowingConsumer<Context> |
StandardOpProcessor.getEvalOp() |
Optional<ThrowingConsumer<Context>> |
StandardOpProcessor.selectOther(Context ctx) |
Modifier and Type | Method and Description |
---|---|
Optional<ThrowingConsumer<Context>> |
StandardOpProcessor.selectOther(Context ctx) |
Modifier and Type | Method and Description |
---|---|
ThrowingConsumer<Context> |
TraversalOpProcessor.select(Context context) |
Modifier and Type | Method and Description |
---|---|
protected void |
TraversalOpProcessor.beforeProcessing(Graph graph,
Context ctx) |
protected void |
TraversalOpProcessor.handleIterator(Context context,
Iterator itty,
Graph graph) |
protected void |
TraversalOpProcessor.onError(Graph graph,
Context ctx) |
protected void |
TraversalOpProcessor.onTraversalSuccess(Graph graph,
Context ctx) |
ThrowingConsumer<Context> |
TraversalOpProcessor.select(Context context) |
Copyright © 2013–2021 Apache Software Foundation. All rights reserved.