[−][src]Trait nakadion::api::SubscriptionCommitApi
Required methods
pub fn commit_cursors<T: Into<FlowId>>(
&self,
id: SubscriptionId,
stream: StreamId,
cursors: &[SubscriptionCursor],
flow_id: T
) -> ApiFuture<'_, CursorCommitResults>
[src]
&self,
id: SubscriptionId,
stream: StreamId,
cursors: &[SubscriptionCursor],
flow_id: T
) -> ApiFuture<'_, CursorCommitResults>
Endpoint for committing offsets of the subscription.
See also Nakadi Manual
Implementors
impl SubscriptionCommitApi for ApiClient
[src]
pub fn commit_cursors<T: Into<FlowId>>(
&self,
id: SubscriptionId,
stream: StreamId,
cursors: &[SubscriptionCursor],
flow_id: T
) -> ApiFuture<'_, CursorCommitResults>
[src]
&self,
id: SubscriptionId,
stream: StreamId,
cursors: &[SubscriptionCursor],
flow_id: T
) -> ApiFuture<'_, CursorCommitResults>