Struct fluvio_dataplane_protocol::record::ConsumerRecord [−][src]
pub struct ConsumerRecord<B = DefaultRecord> {
pub offset: i64,
pub partition: i32,
pub record: B,
}
Expand description
Record that can be used by Consumer which needs access to metadata
Fields
offset: i64
The offset of this Record into its partition
partition: i32
The partition where this Record is stored
record: B
The Record contents
Implementations
Returns the inner representation of the Record
Trait Implementations
Auto Trait Implementations
impl<B> RefUnwindSafe for ConsumerRecord<B> where
B: RefUnwindSafe,
impl<B> Send for ConsumerRecord<B> where
B: Send,
impl<B> Sync for ConsumerRecord<B> where
B: Sync,
impl<B> Unpin for ConsumerRecord<B> where
B: Unpin,
impl<B> UnwindSafe for ConsumerRecord<B> where
B: UnwindSafe,
Blanket Implementations
Mutably borrows from an owned value. Read more
Attaches the provided Subscriber
to this type, returning a
WithDispatch
wrapper. Read more
Attaches the current default Subscriber
to this type, returning a
WithDispatch
wrapper. Read more