| 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  | SessionTaskA  SessionTaskequates to a particular incoming request to theUnifiedHandlerand is analogous to
 aContextin theOpProcessorapproach to handling requests to the server. | 
| Modifier and Type | Method and Description | 
|---|---|
| protected void | OpExecutorHandler. channelRead0(io.netty.channel.ChannelHandlerContext ctx,
            org.javatuples.Pair<RequestMessage,ThrowingConsumer<Context>> objects) | 
| 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  RequestMessageand extracts the session token. | 
| protected void | SessionOpProcessor. handleGraphOperation(Bytecode bytecode,
                    Graph graph,
                    Context context)If  Bytecodeis 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,
       Throwable error) | 
| protected void | TraversalOpProcessor. onTraversalSuccess(Graph graph,
                  Context ctx) | 
| ThrowingConsumer<Context> | TraversalOpProcessor. select(Context context) | 
Copyright © 2013–2023 Apache Software Foundation. All rights reserved.