Module io.axoniq.connector.axonserver

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

Class DcbEventStoreGrpc.DcbEventStoreBlockingStub

java.lang.Object

io.grpc.stub.AbstractStub<S>

io.grpc.stub.AbstractBlockingStub<DcbEventStoreGrpc.DcbEventStoreBlockingStub>

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

Enclosing class:

DcbEventStoreGrpc

public static final class DcbEventStoreGrpc.DcbEventStoreBlockingStub
extends io.grpc.stub.AbstractBlockingStub<DcbEventStoreGrpc.DcbEventStoreBlockingStub>

A stub to allow clients to do limited synchronous 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
AddTagsResponse	addTags(AddTagsRequest request)	Assigns tags to the event identified by its sequence.
protected DcbEventStoreGrpc.DcbEventStoreBlockingStub	build(io.grpc.Channel channel, io.grpc.CallOptions callOptions)
GetHeadResponse	getHead(GetHeadRequest request)	Gets the current _head_ of the Event Store.
GetSequenceAtResponse	getSequenceAt(GetSequenceAtRequest request)	Returns the lowest sequence of an event with a timestamp equal to or higher than the given timestamp.
GetTagsResponse	getTags(GetTagsRequest request)	Gets tags for the event identified by its sequence.
GetTailResponse	getTail(GetTailRequest request)	Gets the current _tail_ of the Event Store.
RemoveTagsResponse	removeTags(RemoveTagsRequest request)	Removes tags from the event identified by its sequence.
Iterator<SourceEventsResponse>	source(SourceEventsRequest request)	Provides a finite stream of events based on the passed SourceEventsRequest.
Iterator<StreamEventsResponse>	stream(StreamEventsRequest request)	Provides an infinite stream of events based on the passed StreamEventsRequest.

Methods inherited from class io.grpc.stub.AbstractBlockingStub

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.DcbEventStoreBlockingStub build(io.grpc.Channel channel,
                                                            io.grpc.CallOptions callOptions)

Specified by:

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

source

public Iterator<SourceEventsResponse> source(SourceEventsRequest request)

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

stream

public Iterator<StreamEventsResponse> stream(StreamEventsRequest request)

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

getHead

public GetHeadResponse getHead(GetHeadRequest request)

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

getTail

public GetTailResponse getTail(GetTailRequest request)

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

getSequenceAt

public GetSequenceAtResponse getSequenceAt(GetSequenceAtRequest request)

 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 AddTagsResponse addTags(AddTagsRequest request)

 Assigns tags to the event identified by its sequence. 
 

removeTags

public RemoveTagsResponse removeTags(RemoveTagsRequest request)

 Removes tags from the event identified by its sequence. 
 

getTags

public GetTagsResponse getTags(GetTagsRequest request)

 Gets tags for the event identified by its sequence.