[−][src]Struct nakadion::components::committer::CommitHandle
Handle to send commit messages to the background task.
The background task will stop, once the last handle is dropped.
Implementations
impl CommitHandle
[src]
pub fn commit(
&self,
cursor: SubscriptionCursor,
frame_started_at: Instant,
frame_completed_at: Instant,
n_events: Option<usize>
) -> Result<(), CommitData>
[src]
&self,
cursor: SubscriptionCursor,
frame_started_at: Instant,
frame_completed_at: Instant,
n_events: Option<usize>
) -> Result<(), CommitData>
Commit the given cursor with additional information.
Fails if the data could not be send which means that the backend is gone. The appropriate action is then to stop streaming.
pub fn commit_data(&self, data: CommitData) -> Result<(), CommitData>
[src]
Commit the given cursor with additional information packed in the struct
CommitData
.
Fails if the data could not be send which means that the backend is gone. The appropriate action is then to stop streaming.
Trait Implementations
impl Clone for CommitHandle
[src]
fn clone(&self) -> CommitHandle
[src]
fn clone_from(&mut self, source: &Self)
1.0.0[src]
Auto Trait Implementations
impl !RefUnwindSafe for CommitHandle
impl Send for CommitHandle
impl Sync for CommitHandle
impl Unpin for CommitHandle
impl !UnwindSafe for CommitHandle
Blanket Implementations
impl<T> Any for T where
T: 'static + ?Sized,
[src]
T: 'static + ?Sized,
impl<T> Borrow<T> for T where
T: ?Sized,
[src]
T: ?Sized,
impl<T> BorrowMut<T> for T where
T: ?Sized,
[src]
T: ?Sized,
fn borrow_mut(&mut self) -> &mut T
[src]
impl<T> From<T> for T
[src]
impl<T, U> Into<U> for T where
U: From<T>,
[src]
U: From<T>,
impl<T> ToOwned for T where
T: Clone,
[src]
T: Clone,
type Owned = T
The resulting type after obtaining ownership.
fn to_owned(&self) -> T
[src]
fn clone_into(&self, target: &mut T)
[src]
impl<T, U> TryFrom<U> for T where
U: Into<T>,
[src]
U: Into<T>,
type Error = Infallible
The type returned in the event of a conversion error.
fn try_from(value: U) -> Result<T, <T as TryFrom<U>>::Error>
[src]
impl<T, U> TryInto<U> for T where
U: TryFrom<T>,
[src]
U: TryFrom<T>,
type Error = <U as TryFrom<T>>::Error
The type returned in the event of a conversion error.
fn try_into(self) -> Result<U, <U as TryFrom<T>>::Error>
[src]
impl<V, T> VZip<V> for T where
V: MultiLane<T>,
V: MultiLane<T>,