Enum dataflow::sink::kafka::KafkaSinkStateEnum [−][src]
enum KafkaSinkStateEnum {
Init(Option<KafkaConsistencyInitState>),
Running(Option<KafkaConsistencyRunningState>),
}
Variants
Init(Option<KafkaConsistencyInitState>)
Tuple Fields
Running(Option<KafkaConsistencyRunningState>)
Tuple Fields
Implementations
Trait Implementations
Auto Trait Implementations
impl !RefUnwindSafe for KafkaSinkStateEnum
impl !Send for KafkaSinkStateEnum
impl !Sync for KafkaSinkStateEnum
impl Unpin for KafkaSinkStateEnum
impl !UnwindSafe for KafkaSinkStateEnum
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