Struct dataflow::source::PersistentTimestampBindingsConfig [−][src]
pub struct PersistentTimestampBindingsConfig<ST: Codec, AT: Codec> {
upper_seal_ts: u64,
read_handle: StreamReadHandle<ST, AT>,
pub write_handle: StreamWriteHandle<ST, AT>,
}
Expand description
Configuration for persistent timestamp bindings.
ST
is the source timestamp, while AT
is the timestamp that is assigned based on timestamp
bindings.
Fields
upper_seal_ts: u64
The timestamp up to which all involved streams have been sealed.
read_handle: StreamReadHandle<ST, AT>
StreamReadHandle
for the collection that we should persist to.
write_handle: StreamWriteHandle<ST, AT>
StreamWriteHandle
for the collection that we should persist to.
Implementations
pub fn new(
upper_seal_ts: u64,
read_handle: StreamReadHandle<K, V>,
write_handle: StreamWriteHandle<K, V>
) -> Self
pub fn new(
upper_seal_ts: u64,
read_handle: StreamReadHandle<K, V>,
write_handle: StreamWriteHandle<K, V>
) -> Self
Creates a new PersistentTimestampBindingsConfig
from the given parts.
Trait Implementations
Auto Trait Implementations
impl<ST, AT> !RefUnwindSafe for PersistentTimestampBindingsConfig<ST, AT>
impl<ST, AT> Send for PersistentTimestampBindingsConfig<ST, AT> where
AT: Send,
ST: Send,
impl<ST, AT> Sync for PersistentTimestampBindingsConfig<ST, AT> where
AT: Sync,
ST: Sync,
impl<ST, AT> Unpin for PersistentTimestampBindingsConfig<ST, AT> where
AT: Unpin,
ST: Unpin,
impl<ST, AT> !UnwindSafe for PersistentTimestampBindingsConfig<ST, AT>
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