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

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

Service providing operations against the EventStore functionality of Axon Server

Implementations

impl EventStoreClient<Channel>

pub async fn connect<D>(dst: D) -> Result<Self, Error> where
    D: TryInto<Endpoint>,
    D::Error: Into<StdError>, 

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

impl<T> EventStoreClient<T> where
    T: GrpcService<BoxBody>,
    T::ResponseBody: Body + HttpBody + Send + 'static,
    T::Error: Into<StdError>,
    <T::ResponseBody as HttpBody>::Error: Into<StdError> + Send, 

pub fn new(inner: T) -> Self

pub fn with_interceptor(inner: T, interceptor: impl Into<Interceptor>) -> Self

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> Clone for EventStoreClient<T>

pub fn clone(&self) -> Self

Returns a copy of the value.

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

Performs copy-assignment from source.

impl<T> Debug for EventStoreClient<T>

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

Formats the value using the given formatter.