Struct dataflow::render::sources::PersistentSourceConfig [−][src]
pub struct PersistentSourceConfig<K: Codec, V: Codec, ST: Codec, AT: Codec> {
bindings_config: PersistentTimestampBindingsConfig<ST, AT>,
envelope_config: PersistentEnvelopeConfig<K, V>,
}
Expand description
Configuration for persistent sources.
Note: This is quite tailored to Kafka Upsert sources for now, but we can change/extend before we add new types of sources/envelopes.
ST
is the source timestamp, while AT
is the timestamp that is assigned based on timestamp
bindings.
Fields
bindings_config: PersistentTimestampBindingsConfig<ST, AT>
envelope_config: PersistentEnvelopeConfig<K, V>
Implementations
pub fn new(
bindings_config: PersistentTimestampBindingsConfig<ST, AT>,
envelope_config: PersistentEnvelopeConfig<K, V>
) -> Self
pub fn new(
bindings_config: PersistentTimestampBindingsConfig<ST, AT>,
envelope_config: PersistentEnvelopeConfig<K, V>
) -> Self
Creates a new PersistentSourceConfig
from the given parts.
Trait Implementations
Auto Trait Implementations
impl<K, V, ST, AT> !RefUnwindSafe for PersistentSourceConfig<K, V, ST, AT>
impl<K, V, ST, AT> Send for PersistentSourceConfig<K, V, ST, AT> where
AT: Send,
K: Send,
ST: Send,
V: Send,
impl<K, V, ST, AT> Sync for PersistentSourceConfig<K, V, ST, AT> where
AT: Sync,
K: Sync,
ST: Sync,
V: Sync,
impl<K, V, ST, AT> Unpin for PersistentSourceConfig<K, V, ST, AT> where
AT: Unpin,
K: Unpin,
ST: Unpin,
V: Unpin,
impl<K, V, ST, AT> !UnwindSafe for PersistentSourceConfig<K, V, 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