Trait nakadion::api::SubscriptionCommitApi

pub trait SubscriptionCommitApi {
    fn commit_cursors<T: Into<FlowId>>(
        &self, 
        id: SubscriptionId, 
        stream: StreamId, 
        cursors: &[SubscriptionCursor], 
        flow_id: T
    ) -> ApiFuture<'_, CursorCommitResults>;
}

Required methods

fn commit_cursors<T: Into<FlowId>>(
    &self,
    id: SubscriptionId,
    stream: StreamId,
    cursors: &[SubscriptionCursor],
    flow_id: T
) -> ApiFuture<'_, CursorCommitResults>

Endpoint for committing offsets of the subscription.

See also Nakadi Manual

Loading content...

Implementors

impl SubscriptionCommitApi for ApiClient

fn commit_cursors<T: Into<FlowId>>(
    &self,
    id: SubscriptionId,
    stream: StreamId,
    cursors: &[SubscriptionCursor],
    flow_id: T
) -> ApiFuture<'_, CursorCommitResults>

Loading content...