Struct rdkafka::producer::future_producer::FutureProducerContext

pub struct FutureProducerContext<C: ClientContext + 'static> { /* fields omitted */ }

The ProducerContext used by the FutureProducer.

This context will use a Future as its DeliveryOpaque and will complete the future when the message is delivered (or failed to).

Trait Implementations

impl<C: ClientContext + 'static> ClientContext for FutureProducerContext<C>

fn log(&self, level: RDKafkaLogLevel, fac: &str, log_message: &str)

Receives log lines from librdkafka.

fn stats(&self, statistics: Statistics)

Receives the statistics of the librdkafka client. To enable, the statistics.interval.ms configuration parameter must be specified.

fn error(&self, error: KafkaError, reason: &str)

Receives global errors from the librdkafka client.

impl<C: Clone + ClientContext + 'static> Clone for FutureProducerContext<C>

fn clone(&self) -> FutureProducerContext<C>

Returns a copy of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl<C, R> Producer<FutureProducerContext<C>> for FutureProducer<C, R> where
    C: ClientContext + 'static,
    R: AsyncRuntime, 

fn client(&self) -> &Client<FutureProducerContext<C>>

Returns the Client underlying this producer.

fn flush<T: Into<Timeout>>(&self, timeout: T)

Flushes any pending messages.

fn in_flight_count(&self) -> i32

Returns the number of messages that are either waiting to be sent or are sent but are waiting to be acknowledged.

fn init_transactions<T: Into<Timeout>>(&self, timeout: T) -> KafkaResult<()>

Enable sending transactions with this producer.

fn begin_transaction(&self) -> KafkaResult<()>

Begins a new transaction.

fn send_offsets_to_transaction<T: Into<Timeout>>(
    &self,
    offsets: &TopicPartitionList,
    cgm: &ConsumerGroupMetadata,
    timeout: T
) -> KafkaResult<()>

Associates an offset commit operation with this transaction.

fn commit_transaction<T: Into<Timeout>>(&self, timeout: T) -> KafkaResult<()>

Commits the current transaction.

fn abort_transaction<T: Into<Timeout>>(&self, timeout: T) -> KafkaResult<()>

Aborts the current transaction.

fn context(&self) -> &Arc<C>

Returns a reference to the ProducerContext used to create this producer.

impl<C: ClientContext + 'static> ProducerContext for FutureProducerContext<C>

type DeliveryOpaque = Box<Sender<OwnedDeliveryResult>>

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.

fn delivery(
    &self,
    delivery_result: &DeliveryResult<'_>,
    tx: Box<Sender<OwnedDeliveryResult>>
)

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.