Struct dataflow::render::envelope_none::PersistentEnvelopeNoneConfig [−][src]
pub struct PersistentEnvelopeNoneConfig<V: Codec> {
pub upper_seal_ts: u64,
pub read_handle: StreamReadHandle<V, ()>,
pub write_handle: StreamWriteHandle<V, ()>,
}
Expand description
Persist configuration for ENVELOPE NONE
sources.
Fields
upper_seal_ts: u64
The timestamp up to which which data should be read when restoring.
read_handle: StreamReadHandle<V, ()>
StreamReadHandle
for the collection that we should persist to.
write_handle: StreamWriteHandle<V, ()>
StreamWriteHandle
for the collection that we should persist to.
Implementations
pub fn new(
upper_seal_ts: u64,
read_handle: StreamReadHandle<V, ()>,
write_handle: StreamWriteHandle<V, ()>
) -> Self
pub fn new(
upper_seal_ts: u64,
read_handle: StreamReadHandle<V, ()>,
write_handle: StreamWriteHandle<V, ()>
) -> Self
Creates a new PersistentEnvelopeNoneConfig
from the given parts.
Trait Implementations
Auto Trait Implementations
impl<V> !RefUnwindSafe for PersistentEnvelopeNoneConfig<V>
impl<V> Send for PersistentEnvelopeNoneConfig<V> where
V: Send,
impl<V> Sync for PersistentEnvelopeNoneConfig<V> where
V: Sync,
impl<V> Unpin for PersistentEnvelopeNoneConfig<V> where
V: Unpin,
impl<V> !UnwindSafe for PersistentEnvelopeNoneConfig<V>
Blanket Implementations
Mutably borrows from an owned value. Read more
Attaches the provided Subscriber
to this type, returning a
WithDispatch
wrapper. Read more
Attaches the current default Subscriber
to this type, returning a
WithDispatch
wrapper. Read more