Struct rdkafka::message::OwnedMessage [−][src]
A Kafka message that owns its backing data.
An OwnedMessage
can be created from a BorrowedMessage
using the
BorrowedMessage::detach
method. OwnedMessage
s don’t hold any reference
to the consumer and don’t use any memory inside the consumer buffer.
Implementations
impl OwnedMessage
[src]
pub fn new(
payload: Option<Vec<u8>>,
key: Option<Vec<u8>>,
topic: String,
timestamp: Timestamp,
partition: i32,
offset: i64,
headers: Option<OwnedHeaders>
) -> OwnedMessage
[src]
payload: Option<Vec<u8>>,
key: Option<Vec<u8>>,
topic: String,
timestamp: Timestamp,
partition: i32,
offset: i64,
headers: Option<OwnedHeaders>
) -> OwnedMessage
Creates a new message with the specified content.
This function is mainly useful in tests of rust-rdkafka
itself.
Trait Implementations
impl Clone for OwnedMessage
[src]
fn clone(&self) -> OwnedMessage
[src]
pub fn clone_from(&mut self, source: &Self)
1.0.0[src]
impl Debug for OwnedMessage
[src]
impl Message for OwnedMessage
[src]
type Headers = OwnedHeaders
The type of headers that this message contains.
fn key(&self) -> Option<&[u8]>
[src]
fn payload(&self) -> Option<&[u8]>
[src]
fn topic(&self) -> &str
[src]
fn partition(&self) -> i32
[src]
fn offset(&self) -> i64
[src]
fn timestamp(&self) -> Timestamp
[src]
fn headers(&self) -> Option<&OwnedHeaders>
[src]
fn payload_view<P: ?Sized + FromBytes>(&self) -> Option<Result<&P, P::Error>>
[src]
fn key_view<K: ?Sized + FromBytes>(&self) -> Option<Result<&K, K::Error>>
[src]
Auto Trait Implementations
impl RefUnwindSafe for OwnedMessage
impl Send for OwnedMessage
impl Sync for OwnedMessage
impl Unpin for OwnedMessage
impl UnwindSafe for OwnedMessage
Blanket Implementations
impl<T> Any for T where
T: 'static + ?Sized,
[src]
T: 'static + ?Sized,
impl<T> Borrow<T> for T where
T: ?Sized,
[src]
T: ?Sized,
impl<T> BorrowMut<T> for T where
T: ?Sized,
[src]
T: ?Sized,
pub fn borrow_mut(&mut self) -> &mut T
[src]
impl<T> From<T> for T
[src]
impl<T, U> Into<U> for T where
U: From<T>,
[src]
U: From<T>,
impl<T> ToOwned for T where
T: Clone,
[src]
T: Clone,
type Owned = T
The resulting type after obtaining ownership.
pub fn to_owned(&self) -> T
[src]
pub fn clone_into(&self, target: &mut T)
[src]
impl<T, U> TryFrom<U> for T where
U: Into<T>,
[src]
U: Into<T>,
type Error = Infallible
The type returned in the event of a conversion error.
pub fn try_from(value: U) -> Result<T, <T as TryFrom<U>>::Error>
[src]
impl<T, U> TryInto<U> for T where
U: TryFrom<T>,
[src]
U: TryFrom<T>,