Struct dataflow::sink::kafka::SinkProducerContext [−][src]
pub struct SinkProducerContext {
metrics: Arc<SinkMetrics>,
}
Fields
metrics: Arc<SinkMetrics>
Implementations
Trait Implementations
type DeliveryOpaque = ()
type DeliveryOpaque = ()
A DeliveryOpaque
is a user-defined structure that will be passed to
the producer when producing a message, and returned to the delivery
method once the message has been delivered, or failed to. Read more
This method will be called once the message has been delivered (or
failed to). The DeliveryOpaque
will be the one provided by the user
when calling send. Read more
Auto Trait Implementations
impl !RefUnwindSafe for SinkProducerContext
impl Send for SinkProducerContext
impl Sync for SinkProducerContext
impl Unpin for SinkProducerContext
impl !UnwindSafe for SinkProducerContext
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