Struct dendrite_auth::dendrite::axon_server::event::event_store_client::EventStoreClient

pub struct EventStoreClient<T> { /* private fields */ }

Service providing operations against the EventStore functionality of Axon Server

Implementations

impl EventStoreClient<Channel>

pub async fn connect<D>(dst: D) -> Result<EventStoreClient<Channel>, Error>

where D: TryInto<Endpoint>, <D as TryInto<Endpoint>>::Error: Into<Box<dyn Error + Sync + Send>>,

Attempt to create a new client by connecting to a given endpoint.

impl<T> EventStoreClient<T>

where T: GrpcService<UnsyncBoxBody<Bytes, Status>>, <T as GrpcService<UnsyncBoxBody<Bytes, Status>>>::Error: Into<Box<dyn Error + Sync + Send>>, <T as GrpcService<UnsyncBoxBody<Bytes, Status>>>::ResponseBody: Body<Data = Bytes> + Send + 'static, <<T as GrpcService<UnsyncBoxBody<Bytes, Status>>>::ResponseBody as Body>::Error: Into<Box<dyn Error + Sync + Send>> + Send,

pub fn new(inner: T) -> EventStoreClient<T>

pub fn with_origin(inner: T, origin: Uri) -> EventStoreClient<T>

pub fn with_interceptor<F>( inner: T, interceptor: F ) -> EventStoreClient<InterceptedService<T, F>>

where F: Interceptor, <T as GrpcService<UnsyncBoxBody<Bytes, Status>>>::ResponseBody: Default, T: Service<Request<UnsyncBoxBody<Bytes, Status>>, Response = Response<<T as GrpcService<UnsyncBoxBody<Bytes, Status>>>::ResponseBody>>, <T as Service<Request<UnsyncBoxBody<Bytes, Status>>>>::Error: Into<Box<dyn Error + Sync + Send>> + Send + Sync,

pub fn send_compressed( self, encoding: CompressionEncoding ) -> EventStoreClient<T>

Compress requests with the given encoding.

This requires the server to support it otherwise it might respond with an error.

pub fn accept_compressed( self, encoding: CompressionEncoding ) -> EventStoreClient<T>

Enable decompressing responses.

pub fn max_decoding_message_size(self, limit: usize) -> EventStoreClient<T>

Limits the maximum size of a decoded message.

Default: 4MB

pub fn max_encoding_message_size(self, limit: usize) -> EventStoreClient<T>

Limits the maximum size of an encoded message.

Default: usize::MAX

pub async fn append_event( &mut self, request: impl IntoStreamingRequest<Message = Event> ) -> Result<Response<Confirmation>, Status>

Accepts a stream of Events returning a Confirmation when completed.

pub async fn append_snapshot( &mut self, request: impl IntoRequest<Event> ) -> Result<Response<Confirmation>, Status>

Accepts a Snapshot event returning a Confirmation when completed.

pub async fn list_aggregate_events( &mut self, request: impl IntoRequest<GetAggregateEventsRequest> ) -> Result<Response<Streaming<Event>>, Status>

Retrieves the Events for a given aggregate. Results are streamed rather than returned at once.

pub async fn list_aggregate_snapshots( &mut self, request: impl IntoRequest<GetAggregateSnapshotsRequest> ) -> Result<Response<Streaming<Event>>, Status>

Retrieves the Snapshots for a given aggregate. Results are streamed rather than returned at once.

pub async fn list_events( &mut self, request: impl IntoStreamingRequest<Message = GetEventsRequest> ) -> Result<Response<Streaming<EventWithToken>>, Status>

Retrieves the Events from a given tracking token. However, if several GetEventsRequests are sent in the stream only first one will create the tracker, others are used for increasing number of permits or blacklisting. Results are streamed rather than returned at once.

pub async fn read_highest_sequence_nr( &mut self, request: impl IntoRequest<ReadHighestSequenceNrRequest> ) -> Result<Response<ReadHighestSequenceNrResponse>, Status>

Gets the highest sequence number for a specific aggregate.

pub async fn query_events( &mut self, request: impl IntoStreamingRequest<Message = QueryEventsRequest> ) -> Result<Response<Streaming<QueryEventsResponse>>, Status>

Performs a query on the event store, returns a stream of results. Input is a stream to allow flow control from the client

pub async fn get_first_token( &mut self, request: impl IntoRequest<GetFirstTokenRequest> ) -> Result<Response<TrackingToken>, Status>

Retrieves the first token available in event store (typically 0). Returns 0 when no events in store.

pub async fn get_last_token( &mut self, request: impl IntoRequest<GetLastTokenRequest> ) -> Result<Response<TrackingToken>, Status>

Retrieves the last committed token in event store. Returns -1 when no events in store.

pub async fn get_token_at( &mut self, request: impl IntoRequest<GetTokenAtRequest> ) -> Result<Response<TrackingToken>, Status>

Retrieves the token of the first token of an event from specified time in event store. Returns -1 when no events in store.

Trait Implementations

impl<T> Clone for EventStoreClient<T>

where T: Clone,

fn clone(&self) -> EventStoreClient<T>

Returns a copy of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl<T> Debug for EventStoreClient<T>

where T: Debug,

fn fmt(&self, f: &mut Formatter<'_>) -> Result<(), Error>

Formats the value using the given formatter.