Uses of Class
io.axoniq.axonserver.grpc.event.dcb.AppendEventsResponse
-
Packages that use AppendEventsResponse Package Description io.axoniq.axonserver.connector.event io.axoniq.axonserver.connector.event.impl io.axoniq.axonserver.grpc.event.dcb -
-
Uses of AppendEventsResponse in io.axoniq.axonserver.connector.event
Methods in io.axoniq.axonserver.connector.event that return types with arguments of type AppendEventsResponse Modifier and Type Method Description default CompletableFuture<AppendEventsResponse>DcbEventChannel. append(ConsistencyCondition condition, TaggedEvent... taggedEvents)Appends variable number oftaggedEventswithConsistencyConditionand returns the completableFuture which contains theAppendEventsResponsewhen awaited.default CompletableFuture<AppendEventsResponse>DcbEventChannel. append(TaggedEvent... taggedEvents)Appends variable number oftaggedEventsand returns the completableFuture which contains theAppendEventsResponsewhen awaited.default CompletableFuture<AppendEventsResponse>DcbEventChannel. append(Collection<TaggedEvent> taggedEvents)Appends aCollectionoftaggedEventsand returns the completableFuture which contains theAppendEventsResponsewhen awaited.default CompletableFuture<AppendEventsResponse>DcbEventChannel. append(Collection<TaggedEvent> taggedEvents, ConsistencyCondition condition)Appends aCollectionoftaggedEventswithConsistencyConditionand returns the completableFuture which contains theAppendEventsResponsewhen awaited.CompletableFuture<AppendEventsResponse>DcbEventChannel.AppendEventsTransaction. commit()Commits this Transaction. -
Uses of AppendEventsResponse in io.axoniq.axonserver.connector.event.impl
Methods in io.axoniq.axonserver.connector.event.impl that return types with arguments of type AppendEventsResponse Modifier and Type Method Description CompletableFuture<AppendEventsResponse>DcbEventChannelImpl. append(Collection<TaggedEvent> taggedEvents, ConsistencyCondition condition) -
Uses of AppendEventsResponse in io.axoniq.axonserver.grpc.event.dcb
Methods in io.axoniq.axonserver.grpc.event.dcb that return AppendEventsResponse Modifier and Type Method Description AppendEventsResponseAppendEventsResponse.Builder. build()AppendEventsResponseAppendEventsResponse.Builder. buildPartial()static AppendEventsResponseAppendEventsResponse. getDefaultInstance()AppendEventsResponseAppendEventsResponse.Builder. getDefaultInstanceForType()AppendEventsResponseAppendEventsResponse. getDefaultInstanceForType()static AppendEventsResponseAppendEventsResponse. parseDelimitedFrom(InputStream input)static AppendEventsResponseAppendEventsResponse. parseDelimitedFrom(InputStream input, com.google.protobuf.ExtensionRegistryLite extensionRegistry)static AppendEventsResponseAppendEventsResponse. parseFrom(byte[] data)static AppendEventsResponseAppendEventsResponse. parseFrom(byte[] data, com.google.protobuf.ExtensionRegistryLite extensionRegistry)static AppendEventsResponseAppendEventsResponse. parseFrom(com.google.protobuf.ByteString data)static AppendEventsResponseAppendEventsResponse. parseFrom(com.google.protobuf.ByteString data, com.google.protobuf.ExtensionRegistryLite extensionRegistry)static AppendEventsResponseAppendEventsResponse. parseFrom(com.google.protobuf.CodedInputStream input)static AppendEventsResponseAppendEventsResponse. parseFrom(com.google.protobuf.CodedInputStream input, com.google.protobuf.ExtensionRegistryLite extensionRegistry)static AppendEventsResponseAppendEventsResponse. parseFrom(InputStream input)static AppendEventsResponseAppendEventsResponse. parseFrom(InputStream input, com.google.protobuf.ExtensionRegistryLite extensionRegistry)static AppendEventsResponseAppendEventsResponse. parseFrom(ByteBuffer data)static AppendEventsResponseAppendEventsResponse. parseFrom(ByteBuffer data, com.google.protobuf.ExtensionRegistryLite extensionRegistry)Methods in io.axoniq.axonserver.grpc.event.dcb that return types with arguments of type AppendEventsResponse Modifier and Type Method Description io.grpc.stub.BlockingClientCall<AppendEventsRequest,AppendEventsResponse>DcbEventStoreGrpc.DcbEventStoreBlockingV2Stub. append()Appends new events to the store.static io.grpc.MethodDescriptor<AppendEventsRequest,AppendEventsResponse>DcbEventStoreGrpc. getAppendMethod()com.google.protobuf.Parser<AppendEventsResponse>AppendEventsResponse. getParserForType()static com.google.protobuf.Parser<AppendEventsResponse>AppendEventsResponse. parser()Methods in io.axoniq.axonserver.grpc.event.dcb with parameters of type AppendEventsResponse Modifier and Type Method Description AppendEventsResponse.BuilderAppendEventsResponse.Builder. mergeFrom(AppendEventsResponse other)static AppendEventsResponse.BuilderAppendEventsResponse. newBuilder(AppendEventsResponse prototype)Method parameters in io.axoniq.axonserver.grpc.event.dcb with type arguments of type AppendEventsResponse Modifier and Type Method Description default io.grpc.stub.StreamObserver<AppendEventsRequest>DcbEventStoreGrpc.AsyncService. append(io.grpc.stub.StreamObserver<AppendEventsResponse> responseObserver)Appends new events to the store.io.grpc.stub.StreamObserver<AppendEventsRequest>DcbEventStoreGrpc.DcbEventStoreStub. append(io.grpc.stub.StreamObserver<AppendEventsResponse> responseObserver)Appends new events to the store.
-