[−][src]Trait nakadion::components::committer::Commits

pub trait Commits {
    fn commit<'a>(
        &'a self, 
        cursors: &'a [SubscriptionCursor]
    ) -> CommitFuture<'a>;

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

    fn set_timeout_millis(&mut self, timeout: CommitAttemptTimeoutMillis);

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

    fn set_subscription_id(&mut self, subscription_id: SubscriptionId);

    fn set_stream_id(&mut self, stream_id: StreamId);

    fn subscription_id(&self) -> SubscriptionId;

    fn stream_id(&self) -> StreamId;

    fn instrumentation(&self) -> Instrumentation { ... }
}

Can commit cursors for a stream

Required methods

fn commit<'a>(&'a self, cursors: &'a [SubscriptionCursor]) -> CommitFuture<'a>

Commit cursor s to Nakadi.

fn set_flow_id(&mut self, flow_id: FlowId)

fn set_timeout_millis(&mut self, timeout: CommitAttemptTimeoutMillis)

fn set_instrumentation(&mut self, instrumentation: Instrumentation)

fn set_subscription_id(&mut self, subscription_id: SubscriptionId)

fn set_stream_id(&mut self, stream_id: StreamId)

fn subscription_id(&self) -> SubscriptionId

fn stream_id(&self) -> StreamId

Loading content...

Provided methods

fn instrumentation(&self) -> Instrumentation

Return instrumentation.

Returns Instrumentation::default() by default.

Loading content...

Implementors

impl<C> Commits for Committer<C> where
    C: SubscriptionApi + Send + Sync + 'static, [src]

Loading content...