Struct dataflow::sink::kafka::KafkaConsistencyRunningState [−][src]
struct KafkaConsistencyRunningState {
topic: String,
schema_id: i32,
gate_ts: Rc<Cell<Option<Timestamp>>>,
}
Fields
topic: String
schema_id: i32
gate_ts: Rc<Cell<Option<Timestamp>>>
Trait Implementations
Auto Trait Implementations
impl !RefUnwindSafe for KafkaConsistencyRunningState
impl !Send for KafkaConsistencyRunningState
impl !Sync for KafkaConsistencyRunningState
impl Unpin for KafkaConsistencyRunningState
impl !UnwindSafe for KafkaConsistencyRunningState
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