Enum dataflow_types::SourceConnector [−][src]
pub enum SourceConnector {
External {
connector: ExternalSourceConnector,
encoding: SourceDataEncoding,
envelope: SourceEnvelope,
consistency: Consistency,
ts_frequency: Duration,
timeline: Timeline,
persist: Option<SourcePersistDesc>,
},
Local {
timeline: Timeline,
persisted_name: Option<String>,
},
}
Variants
External
Fields
connector: ExternalSourceConnector
encoding: SourceDataEncoding
envelope: SourceEnvelope
consistency: Consistency
ts_frequency: Duration
timeline: Timeline
persist: Option<SourcePersistDesc>
Local
A local “source” is either fed by a local input handle, or by reading from a
persisted_source()
. For non-persisted sources, values that are to be inserted
are sent from the coordinator and pushed into the handle on a worker.
For persisted sources, the coordinator only writes new values to a persistent stream. These values will then “show up” here because we read from the same persistent stream.
Implementations
Returns true
if this connector yields input data (including
timestamps) that is stable across restarts. This is important for
exactly-once Sinks that need to ensure that the same data is written,
even when failures/restarts happen.
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 SourceConnector
impl Send for SourceConnector
impl Sync for SourceConnector
impl Unpin for SourceConnector
impl UnwindSafe for SourceConnector
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