Struct mz_storage::source::generator::LoadGeneratorSourceReader
source · pub struct LoadGeneratorSourceReader { /* private fields */ }
Trait Implementations§
source§impl SourceReader for LoadGeneratorSourceReader
impl SourceReader for LoadGeneratorSourceReader
type Key = ()
type Value = Row
type Time = MzOffset
type Diff = i64
source§fn get_next_message(
&mut self
) -> NextMessage<Self::Key, Self::Value, Self::Time, Self::Diff>
fn get_next_message(
&mut self
) -> NextMessage<Self::Key, Self::Value, Self::Time, Self::Diff>
Returns the next message available from the source. Read more
source§fn next<'life0, 'async_trait>(
&'life0 mut self,
timestamp_granularity: Duration
) -> Pin<Box<dyn Future<Output = Option<SourceMessageType<Self::Key, Self::Value, Self::Time, Self::Diff>>> + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
fn next<'life0, 'async_trait>(
&'life0 mut self,
timestamp_granularity: Duration
) -> Pin<Box<dyn Future<Output = Option<SourceMessageType<Self::Key, Self::Value, Self::Time, Self::Diff>>> + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
Returns the next message available from the source.
source§fn into_stream<'a>(
self,
timestamp_granularity: Duration
) -> LocalBoxStream<'a, SourceMessageType<Self::Key, Self::Value, Self::Time, Self::Diff>>where
Self: Sized + 'a,
fn into_stream<'a>(
self,
timestamp_granularity: Duration
) -> LocalBoxStream<'a, SourceMessageType<Self::Key, Self::Value, Self::Time, Self::Diff>>where
Self: Sized + 'a,
Returns an adapter that treats the source as a stream. Read more
Auto Trait Implementations§
impl !RefUnwindSafe for LoadGeneratorSourceReader
impl !Send for LoadGeneratorSourceReader
impl !Sync for LoadGeneratorSourceReader
impl Unpin for LoadGeneratorSourceReader
impl !UnwindSafe for LoadGeneratorSourceReader
Blanket Implementations§
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
source§impl<T> Pointable for T
impl<T> Pointable for T
source§impl<P, R> ProtoType<R> for Pwhere
R: RustType<P>,
impl<P, R> ProtoType<R> for Pwhere
R: RustType<P>,
source§fn into_rust(self) -> Result<R, TryFromProtoError>
fn into_rust(self) -> Result<R, TryFromProtoError>
See
RustType::from_proto
.source§fn from_rust(rust: &R) -> P
fn from_rust(rust: &R) -> P
See
RustType::into_proto
.