Struct persist::operators::upsert::PersistentUpsertConfig [−][src]
pub struct PersistentUpsertConfig<K: Codec, V: Codec> {
upper_seal_ts: u64,
read_handle: StreamReadHandle<K, V>,
pub write_handle: StreamWriteHandle<K, V>,
}
Expand description
Persist configuration for persistent upsert.
Fields
upper_seal_ts: u64
The timestamp up to which which data should be read when restoring.
read_handle: StreamReadHandle<K, V>
StreamReadHandle
for the collection that we should persist to.
write_handle: StreamWriteHandle<K, V>
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 PersistentUpsertConfig
from the given parts.
Trait Implementations
Auto Trait Implementations
impl<K, V> !RefUnwindSafe for PersistentUpsertConfig<K, V>
impl<K, V> Send for PersistentUpsertConfig<K, V> where
K: Send,
V: Send,
impl<K, V> Sync for PersistentUpsertConfig<K, V> where
K: Sync,
V: Sync,
impl<K, V> Unpin for PersistentUpsertConfig<K, V> where
K: Unpin,
V: Unpin,
impl<K, V> !UnwindSafe for PersistentUpsertConfig<K, 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