Struct AsyncUmaDbClient 

pub struct AsyncUmaDbClient { /* private fields */ }

Implementations

impl AsyncUmaDbClient

pub async fn subscribe( &self, query: Option<DcbQuery>, after: Option<u64>, ) -> DcbResult<Box<dyn DcbSubscriptionAsync + Send + 'static>>

pub async fn connect( url: String, ca_path: Option<String>, batch_size: Option<u32>, api_key: Option<String>, ) -> DcbResult<Self>

pub async fn connect_with_tls_options( url: String, tls_options: Option<ClientTlsOptions>, batch_size: Option<u32>, api_key: Option<String>, ) -> DcbResult<Self>

pub async fn register_cancel_sigint_handler(&self)

Trait Implementations

impl DcbEventStoreAsync for AsyncUmaDbClient

fn read<'a, 'async_trait>( &'a self, query: Option<DcbQuery>, start: Option<u64>, backwards: bool, limit: Option<u32>, subscribe: bool, ) -> Pin<Box<dyn Future<Output = DcbResult<Box<dyn DcbReadResponseAsync + Send + 'static>>> + Send + 'async_trait>>

where Self: 'async_trait, 'a: 'async_trait,

Reads events from the store based on the provided query and constraints

fn head<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = DcbResult<Option<u64>>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Returns the current head position of the event store, or None if empty

fn get_tracking_info<'life0, 'life1, 'async_trait>( &'life0 self, source: &'life1 str, ) -> Pin<Box<dyn Future<Output = DcbResult<Option<u64>>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Returns the greatest recorded upstream position for a tracking source, if any

fn append<'life0, 'async_trait>( &'life0 self, events: Vec<DcbEvent>, condition: Option<DcbAppendCondition>, tracking_info: Option<TrackingInfo>, ) -> Pin<Box<dyn Future<Output = DcbResult<u64>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Appends given events to the event store, unless the condition fails

fn read_with_head<'a, 'async_trait>( &'a self, query: Option<DcbQuery>, after: Option<u64>, backwards: bool, limit: Option<u32>, ) -> Pin<Box<dyn Future<Output = Result<(Vec<DcbSequencedEvent>, Option<u64>), DcbError>> + Send + 'async_trait>>

where 'a: 'async_trait, Self: 'async_trait,

Reads events from the store and returns them as a tuple of (Vec<DcbSequencedEvent>, Option<u64>)