Trait cloudevents_sdk_rdkafka::BaseRecordExt

pub trait BaseRecordExt<'a, K: ToBytes + ?Sized>: Sealed {
    fn message_record(
        self, 
        message_record: &'a MessageRecord
    ) -> Result<BaseRecord<'a, K, Vec<u8>>>;
}

Extension Trait for BaseRecord that fills the record with a MessageRecord.

This trait is sealed and cannot be implemented for types outside of this crate.

Required methods

fn message_record(
    self,
    message_record: &'a MessageRecord
) -> Result<BaseRecord<'a, K, Vec<u8>>>

Fill this BaseRecord with a MessageRecord.

Loading content...

Implementations on Foreign Types

impl<'a, K: ToBytes + ?Sized> BaseRecordExt<'a, K> for BaseRecord<'a, K, Vec<u8>>

fn message_record(
    self,
    message_record: &'a MessageRecord
) -> Result<BaseRecord<'a, K, Vec<u8>>>

Loading content...

Implementors

Loading content...