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_SESSION value to every RequestMessage . |
RequestMessage |
MessageSerializer.deserializeRequest(ByteBuf msg)
Deserialize a Netty
ByteBuf into a RequestMessage . |
Modifier and Type | Method and Description |
---|---|
protected abstract org.apache.tinkerpop.gremlin.driver.Connection |
Client.chooseConnection(RequestMessage msg)
Chooses a
Connection to write the message to. |
protected org.apache.tinkerpop.gremlin.driver.Connection |
Client.ClusteredClient.chooseConnection(RequestMessage msg)
Uses a
LoadBalancingStrategy to choose the best Host and 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
RequestMessage to. |
Iterator<Host> |
LoadBalancingStrategy.RoundRobin.select(RequestMessage msg) |
ByteBuf |
MessageSerializer.serializeRequestAsBinary(RequestMessage requestMessage,
ByteBufAllocator allocator)
Serialize a
ResponseMessage to a Netty ByteBuf . |
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.INVALID
An "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 |
SimpleClient.submit(RequestMessage requestMessage,
Consumer<ResponseMessage> callback) |
void |
NioClient.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 |
---|---|
protected Optional<ThrowingConsumer<Context>> |
AbstractEvalOpProcessor.validateEvalMessage(RequestMessage message) |
Modifier and Type | Method and Description |
---|---|
protected Optional<ThrowingConsumer<Context>> |
SessionOpProcessor.validateEvalMessage(RequestMessage message) |
Copyright © 2013–2015 Apache Software Foundation. All rights reserved.