| Modifier and Type | Method and Description | 
|---|---|
| RequestMessage | Client. buildMessage(RequestMessage.Builder builder)Makes any final changes to the builder and returns the constructed  RequestMessage. | 
| RequestMessage | Client.ReboundClusteredClient. buildMessage(RequestMessage.Builder builder) | 
| RequestMessage | Client.SessionedClient. buildMessage(RequestMessage.Builder builder)Adds the  Tokens.ARGS_SESSIONvalue to everyRequestMessage. | 
| RequestMessage | MessageSerializer. deserializeRequest(ByteBuf msg)Deserialize a Netty  ByteBufinto aRequestMessage. | 
| Modifier and Type | Method and Description | 
|---|---|
| protected abstract org.apache.tinkerpop.gremlin.driver.Connection | Client. chooseConnection(RequestMessage msg)Chooses a  Connectionto write the message to. | 
| protected org.apache.tinkerpop.gremlin.driver.Connection | Client.ClusteredClient. chooseConnection(RequestMessage msg)Uses a  LoadBalancingStrategyto choose the bestHostand then selects the best connection
 from that host's connection pool. | 
| protected org.apache.tinkerpop.gremlin.driver.Connection | Client.ReboundClusteredClient. chooseConnection(RequestMessage msg)Delegates to the underlying  Client.ClusteredClient. | 
| protected org.apache.tinkerpop.gremlin.driver.Connection | Client.SessionedClient. chooseConnection(RequestMessage msg)Since the session is bound to a single host, simply borrow a connection from that pool. | 
| Iterator<Host> | LoadBalancingStrategy. select(RequestMessage msg)Provide an ordered list of hosts to send the the given  RequestMessageto. | 
| Iterator<Host> | LoadBalancingStrategy.RoundRobin. select(RequestMessage msg) | 
| ByteBuf | MessageSerializer. serializeRequestAsBinary(RequestMessage requestMessage,
                        ByteBufAllocator allocator)Serialize a  ResponseMessageto a NettyByteBuf. | 
| CompletableFuture<ResultSet> | Client. submitAsync(RequestMessage msg)A low-level method that allows the submission of a manually constructed  RequestMessage. | 
| Modifier and Type | Method and Description | 
|---|---|
| protected void | WebSocketGremlinRequestEncoder. encode(ChannelHandlerContext channelHandlerContext,
      RequestMessage requestMessage,
      List<Object> objects) | 
| Modifier and Type | Field and Description | 
|---|---|
| static RequestMessage | RequestMessage. INVALIDAn "invalid" message. | 
| Modifier and Type | Method and Description | 
|---|---|
| RequestMessage | RequestMessage.Builder. create()Create the request message given the settings provided to the  RequestMessage.Builder. | 
| Modifier and Type | Method and Description | 
|---|---|
| static ResponseMessage.Builder | ResponseMessage. build(RequestMessage requestMessage) | 
| Modifier and Type | Method and Description | 
|---|---|
| RequestMessage | AbstractGraphSONMessageSerializerV1d0. deserializeRequest(ByteBuf msg) | 
| RequestMessage | GryoMessageSerializerV1d0. deserializeRequest(ByteBuf msg) | 
| RequestMessage | GraphSONMessageSerializerV1d0. deserializeRequest(String msg) | 
| RequestMessage | MessageTextSerializer. deserializeRequest(String msg) | 
| Modifier and Type | Method and Description | 
|---|---|
| ByteBuf | AbstractGraphSONMessageSerializerV1d0. serializeRequestAsBinary(RequestMessage requestMessage,
                        ByteBufAllocator allocator) | 
| ByteBuf | GryoMessageSerializerV1d0. serializeRequestAsBinary(RequestMessage requestMessage,
                        ByteBufAllocator allocator) | 
| String | GraphSONMessageSerializerV1d0. serializeRequestAsString(RequestMessage requestMessage) | 
| String | MessageTextSerializer. serializeRequestAsString(RequestMessage requestMessage) | 
| Modifier and Type | Method and Description | 
|---|---|
| void | NioClient. submit(RequestMessage requestMessage,
      Consumer<ResponseMessage> callback) | 
| void | SimpleClient. submit(RequestMessage requestMessage,
      Consumer<ResponseMessage> callback) | 
| void | WebSocketClient. submit(RequestMessage requestMessage,
      Consumer<ResponseMessage> callback) | 
| Modifier and Type | Method and Description | 
|---|---|
| RequestMessage | Context. getRequestMessage()Gets the current request to Gremlin Server. | 
| Constructor and Description | 
|---|
| Context(RequestMessage requestMessage,
       ChannelHandlerContext ctx,
       Settings settings,
       GraphManager graphManager,
       GremlinExecutor gremlinExecutor,
       ScheduledExecutorService scheduledExecutorService) | 
| Modifier and Type | Method and Description | 
|---|---|
| protected void | OpSelectorHandler. decode(ChannelHandlerContext ctx,
      RequestMessage msg,
      List<Object> objects) | 
| Modifier and Type | Method and Description | 
|---|---|
| abstract Optional<ThrowingConsumer<Context>> | AbstractEvalOpProcessor. selectOther(RequestMessage requestMessage)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 static Session | SessionOpProcessor. getSession(Context context,
          RequestMessage msg)Examines the  RequestMessageand extracts the session token. | 
| Optional<ThrowingConsumer<Context>> | SessionOpProcessor. selectOther(RequestMessage requestMessage)Session based requests accept a "close" operator in addition to "eval". | 
| protected Optional<ThrowingConsumer<Context>> | SessionOpProcessor. validateEvalMessage(RequestMessage message) | 
| Modifier and Type | Method and Description | 
|---|---|
| Optional<ThrowingConsumer<Context>> | StandardOpProcessor. selectOther(RequestMessage requestMessage) | 
Copyright © 2013–2015 Apache Software Foundation. All rights reserved.