Uses of Class
io.axoniq.axonserver.grpc.query.QueryRequest
-
Packages that use QueryRequest Package Description io.axoniq.axonserver.connector.query io.axoniq.axonserver.connector.query.impl io.axoniq.axonserver.grpc.query -
-
Uses of QueryRequest in io.axoniq.axonserver.connector.query
Methods in io.axoniq.axonserver.connector.query with parameters of type QueryRequest Modifier and Type Method Description voidQueryHandler. handle(QueryRequest query, ReplyChannel<QueryResponse> responseHandler)Handle the givenquery, using givenresponseHandlerto send the response(s).ResultStream<QueryResponse>QueryChannel. query(QueryRequest query)Sends the givenqueryto AxonServer for routing to the appropriate handlers.default FlowControlQueryHandler. stream(QueryRequest query, ReplyChannel<QueryResponse> responseHandler)Handle the givenquery, using the givenresponseHandlerto send the response(s).SubscriptionQueryResultQueryChannel. subscriptionQuery(QueryRequest query, int bufferSize, int fetchSize)Sends out a subscriptionqueryto AxonServer for routing to the appropriate handler.default SubscriptionQueryResultQueryChannel. subscriptionQuery(QueryRequest query, SerializedObject updateType, int bufferSize, int fetchSize)Deprecated. -
Uses of QueryRequest in io.axoniq.axonserver.connector.query.impl
Methods in io.axoniq.axonserver.connector.query.impl with parameters of type QueryRequest Modifier and Type Method Description ResultStream<QueryResponse>QueryChannelImpl. query(QueryRequest query)SubscriptionQueryResultQueryChannelImpl. subscriptionQuery(QueryRequest query, int bufferSize, int fetchSize) -
Uses of QueryRequest in io.axoniq.axonserver.grpc.query
Methods in io.axoniq.axonserver.grpc.query that return QueryRequest Modifier and Type Method Description QueryRequestQueryRequest.Builder. build()QueryRequestQueryRequest.Builder. buildPartial()static QueryRequestQueryRequest. getDefaultInstance()QueryRequestQueryRequest.Builder. getDefaultInstanceForType()QueryRequestQueryRequest. getDefaultInstanceForType()QueryRequestQueryProviderInbound.Builder. getQuery()Represents an incoming Query, for which this component is expected to provide a responseQueryRequestQueryProviderInbound. getQuery()Represents an incoming Query, for which this component is expected to provide a responseQueryRequestQueryProviderInboundOrBuilder. getQuery()Represents an incoming Query, for which this component is expected to provide a responseQueryRequestSubscriptionQuery.Builder. getQueryRequest()The Query describing the desire for informationQueryRequestSubscriptionQuery. getQueryRequest()The Query describing the desire for informationQueryRequestSubscriptionQueryOrBuilder. getQueryRequest()The Query describing the desire for informationstatic QueryRequestQueryRequest. parseDelimitedFrom(InputStream input)static QueryRequestQueryRequest. parseDelimitedFrom(InputStream input, com.google.protobuf.ExtensionRegistryLite extensionRegistry)static QueryRequestQueryRequest. parseFrom(byte[] data)static QueryRequestQueryRequest. parseFrom(byte[] data, com.google.protobuf.ExtensionRegistryLite extensionRegistry)static QueryRequestQueryRequest. parseFrom(com.google.protobuf.ByteString data)static QueryRequestQueryRequest. parseFrom(com.google.protobuf.ByteString data, com.google.protobuf.ExtensionRegistryLite extensionRegistry)static QueryRequestQueryRequest. parseFrom(com.google.protobuf.CodedInputStream input)static QueryRequestQueryRequest. parseFrom(com.google.protobuf.CodedInputStream input, com.google.protobuf.ExtensionRegistryLite extensionRegistry)static QueryRequestQueryRequest. parseFrom(InputStream input)static QueryRequestQueryRequest. parseFrom(InputStream input, com.google.protobuf.ExtensionRegistryLite extensionRegistry)static QueryRequestQueryRequest. parseFrom(ByteBuffer data)static QueryRequestQueryRequest. parseFrom(ByteBuffer data, com.google.protobuf.ExtensionRegistryLite extensionRegistry)Methods in io.axoniq.axonserver.grpc.query that return types with arguments of type QueryRequest Modifier and Type Method Description com.google.protobuf.Parser<QueryRequest>QueryRequest. getParserForType()static io.grpc.MethodDescriptor<QueryRequest,QueryResponse>QueryServiceGrpc. getQueryMethod()static com.google.protobuf.Parser<QueryRequest>QueryRequest. parser()Methods in io.axoniq.axonserver.grpc.query with parameters of type QueryRequest Modifier and Type Method Description QueryRequest.BuilderQueryRequest.Builder. mergeFrom(QueryRequest other)QueryProviderInbound.BuilderQueryProviderInbound.Builder. mergeQuery(QueryRequest value)Represents an incoming Query, for which this component is expected to provide a responseSubscriptionQuery.BuilderSubscriptionQuery.Builder. mergeQueryRequest(QueryRequest value)The Query describing the desire for informationstatic QueryRequest.BuilderQueryRequest. newBuilder(QueryRequest prototype)default voidQueryServiceGrpc.AsyncService. query(QueryRequest request, io.grpc.stub.StreamObserver<QueryResponse> responseObserver)Sends a point-to-point or scatter-gather QueryIterator<QueryResponse>QueryServiceGrpc.QueryServiceBlockingStub. query(QueryRequest request)Sends a point-to-point or scatter-gather Queryio.grpc.stub.BlockingClientCall<?,QueryResponse>QueryServiceGrpc.QueryServiceBlockingV2Stub. query(QueryRequest request)Sends a point-to-point or scatter-gather QueryvoidQueryServiceGrpc.QueryServiceStub. query(QueryRequest request, io.grpc.stub.StreamObserver<QueryResponse> responseObserver)Sends a point-to-point or scatter-gather QueryQueryProviderInbound.BuilderQueryProviderInbound.Builder. setQuery(QueryRequest value)Represents an incoming Query, for which this component is expected to provide a responseSubscriptionQuery.BuilderSubscriptionQuery.Builder. setQueryRequest(QueryRequest value)The Query describing the desire for information
-