Trait nakadion::api::SubscriptionCommitApi [−][src]
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>
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