pub struct AppendAck {
pub start: StreamPosition,
pub end: StreamPosition,
pub tail: StreamPosition,
}
Expand description
Acknowledgment to an append request.
Fields§
§start: StreamPosition
Sequence number and timestamp of the first record that was appended.
end: StreamPosition
Sequence number of the last record that was appended + 1,
and timestamp of the last record that was appended.
The difference between end.seq_num
and start.seq_num
will be the number of records appended.
tail: StreamPosition
Sequence number that will be assigned to the next record on the stream,
and timestamp of the last record on the stream.
This can be greater than the end
position in case of concurrent appends.
Trait Implementations§
Auto Trait Implementations§
impl Freeze for AppendAck
impl RefUnwindSafe for AppendAck
impl Send for AppendAck
impl Sync for AppendAck
impl Unpin for AppendAck
impl UnwindSafe for AppendAck
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
Source§impl<T> CloneToUninit for Twhere
T: Clone,
impl<T> CloneToUninit for Twhere
T: Clone,
Source§impl<T> Instrument for T
impl<T> Instrument for T
Source§fn instrument(self, span: Span) -> Instrumented<Self>
fn instrument(self, span: Span) -> Instrumented<Self>
Source§fn in_current_span(self) -> Instrumented<Self>
fn in_current_span(self) -> Instrumented<Self>
Source§impl<T> IntoRequest<T> for T
impl<T> IntoRequest<T> for T
Source§fn into_request(self) -> Request<T>
fn into_request(self) -> Request<T>
Wrap the input message
T
in a tonic::Request