Struct dataflow_types::types::SourcePersistDesc [−][src]
pub struct SourcePersistDesc {
pub primary_stream: PersistStreamDesc,
pub timestamp_bindings_stream: PersistStreamDesc,
pub envelope_desc: EnvelopePersistDesc,
}
Expand description
The details needed to make a source that uses an external SourceConnector
persistent.
Fields
primary_stream: PersistStreamDesc
Name of the primary persisted stream of this source. This is what a consumer of the persisted data would be interested in while the secondary stream(s) of the source are an internal implementation detail.
timestamp_bindings_stream: PersistStreamDesc
Persisted stream of timestamp bindings.
envelope_desc: EnvelopePersistDesc
Any additional details that we need to make the envelope logic stateful.
Trait Implementations
fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error> where
__D: Deserializer<'de>,
fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error> where
__D: Deserializer<'de>,
Deserialize this value from the given Serde deserializer. Read more
Auto Trait Implementations
impl RefUnwindSafe for SourcePersistDesc
impl Send for SourcePersistDesc
impl Sync for SourcePersistDesc
impl Unpin for SourcePersistDesc
impl UnwindSafe for SourcePersistDesc
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