Module io.axoniq.connector.axonserver

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

Class DcbEventStoreGrpc.DcbEventStoreBlockingV2Stub

java.lang.Object

io.grpc.stub.AbstractStub<S>

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

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

Enclosing class:

DcbEventStoreGrpc

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

A stub to allow clients to do 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.
io.grpc.stub.BlockingClientCall<AppendEventsRequest,AppendEventsResponse>	append()	Appends new events to the store.
protected DcbEventStoreGrpc.DcbEventStoreBlockingV2Stub	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.
io.grpc.stub.BlockingClientCall<?,SourceEventsResponse>	source(SourceEventsRequest request)	Provides a finite stream of events based on the passed SourceEventsRequest.
io.grpc.stub.BlockingClientCall<?,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.DcbEventStoreBlockingV2Stub build(io.grpc.Channel channel,
                                                              io.grpc.CallOptions callOptions)

Specified by:

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

append

@ExperimentalApi("https://github.com/grpc/grpc-java/issues/10918")
public io.grpc.stub.BlockingClientCall<AppendEventsRequest,AppendEventsResponse> append()

 Appends new events to the store. 
 

source

@ExperimentalApi("https://github.com/grpc/grpc-java/issues/10918")
public io.grpc.stub.BlockingClientCall<?,SourceEventsResponse> source(SourceEventsRequest request)

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

stream

@ExperimentalApi("https://github.com/grpc/grpc-java/issues/10918")
public io.grpc.stub.BlockingClientCall<?,StreamEventsResponse> stream(StreamEventsRequest request)

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

getHead

public GetHeadResponse getHead(GetHeadRequest request)
                        throws io.grpc.StatusException

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

Throws:

io.grpc.StatusException

getTail

public GetTailResponse getTail(GetTailRequest request)
                        throws io.grpc.StatusException

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

Throws:

io.grpc.StatusException

getSequenceAt

public GetSequenceAtResponse getSequenceAt(GetSequenceAtRequest request)
                                    throws io.grpc.StatusException

 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. 
 

Throws:

io.grpc.StatusException

addTags

public AddTagsResponse addTags(AddTagsRequest request)
                        throws io.grpc.StatusException

 Assigns tags to the event identified by its sequence. 
 

Throws:

io.grpc.StatusException

removeTags

public RemoveTagsResponse removeTags(RemoveTagsRequest request)
                              throws io.grpc.StatusException

 Removes tags from the event identified by its sequence. 
 

Throws:

io.grpc.StatusException

getTags

public GetTagsResponse getTags(GetTagsRequest request)
                        throws io.grpc.StatusException

 Gets tags for the event identified by its sequence. 
 

Throws:

io.grpc.StatusException