Struct rdkafka::producer::future_producer::FutureProducerContext
source · [−]pub struct FutureProducerContext<C: ClientContext + 'static> { /* private fields */ }
Expand description
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
Receives log lines from librdkafka. Read more
Receives the decoded statistics of the librdkafka client. To enable, the
statistics.interval.ms
configuration parameter must be specified. Read more
Receives the JSON-encoded statistics of the librdkafka client. To
enable, the statistics.interval.ms
configuration parameter must be
specified. Read more
Receives global errors from the librdkafka client. Read more
impl<C, R> Producer<FutureProducerContext<C>> for FutureProducer<C, R> where
C: ClientContext + 'static,
R: AsyncRuntime,
impl<C, R> Producer<FutureProducerContext<C>> for FutureProducer<C, R> where
C: ClientContext + 'static,
R: AsyncRuntime,
Returns the Client
underlying this producer.
Flushes any pending messages. Read more
Returns the number of messages that are either waiting to be sent or are sent but are waiting to be acknowledged. Read more
Enable sending transactions with this producer. Read more
Begins a new transaction. Read more
fn send_offsets_to_transaction<T: Into<Timeout>>(
&self,
offsets: &TopicPartitionList,
cgm: &ConsumerGroupMetadata,
timeout: T
) -> KafkaResult<()>
fn send_offsets_to_transaction<T: Into<Timeout>>(
&self,
offsets: &TopicPartitionList,
cgm: &ConsumerGroupMetadata,
timeout: T
) -> KafkaResult<()>
Associates an offset commit operation with this transaction. Read more
Commits the current transaction. Read more
Aborts the current transaction. Read more
Returns a reference to the ProducerContext
used to create this
producer. Read more
type DeliveryOpaque = Box<Sender<OwnedDeliveryResult>>
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. Read more
fn delivery(
&self,
delivery_result: &DeliveryResult<'_>,
tx: Box<Sender<OwnedDeliveryResult>>
)
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. Read more
Auto Trait Implementations
impl<C> RefUnwindSafe for FutureProducerContext<C> where
C: RefUnwindSafe,
impl<C> Send for FutureProducerContext<C>
impl<C> Sync for FutureProducerContext<C>
impl<C> Unpin for FutureProducerContext<C> where
C: Unpin,
impl<C> UnwindSafe for FutureProducerContext<C> where
C: UnwindSafe,
Blanket Implementations
Mutably borrows from an owned value. Read more