Struct nakadion::components::committer::Committer

pub struct Committer<C> { /* fields omitted */ }

Commits cursors for a stream

Committer is bound to a given subscription and stream. It has to be configured with its mutating methods.

Implementations

impl<C> Committer<C> where
    C: SubscriptionCommitApi + Send + Sync + 'static, 

pub fn new(
    client: C,
    subscription_id: SubscriptionId,
    stream_id: StreamId
) -> Self

Create a new instance bound to the given subscription and stream

pub fn set_logger<L: Logger>(&mut self, logger: L)

pub fn logger<L: Logger>(self, logger: L) -> Self

pub fn instrumentation(&self) -> Instrumentation

pub fn set_flow_id(&mut self, flow_id: FlowId)

pub fn set_config(&mut self, config: CommitConfig)

pub fn set_instrumentation(&mut self, instrumentation: Instrumentation)

pub fn subscription_id(&self) -> SubscriptionId

pub fn stream_id(&self) -> StreamId

pub fn config(&self) -> &CommitConfig

pub async fn commit<'_, '_>(
    &'_ self,
    cursors: &'_ [SubscriptionCursor]
) -> Result<CursorCommitResults, CommitError>