Uses of Class
org.apache.tinkerpop.gremlin.util.message.RequestMessage
-
-
Uses of RequestMessage in org.apache.tinkerpop.gremlin.driver
Methods in org.apache.tinkerpop.gremlin.driver that return RequestMessage Modifier and Type Method Description RequestMessage
ResultSet. getOriginalRequestMessage()
Methods in org.apache.tinkerpop.gremlin.driver with parameters of type RequestMessage Modifier and Type Method Description protected org.apache.tinkerpop.gremlin.driver.Connection
Client.AliasClusteredClient. chooseConnection(RequestMessage msg)
Delegates to the underlyingClient.ClusteredClient
.protected abstract org.apache.tinkerpop.gremlin.driver.Connection
Client. chooseConnection(RequestMessage msg)
Chooses aConnection
to write the message to.protected org.apache.tinkerpop.gremlin.driver.Connection
Client.ClusteredClient. chooseConnection(RequestMessage msg)
Uses aLoadBalancingStrategy
to choose the bestHost
and then selects the best connection from that host's connection pool.Iterator<Host>
LoadBalancingStrategy.RoundRobin. select(RequestMessage msg)
Iterator<Host>
LoadBalancingStrategy. select(RequestMessage msg)
Provide an ordered list of hosts to send the givenRequestMessage
to.CompletableFuture<ResultSet>
Client.AliasClusteredClient. submitAsync(RequestMessage msg)
CompletableFuture<ResultSet>
Client. submitAsync(RequestMessage msg)
A low-level method that allows the submission of a manually constructedRequestMessage
.Constructors in org.apache.tinkerpop.gremlin.driver with parameters of type RequestMessage Constructor Description ResultSet(ResultQueue resultQueue, ExecutorService executor, CompletableFuture<Void> readCompleted, RequestMessage originalRequestMessage, Host host)
-
Uses of RequestMessage in org.apache.tinkerpop.gremlin.driver.handler
Methods in org.apache.tinkerpop.gremlin.driver.handler with parameters of type RequestMessage Modifier and Type Method Description protected void
HttpGremlinRequestEncoder. encode(io.netty.channel.ChannelHandlerContext channelHandlerContext, RequestMessage requestMessage, List<Object> objects)
-
Uses of RequestMessage in org.apache.tinkerpop.gremlin.driver.simple
Methods in org.apache.tinkerpop.gremlin.driver.simple with parameters of type RequestMessage Modifier and Type Method Description List<ResponseMessage>
AbstractClient. submit(RequestMessage requestMessage)
void
AbstractClient. submit(RequestMessage requestMessage, Consumer<ResponseMessage> callback)
List<ResponseMessage>
SimpleClient. submit(RequestMessage requestMessage)
void
SimpleClient. submit(RequestMessage requestMessage, Consumer<ResponseMessage> callback)
CompletableFuture<List<ResponseMessage>>
SimpleClient. submitAsync(RequestMessage requestMessage)
CompletableFuture<List<ResponseMessage>>
SimpleHttpClient. submitAsync(RequestMessage requestMessage)
abstract void
AbstractClient. writeAndFlush(RequestMessage requestMessage)
void
SimpleHttpClient. writeAndFlush(RequestMessage requestMessage)
-
Uses of RequestMessage in org.apache.tinkerpop.gremlin.server
Methods in org.apache.tinkerpop.gremlin.server that return RequestMessage Modifier and Type Method Description RequestMessage
Context. getRequestMessage()
Gets the current request to Gremlin Server.Constructors in org.apache.tinkerpop.gremlin.server with parameters of type RequestMessage Constructor Description Context(RequestMessage requestMessage, io.netty.channel.ChannelHandlerContext ctx, Settings settings, GraphManager graphManager, GremlinExecutor gremlinExecutor, ScheduledExecutorService scheduledExecutorService)
Context(RequestMessage requestMessage, io.netty.channel.ChannelHandlerContext ctx, Settings settings, GraphManager graphManager, GremlinExecutor gremlinExecutor, ScheduledExecutorService scheduledExecutorService, HttpGremlinEndpointHandler.RequestState requestState)
-
Uses of RequestMessage in org.apache.tinkerpop.gremlin.server.authz
Methods in org.apache.tinkerpop.gremlin.server.authz with parameters of type RequestMessage Modifier and Type Method Description void
Authorizer. authorize(AuthenticatedUser user, RequestMessage msg)
Checks whether a user is authorized to have a script request from a gremlin client answered and raises anAuthorizationException
if this is not the case. -
Uses of RequestMessage in org.apache.tinkerpop.gremlin.server.handler
Methods in org.apache.tinkerpop.gremlin.server.handler that return RequestMessage Modifier and Type Method Description RequestMessage
HttpRequestMessageDecoder. getRequestMessageFromHttpRequest(io.netty.handler.codec.http.FullHttpRequest request, Map<String,MessageSerializer<?>> serializers)
Convert a http request into aRequestMessage
.Methods in org.apache.tinkerpop.gremlin.server.handler with parameters of type RequestMessage Modifier and Type Method Description void
HttpGremlinEndpointHandler. channelRead0(io.netty.channel.ChannelHandlerContext ctx, RequestMessage requestMessage)
-
Uses of RequestMessage in org.apache.tinkerpop.gremlin.server.util
Methods in org.apache.tinkerpop.gremlin.server.util that return RequestMessage Modifier and Type Method Description RequestMessage
TextPlainMessageSerializer. deserializeBinaryRequest(io.netty.buffer.ByteBuf msg)
Methods in org.apache.tinkerpop.gremlin.server.util with parameters of type RequestMessage Modifier and Type Method Description static GremlinError
GremlinError. invalidGremlinType(RequestMessage requestMessage)
static GremlinError
GremlinError. longRequest(RequestMessage requestMessage)
io.netty.buffer.ByteBuf
TextPlainMessageSerializer. serializeRequestAsBinary(RequestMessage requestMessage, io.netty.buffer.ByteBufAllocator allocator)
static GremlinError
GremlinError. timeout(RequestMessage requestMessage)
-
Uses of RequestMessage in org.apache.tinkerpop.gremlin.util
Methods in org.apache.tinkerpop.gremlin.util that return RequestMessage Modifier and Type Method Description RequestMessage
MessageSerializer. deserializeBinaryRequest(io.netty.buffer.ByteBuf msg)
Deserialize a NettyByteBuf
into aRequestMessage
.Methods in org.apache.tinkerpop.gremlin.util with parameters of type RequestMessage Modifier and Type Method Description io.netty.buffer.ByteBuf
MessageSerializer. serializeRequestAsBinary(RequestMessage requestMessage, io.netty.buffer.ByteBufAllocator allocator)
Serialize aResponseMessage
to a NettyByteBuf
. -
Uses of RequestMessage in org.apache.tinkerpop.gremlin.util.message
Methods in org.apache.tinkerpop.gremlin.util.message that return RequestMessage Modifier and Type Method Description RequestMessage
RequestMessage.Builder. create()
Create the request message given the settings provided to theRequestMessage.Builder
.RequestMessage
RequestMessage. trimMessage(int size)
Methods in org.apache.tinkerpop.gremlin.util.message with parameters of type RequestMessage Modifier and Type Method Description static RequestMessage.Builder
RequestMessage. from(RequestMessage msg)
static RequestMessage.Builder
RequestMessage. from(RequestMessage msg, String gremlin)
-
Uses of RequestMessage in org.apache.tinkerpop.gremlin.util.ser
Methods in org.apache.tinkerpop.gremlin.util.ser that return RequestMessage Modifier and Type Method Description RequestMessage
AbstractGraphSONMessageSerializerV4.RequestMessageDeserializer. createObject(Map<String,Object> data)
RequestMessage
AbstractGraphSONMessageSerializerV4. deserializeBinaryRequest(io.netty.buffer.ByteBuf msg)
RequestMessage
GraphBinaryMessageSerializerV4. deserializeBinaryRequest(io.netty.buffer.ByteBuf msg)
Methods in org.apache.tinkerpop.gremlin.util.ser with parameters of type RequestMessage Modifier and Type Method Description void
AbstractGraphSONMessageSerializerV4.RequestMessageSerializer. ser(RequestMessage requestMessage, org.apache.tinkerpop.shaded.jackson.core.JsonGenerator jsonGenerator, org.apache.tinkerpop.shaded.jackson.databind.SerializerProvider serializerProvider, org.apache.tinkerpop.shaded.jackson.databind.jsontype.TypeSerializer typeSerializer)
void
AbstractGraphSONMessageSerializerV4.RequestMessageSerializer. serialize(RequestMessage requestMessage, org.apache.tinkerpop.shaded.jackson.core.JsonGenerator jsonGenerator, org.apache.tinkerpop.shaded.jackson.databind.SerializerProvider serializerProvider)
io.netty.buffer.ByteBuf
AbstractGraphSONMessageSerializerV4. serializeRequestAsBinary(RequestMessage requestMessage, io.netty.buffer.ByteBufAllocator allocator)
io.netty.buffer.ByteBuf
GraphBinaryMessageSerializerV4. serializeRequestAsBinary(RequestMessage requestMessage, io.netty.buffer.ByteBufAllocator allocator)
void
AbstractGraphSONMessageSerializerV4.RequestMessageSerializer. serializeWithType(RequestMessage requestMessage, org.apache.tinkerpop.shaded.jackson.core.JsonGenerator jsonGenerator, org.apache.tinkerpop.shaded.jackson.databind.SerializerProvider serializerProvider, org.apache.tinkerpop.shaded.jackson.databind.jsontype.TypeSerializer typeSerializer)
-
Uses of RequestMessage in org.apache.tinkerpop.gremlin.util.ser.binary
Methods in org.apache.tinkerpop.gremlin.util.ser.binary that return RequestMessage Modifier and Type Method Description RequestMessage
RequestMessageSerializer. readValue(io.netty.buffer.ByteBuf byteBuf, GraphBinaryReader context)
Methods in org.apache.tinkerpop.gremlin.util.ser.binary with parameters of type RequestMessage Modifier and Type Method Description void
RequestMessageSerializer. writeValue(RequestMessage value, io.netty.buffer.ByteBuf byteBuf, GraphBinaryWriter context)
-