pub struct TopicReader { /* private fields */ }Implementations§
Source§impl TopicReader
impl TopicReader
pub async fn read_batch(&mut self) -> YdbResult<TopicReaderBatch>
Sourcepub async fn pop_batch_in_tx(
&mut self,
tx: &mut Box<dyn Transaction>,
) -> YdbResult<TopicReaderBatch>
pub async fn pop_batch_in_tx( &mut self, tx: &mut Box<dyn Transaction>, ) -> YdbResult<TopicReaderBatch>
Read a batch of messages within a transaction context.
The TopicReaderBatch from the result will be committed within the tx transaction.
This is an EXAMPLE of the interface. IT IS NOT PRODUCTION READY.
The reader will fail consistently on ANY error, including TLI.
You can use this method to test the interface and try writing your own code to see how it works. DO NOT USE IN PRODUCTION
pub fn commit( &mut self, commit_marker: TopicReaderCommitMarker, ) -> YdbResult<()>
Trait Implementations§
Auto Trait Implementations§
impl !Freeze for TopicReader
impl !RefUnwindSafe for TopicReader
impl Send for TopicReader
impl !Sync for TopicReader
impl Unpin for TopicReader
impl !UnwindSafe for TopicReader
Blanket Implementations§
Source§impl<T> Any for T
impl<T> Any for T
Source§fn type_id_compat(&self) -> TypeId
fn type_id_compat(&self) -> TypeId
TODO: once 1.33.0 is the minimum supported compiler version, remove
Any::type_id_compat and use StdAny::type_id instead.
https://github.com/rust-lang/rust/issues/27745
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> 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> IntoEither for T
impl<T> IntoEither for T
Source§fn into_either(self, into_left: bool) -> Either<Self, Self>
fn into_either(self, into_left: bool) -> Either<Self, Self>
Converts
self into a Left variant of Either<Self, Self>
if into_left is true.
Converts self into a Right variant of Either<Self, Self>
otherwise. Read moreSource§fn into_either_with<F>(self, into_left: F) -> Either<Self, Self>
fn into_either_with<F>(self, into_left: F) -> Either<Self, Self>
Converts
self into a Left variant of Either<Self, Self>
if into_left(&self) returns true.
Converts self into a Right variant of Either<Self, Self>
otherwise. Read moreSource§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