Struct rdkafka::producer::FutureProducerContext
[−]
[src]
pub struct FutureProducerContext<C: ProducerContext> { /* fields omitted */ }
The ProducerContext used by the FutureProducer. This context will use a Future as its DeliveryContext and will complete the future when the message is delivered (or failed to). All other callbacks will be delegated to the wrapped ProducerContext.
Trait Implementations
impl<C: Clone + ProducerContext> Clone for FutureProducerContext<C>[src]
fn clone(&self) -> FutureProducerContext<C>
Returns a copy of the value. Read more
fn clone_from(&mut self, source: &Self)1.0.0
Performs copy-assignment from source. Read more
impl<C: ProducerContext> Context for FutureProducerContext<C>[src]
impl<C: ProducerContext> ProducerContext for FutureProducerContext<C>[src]
type DeliveryContext = Complete<DeliveryStatus>
A DeliveryContext is a user-defined structure that will be passed to the base producer when producing a message. The base producer will call the received method on this data once the associated message has been processed correctly. Read more
fn delivery(&self, status: DeliveryStatus, tx: Complete<DeliveryStatus>)
This method will be called once the message has beed delivered (or failed to). The DeliveryContext will be the one provided by the user when calling send. Read more