Struct rdkafka::producer::DefaultProducerContext

source · [−]

pub struct DefaultProducerContext;

Expand description

An inert producer context that can be used when customizations are not required.

Trait Implementations

source

impl ClientContext for DefaultProducerContext

source

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

Receives log lines from librdkafka. Read more

source

fn stats(&self, statistics: Statistics)

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

source

fn stats_raw(&self, statistics: &[u8 ])

Receives the JSON-encoded statistics of the librdkafka client. To enable, the statistics.interval.ms configuration parameter must be specified. Read more

source

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

Receives global errors from the librdkafka client. Read more

source

impl Clone for DefaultProducerContext

source

fn clone(&self) -> DefaultProducerContext

Returns a copy of the value. Read more

1.0.0 · source

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

Performs copy-assignment from source. Read more

source

impl ProducerContext for DefaultProducerContext

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

source

fn delivery(&self, _: &DeliveryResult<'_>, _: Self::DeliveryOpaque)

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 DefaultProducerContext

impl Send for DefaultProducerContext

impl Sync for DefaultProducerContext

impl Unpin for DefaultProducerContext

pub fn into(self) -> U

Performs the conversion.

source

impl<T> ToOwned for T where
T: Clone,

type Owned = T

The resulting type after obtaining ownership.

source

pub fn to_owned(&self) -> T

Creates owned data from borrowed data, usually by cloning. Read more

source

pub fn clone_into(&self, target: &mut T)

🔬 This is a nightly-only experimental API. (toowned_clone_into)

Uses borrowed data to replace owned data, usually by cloning. Read more

source

impl<T, U> TryFrom for T where
U: Into<T>,

type Error = Infallible

The type returned in the event of a conversion error.

const: unstable · source

pub fn try_from(value: U) -> Result<T, <T as TryFrom>::Error>

Performs the conversion.

source

impl<T, U> TryInto for T where
U: TryFrom<T>,

type Error = >::Error

The type returned in the event of a conversion error.

const: unstable · source

pub fn try_into(self) -> Result<U, >::Error>

Performs the conversion.

Struct rdkafka::producer::DefaultProducerContext

Trait Implementations

impl ClientContext for DefaultProducerContext

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

fn stats(&self, statistics: Statistics)

fn stats_raw(&self, statistics: &[u8 ])

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

impl Clone for DefaultProducerContext

fn clone(&self) -> DefaultProducerContext

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

impl ProducerContext for DefaultProducerContext

type DeliveryOpaque = ()

fn delivery(&self, _: &DeliveryResult<'_>, _: Self::DeliveryOpaque)

Auto Trait Implementations

impl RefUnwindSafe for DefaultProducerContext

impl Send for DefaultProducerContext

impl Sync for DefaultProducerContext

impl Unpin for DefaultProducerContext

impl UnwindSafe for DefaultProducerContext

Blanket Implementations

impl<T> Any for T where
T: 'static + ?Sized,

pub fn type_id(&self) -> TypeId

impl<T> Borrow<T> for T where
T: ?Sized,

pub fn borrow(&self) -> &T

impl<T> BorrowMut<T> for T where
T: ?Sized,

pub fn borrow_mut(&mut self) -> &mut T

impl<T> From<T> for T

pub fn from(t: T) -> T

impl<T, U> Into<U> for T where
U: From<T>,

pub fn into(self) -> U

impl<T> ToOwned for T where
T: Clone,

type Owned = T

pub fn to_owned(&self) -> T

pub fn clone_into(&self, target: &mut T)

impl<T, U> TryFrom<U> for T where
U: Into<T>,

type Error = Infallible

pub fn try_from(value: U) -> Result<T, <T as TryFrom<U>>::Error>

impl<T, U> TryInto<U> for T where
U: TryFrom<T>,

type Error = <U as TryFrom<T>>::Error

pub fn try_into(self) -> Result<U, <U as TryFrom<T>>::Error>

Struct rdkafka::producer::DefaultProducerContext

Trait Implementations

impl ClientContext for DefaultProducerContext

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

fn stats(&self, statistics: Statistics)

fn stats_raw(&self, statistics: &[u8])

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

impl Clone for DefaultProducerContext

fn clone(&self) -> DefaultProducerContext

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

impl ProducerContext for DefaultProducerContext

type DeliveryOpaque = ()

fn delivery(&self, _: &DeliveryResult<'_>, _: Self::DeliveryOpaque)

Auto Trait Implementations

impl RefUnwindSafe for DefaultProducerContext

impl Send for DefaultProducerContext

impl Sync for DefaultProducerContext

impl Unpin for DefaultProducerContext

impl UnwindSafe for DefaultProducerContext

Blanket Implementations

impl<T> Any for T where T: 'static + ?Sized,

pub fn type_id(&self) -> TypeId

impl<T> Borrow<T> for T where T: ?Sized,

pub fn borrow(&self) -> &T

impl<T> BorrowMut<T> for T where T: ?Sized,

pub fn borrow_mut(&mut self) -> &mut T

impl<T> From<T> for T

pub fn from(t: T) -> T

impl<T, U> Into<U> for T where U: From<T>,

pub fn into(self) -> U

impl<T> ToOwned for T where T: Clone,

type Owned = T

pub fn to_owned(&self) -> T

pub fn clone_into(&self, target: &mut T)

impl<T, U> TryFrom<U> for T where U: Into<T>,

type Error = Infallible

pub fn try_from(value: U) -> Result<T, <T as TryFrom<U>>::Error>

impl<T, U> TryInto<U> for T where U: TryFrom<T>,

type Error = <U as TryFrom<T>>::Error

pub fn try_into(self) -> Result<U, <U as TryFrom<T>>::Error>

fn stats_raw(&self, statistics: &[u8 ])

impl<T> Any for T where
T: 'static + ?Sized,

impl<T> Borrow<T> for T where
T: ?Sized,

impl<T> BorrowMut<T> for T where
T: ?Sized,

impl<T, U> Into<U> for T where
U: From<T>,

impl<T> ToOwned for T where
T: Clone,

impl<T, U> TryFrom<U> for T where
U: Into<T>,

impl<T, U> TryInto<U> for T where
U: TryFrom<T>,