Package | Description |
---|---|
io.axoniq.axonserver.grpc.query | |
org.axonframework.axonserver.connector.query | |
org.axonframework.axonserver.connector.query.subscription |
Modifier and Type | Field and Description |
---|---|
static io.grpc.MethodDescriptor<QueryRequest,QueryResponse> |
QueryServiceGrpc.METHOD_QUERY |
Modifier and Type | Method and Description |
---|---|
QueryResponse |
QueryResponse.Builder.build() |
QueryResponse |
QueryResponse.Builder.buildPartial() |
static QueryResponse |
QueryResponse.getDefaultInstance() |
QueryResponse |
QueryResponse.getDefaultInstanceForType() |
QueryResponse |
QueryResponse.Builder.getDefaultInstanceForType() |
QueryResponse |
SubscriptionQueryResponseOrBuilder.getInitialResult()
optional .io.axoniq.axonserver.grpc.query.QueryResponse initial_result = 3; |
QueryResponse |
SubscriptionQueryResponse.getInitialResult()
optional .io.axoniq.axonserver.grpc.query.QueryResponse initial_result = 3; |
QueryResponse |
SubscriptionQueryResponse.Builder.getInitialResult()
optional .io.axoniq.axonserver.grpc.query.QueryResponse initial_result = 3; |
QueryResponse |
QueryProviderOutbound.getQueryResponse()
optional .io.axoniq.axonserver.grpc.query.QueryResponse query_response = 4; |
QueryResponse |
QueryProviderOutbound.Builder.getQueryResponse()
optional .io.axoniq.axonserver.grpc.query.QueryResponse query_response = 4; |
QueryResponse |
QueryProviderOutboundOrBuilder.getQueryResponse()
optional .io.axoniq.axonserver.grpc.query.QueryResponse query_response = 4; |
static QueryResponse |
QueryResponse.parseDelimitedFrom(InputStream input) |
static QueryResponse |
QueryResponse.parseDelimitedFrom(InputStream input,
com.google.protobuf.ExtensionRegistryLite extensionRegistry) |
static QueryResponse |
QueryResponse.parseFrom(byte[] data) |
static QueryResponse |
QueryResponse.parseFrom(byte[] data,
com.google.protobuf.ExtensionRegistryLite extensionRegistry) |
static QueryResponse |
QueryResponse.parseFrom(com.google.protobuf.ByteString data) |
static QueryResponse |
QueryResponse.parseFrom(com.google.protobuf.ByteString data,
com.google.protobuf.ExtensionRegistryLite extensionRegistry) |
static QueryResponse |
QueryResponse.parseFrom(com.google.protobuf.CodedInputStream input) |
static QueryResponse |
QueryResponse.parseFrom(com.google.protobuf.CodedInputStream input,
com.google.protobuf.ExtensionRegistryLite extensionRegistry) |
static QueryResponse |
QueryResponse.parseFrom(InputStream input) |
static QueryResponse |
QueryResponse.parseFrom(InputStream input,
com.google.protobuf.ExtensionRegistryLite extensionRegistry) |
Modifier and Type | Method and Description |
---|---|
com.google.protobuf.Parser<QueryResponse> |
QueryResponse.getParserForType() |
static com.google.protobuf.Parser<QueryResponse> |
QueryResponse.parser() |
Iterator<QueryResponse> |
QueryServiceGrpc.QueryServiceBlockingStub.query(QueryRequest request) |
Modifier and Type | Method and Description |
---|---|
QueryResponse.Builder |
QueryResponse.Builder.mergeFrom(QueryResponse other) |
SubscriptionQueryResponse.Builder |
SubscriptionQueryResponse.Builder.mergeInitialResult(QueryResponse value)
optional .io.axoniq.axonserver.grpc.query.QueryResponse initial_result = 3; |
QueryProviderOutbound.Builder |
QueryProviderOutbound.Builder.mergeQueryResponse(QueryResponse value)
optional .io.axoniq.axonserver.grpc.query.QueryResponse query_response = 4; |
static QueryResponse.Builder |
QueryResponse.newBuilder(QueryResponse prototype) |
SubscriptionQueryResponse.Builder |
SubscriptionQueryResponse.Builder.setInitialResult(QueryResponse value)
optional .io.axoniq.axonserver.grpc.query.QueryResponse initial_result = 3; |
QueryProviderOutbound.Builder |
QueryProviderOutbound.Builder.setQueryResponse(QueryResponse value)
optional .io.axoniq.axonserver.grpc.query.QueryResponse query_response = 4; |
Modifier and Type | Method and Description |
---|---|
void |
QueryServiceGrpc.QueryServiceImplBase.query(QueryRequest request,
io.grpc.stub.StreamObserver<QueryResponse> responseObserver) |
void |
QueryServiceGrpc.QueryServiceStub.query(QueryRequest request,
io.grpc.stub.StreamObserver<QueryResponse> responseObserver) |
Modifier and Type | Method and Description |
---|---|
QueryResponse |
QuerySerializer.serializeResponse(QueryResponseMessage<?> response,
String requestMessageId) |
Modifier and Type | Method and Description |
---|---|
<R> QueryResponseMessage<R> |
QuerySerializer.deserializeResponse(QueryResponse commandResponse) |
Constructor and Description |
---|
GrpcBackedResponseMessage(QueryResponse queryResponse,
Serializer messageSerializer) |
Modifier and Type | Method and Description |
---|---|
SubscriptionQueryResult<QueryResponse,QueryUpdate> |
AxonServerSubscriptionQueryResult.get() |
Constructor and Description |
---|
DeserializedResult(SubscriptionQueryResult<QueryResponse,QueryUpdate> delegate,
SubscriptionMessageSerializer serializer) |
Copyright © 2010–2018. All rights reserved.