Module io.axoniq.connector.axonserver

Package io.axoniq.axonserver.grpc.event.dcb

Class DcbEventStoreGrpc.DcbEventStoreStub

java.lang.Object

io.grpc.stub.AbstractStub<S>

io.grpc.stub.AbstractAsyncStub<DcbEventStoreGrpc.DcbEventStoreStub>

io.axoniq.axonserver.grpc.event.dcb.DcbEventStoreGrpc.DcbEventStoreStub

Enclosing class:

DcbEventStoreGrpc

public static final class DcbEventStoreGrpc.DcbEventStoreStub
extends io.grpc.stub.AbstractAsyncStub<DcbEventStoreGrpc.DcbEventStoreStub>

A stub to allow clients to do asynchronous rpc calls to service DcbEventStore.

 Service providing Event Store RPCs supporting DCB. 
 

Nested Class Summary

Nested classes/interfaces inherited from class io.grpc.stub.AbstractStub

io.grpc.stub.AbstractStub.StubFactory<T extends io.grpc.stub.AbstractStub<T>>

Method Summary

Modifier and Type	Method	Description
void	addTags(AddTagsRequest request, io.grpc.stub.StreamObserver<AddTagsResponse> responseObserver)	Assigns tags to the event identified by its sequence.
io.grpc.stub.StreamObserver<AppendEventsRequest>	append(io.grpc.stub.StreamObserver<AppendEventsResponse> responseObserver)	Appends new events to the store.
protected DcbEventStoreGrpc.DcbEventStoreStub	build(io.grpc.Channel channel, io.grpc.CallOptions callOptions)
void	getHead(GetHeadRequest request, io.grpc.stub.StreamObserver<GetHeadResponse> responseObserver)	Gets the current _head_ of the Event Store.
void	getSequenceAt(GetSequenceAtRequest request, io.grpc.stub.StreamObserver<GetSequenceAtResponse> responseObserver)	Returns the lowest sequence of an event with a timestamp equal to or higher than the given timestamp.
void	getTags(GetTagsRequest request, io.grpc.stub.StreamObserver<GetTagsResponse> responseObserver)	Gets tags for the event identified by its sequence.
void	getTail(GetTailRequest request, io.grpc.stub.StreamObserver<GetTailResponse> responseObserver)	Gets the current _tail_ of the Event Store.
void	removeTags(RemoveTagsRequest request, io.grpc.stub.StreamObserver<RemoveTagsResponse> responseObserver)	Removes tags from the event identified by its sequence.
void	source(SourceEventsRequest request, io.grpc.stub.StreamObserver<SourceEventsResponse> responseObserver)	Provides a finite stream of events based on the passed SourceEventsRequest.
void	stream(StreamEventsRequest request, io.grpc.stub.StreamObserver<StreamEventsResponse> responseObserver)	Provides an infinite stream of events based on the passed StreamEventsRequest.

Methods inherited from class io.grpc.stub.AbstractAsyncStub

newStub, newStub

Methods inherited from class io.grpc.stub.AbstractStub

getCallOptions, getChannel, withCallCredentials, withChannel, withCompression, withDeadline, withDeadlineAfter, withDeadlineAfter, withExecutor, withInterceptors, withMaxInboundMessageSize, withMaxOutboundMessageSize, withOnReadyThreshold, withOption, withWaitForReady

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Method Detail

build

protected DcbEventStoreGrpc.DcbEventStoreStub build(io.grpc.Channel channel,
                                                    io.grpc.CallOptions callOptions)

Specified by:

build in class io.grpc.stub.AbstractStub<DcbEventStoreGrpc.DcbEventStoreStub>

append

public io.grpc.stub.StreamObserver<AppendEventsRequest> append(io.grpc.stub.StreamObserver<AppendEventsResponse> responseObserver)

 Appends new events to the store. 
 

source

public void source(SourceEventsRequest request,
                   io.grpc.stub.StreamObserver<SourceEventsResponse> responseObserver)

 Provides a finite stream of events based on the passed SourceEventsRequest. 
 

stream

public void stream(StreamEventsRequest request,
                   io.grpc.stub.StreamObserver<StreamEventsResponse> responseObserver)

 Provides an infinite stream of events based on the passed StreamEventsRequest.  
 

getHead

public void getHead(GetHeadRequest request,
                    io.grpc.stub.StreamObserver<GetHeadResponse> responseObserver)

 Gets the current _head_ of the Event Store. The _head_ points to the sequence of the first event to be appended. 
 

getTail

public void getTail(GetTailRequest request,
                    io.grpc.stub.StreamObserver<GetTailResponse> responseObserver)

 Gets the current _tail_ of the Event Store. The _tail_ points to the sequence of the first event stored. 
 

getSequenceAt

public void getSequenceAt(GetSequenceAtRequest request,
                          io.grpc.stub.StreamObserver<GetSequenceAtResponse> responseObserver)

 Returns the lowest sequence of an event with a timestamp equal to or higher than the given timestamp. The HEAD is
returned if no events exist with a timestamp equal to or higher than the given timestamp.
N.B. Axon Server does not assign timestamps to events. The timestamps used for fulfilling this RPC are timestamps
provided by the client. It could happen that there are events after the returned sequence that have an earlier
timestamp. Axon Server does not reject appends if timestamps of events are not monotonically increasing. 
 

addTags

public void addTags(AddTagsRequest request,
                    io.grpc.stub.StreamObserver<AddTagsResponse> responseObserver)

 Assigns tags to the event identified by its sequence. 
 

removeTags

public void removeTags(RemoveTagsRequest request,
                       io.grpc.stub.StreamObserver<RemoveTagsResponse> responseObserver)

 Removes tags from the event identified by its sequence. 
 

getTags

public void getTags(GetTagsRequest request,
                    io.grpc.stub.StreamObserver<GetTagsResponse> responseObserver)

 Gets tags for the event identified by its sequence.