pub enum AckNoOp {
ParticipantAck(ParticipantAckEnvelope),
MarkerAck(MarkerAckEnvelope),
}Expand description
Idempotent normal or marker acknowledgement.
Variants§
ParticipantAck(ParticipantAckEnvelope)
Continuous acknowledgement.
MarkerAck(MarkerAckEnvelope)
Marker acknowledgement.
Implementations§
Source§impl AckNoOp
impl AckNoOp
Sourcepub const fn participant_ack(request: ParticipantAckEnvelope) -> Self
pub const fn participant_ack(request: ParticipantAckEnvelope) -> Self
Constructs an idempotent continuous acknowledgement at its requested cursor.
Sourcepub const fn marker_ack(request: MarkerAckEnvelope) -> Self
pub const fn marker_ack(request: MarkerAckEnvelope) -> Self
Constructs an idempotent marker acknowledgement at its requested marker cursor.
Sourcepub const fn current_cursor(&self) -> DeliverySeq
pub const fn current_cursor(&self) -> DeliverySeq
Unchanged cursor, derived from the selected request envelope.
Trait Implementations§
impl Eq for AckNoOp
impl StructuralPartialEq for AckNoOp
Auto Trait Implementations§
impl Freeze for AckNoOp
impl RefUnwindSafe for AckNoOp
impl Send for AckNoOp
impl Sync for AckNoOp
impl Unpin for AckNoOp
impl UnsafeUnpin for AckNoOp
impl UnwindSafe for AckNoOp
Blanket Implementations§
Source§impl<T> BorrowMut<T> for Twhere
T: ?Sized,
impl<T> BorrowMut<T> for Twhere
T: ?Sized,
Source§fn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
Mutably borrows from an owned value. Read more