Modifier and Type | Method and Description |
---|---|
ResponseMessage |
MessageSerializer.deserializeResponse(io.netty.buffer.ByteBuf msg)
Deserialize a Netty
ByteBuf into a ResponseMessage . |
Modifier and Type | Method and Description |
---|---|
io.netty.buffer.ByteBuf |
MessageSerializer.serializeResponseAsBinary(ResponseMessage responseMessage,
io.netty.buffer.ByteBufAllocator allocator)
Serialize a
ResponseMessage to a Netty ByteBuf . |
Modifier and Type | Method and Description |
---|---|
ResponseMessage |
ResponseMessage.Builder.create() |
Modifier and Type | Method and Description |
---|---|
ResponseMessage |
AbstractGraphSONMessageSerializerV2d0.ResponseMessageDeserializer.createObject(Map<String,Object> data) |
ResponseMessage |
AbstractGraphSONMessageSerializerV2d0.deserializeResponse(io.netty.buffer.ByteBuf msg) |
ResponseMessage |
AbstractGraphSONMessageSerializerV1d0.deserializeResponse(io.netty.buffer.ByteBuf msg) |
ResponseMessage |
GraphBinaryMessageSerializerV1.deserializeResponse(io.netty.buffer.ByteBuf msg) |
ResponseMessage |
MessageTextSerializer.deserializeResponse(String msg) |
ResponseMessage |
GraphSONMessageSerializerV2d0.deserializeResponse(String msg) |
ResponseMessage |
GraphSONMessageSerializerV3d0.deserializeResponse(String msg) |
ResponseMessage |
GraphSONMessageSerializerV1d0.deserializeResponse(String msg) |
<I extends InputShim> |
ResponseMessageGryoSerializer.read(KryoShim<I,?> kryo,
I input,
Class<ResponseMessage> clazz) |
Modifier and Type | Method and Description |
---|---|
void |
AbstractGraphSONMessageSerializerV2d0.ResponseMessageSerializer.ser(ResponseMessage responseMessage,
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 |
AbstractGraphSONMessageSerializerV1d0.ResponseMessageSerializer.ser(ResponseMessage responseMessage,
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 |
AbstractGraphSONMessageSerializerV2d0.ResponseMessageSerializer.serialize(ResponseMessage responseMessage,
org.apache.tinkerpop.shaded.jackson.core.JsonGenerator jsonGenerator,
org.apache.tinkerpop.shaded.jackson.databind.SerializerProvider serializerProvider) |
void |
AbstractGraphSONMessageSerializerV1d0.ResponseMessageSerializer.serialize(ResponseMessage responseMessage,
org.apache.tinkerpop.shaded.jackson.core.JsonGenerator jsonGenerator,
org.apache.tinkerpop.shaded.jackson.databind.SerializerProvider serializerProvider) |
io.netty.buffer.ByteBuf |
AbstractGraphSONMessageSerializerV2d0.serializeResponseAsBinary(ResponseMessage responseMessage,
io.netty.buffer.ByteBufAllocator allocator) |
io.netty.buffer.ByteBuf |
AbstractGraphSONMessageSerializerV1d0.serializeResponseAsBinary(ResponseMessage responseMessage,
io.netty.buffer.ByteBufAllocator allocator) |
io.netty.buffer.ByteBuf |
GraphBinaryMessageSerializerV1.serializeResponseAsBinary(ResponseMessage responseMessage,
io.netty.buffer.ByteBufAllocator allocator) |
String |
MessageTextSerializer.serializeResponseAsString(ResponseMessage responseMessage) |
String |
GraphSONMessageSerializerV2d0.serializeResponseAsString(ResponseMessage responseMessage) |
String |
GraphSONMessageSerializerV3d0.serializeResponseAsString(ResponseMessage responseMessage) |
String |
GraphSONMessageSerializerV1d0.serializeResponseAsString(ResponseMessage responseMessage) |
void |
AbstractGraphSONMessageSerializerV2d0.ResponseMessageSerializer.serializeWithType(ResponseMessage responseMessage,
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 |
AbstractGraphSONMessageSerializerV1d0.ResponseMessageSerializer.serializeWithType(ResponseMessage responseMessage,
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) |
<O extends OutputShim> |
ResponseMessageGryoSerializer.write(KryoShim<?,O> kryo,
O output,
ResponseMessage responseMessage) |
Modifier and Type | Method and Description |
---|---|
<I extends InputShim> |
ResponseMessageGryoSerializer.read(KryoShim<I,?> kryo,
I input,
Class<ResponseMessage> clazz) |
Modifier and Type | Method and Description |
---|---|
ResponseMessage |
ResponseMessageSerializer.readValue(io.netty.buffer.ByteBuf byteBuf,
GraphBinaryReader context) |
Modifier and Type | Method and Description |
---|---|
void |
ResponseMessageSerializer.writeValue(ResponseMessage value,
io.netty.buffer.ByteBuf byteBuf,
GraphBinaryWriter context) |
Modifier and Type | Method and Description |
---|---|
List<ResponseMessage> |
AbstractClient.submit(RequestMessage requestMessage) |
List<ResponseMessage> |
SimpleClient.submit(RequestMessage requestMessage) |
default List<ResponseMessage> |
SimpleClient.submit(String gremlin) |
CompletableFuture<List<ResponseMessage>> |
AbstractClient.submitAsync(RequestMessage requestMessage) |
CompletableFuture<List<ResponseMessage>> |
SimpleClient.submitAsync(RequestMessage requestMessage) |
default CompletableFuture<List<ResponseMessage>> |
SimpleClient.submitAsync(String gremlin) |
Modifier and Type | Method and Description |
---|---|
void |
AbstractClient.submit(RequestMessage requestMessage,
Consumer<ResponseMessage> callback) |
void |
SimpleClient.submit(RequestMessage requestMessage,
Consumer<ResponseMessage> callback) |
default void |
SimpleClient.submit(String gremlin,
Consumer<ResponseMessage> callback) |
Modifier and Type | Method and Description |
---|---|
void |
Context.write(ResponseMessage message) |
void |
Context.writeAndFlush(ResponseMessage message)
Writes a response message to the underlying channel while ensuring that at most one
final response is written. |
Modifier and Type | Method and Description |
---|---|
ResponseMessage |
SessionException.getResponseMessage() |
Modifier and Type | Method and Description |
---|---|
protected void |
GremlinResponseFrameEncoder.encode(io.netty.channel.ChannelHandlerContext ctx,
ResponseMessage o,
List<Object> objects) |
Constructor and Description |
---|
SessionException(String message,
ResponseMessage responseMessage) |
SessionException(String message,
Throwable cause,
ResponseMessage responseMessage) |
Modifier and Type | Method and Description |
---|---|
ResponseMessage |
OpProcessorException.getResponseMessage() |
Constructor and Description |
---|
OpProcessorException(String message,
ResponseMessage responseMessage) |
Copyright © 2013–2022 Apache Software Foundation. All rights reserved.