Struct Kurrent

pub struct Kurrent {
    pub client: Client,
}

Fields

client: Client

Implementations

impl Kurrent

pub fn new(settings: &ConnectionSettings) -> Result<Self, Error>

pub fn from_env() -> Result<Self, Error>

pub fn stream_builder(&self, stream_id: EventStreamId) -> EventStreamBuilder

pub fn stream_writer(&self, stream_id: EventStreamId) -> EventStreamWriter

pub async fn append_to_stream( &mut self, stream_id: EventStreamId, options: &AppendToStreamOptions, events: Vec<EventData>, ) -> Result<WriteResult, Error>

Trait Implementations

impl Clone for Kurrent

fn clone(&self) -> Kurrent

Returns a copy of the value.

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

Performs copy-assignment from source.

impl EventStore for Kurrent

async fn publish<E: Event>( &mut self, stream_id: EventStreamId, events: Vec<E>, expected_version: Option<EventStreamVersion>, ) -> Result<(), Error>

async fn read_stream<E: Event>( &self, stream_id: EventStreamId, ) -> Result<EventStream<E>, Error>