pub struct AstarteMessage {
pub interface_name: String,
pub path: String,
pub timestamp: Option<Timestamp>,
pub payload: Option<Payload>,
}
Expand description
Astarte message to be used when sending data to Astarte.
Fields§
§interface_name: String
Name of the interface to send data on.
path: String
Endpoint to send the data on.
timestamp: Option<Timestamp>
Explicit timestamp for the message transmission.
payload: Option<Payload>
Content of the message.
Implementations§
source§impl AstarteMessage
impl AstarteMessage
sourcepub fn take_data(self) -> Option<AstarteDataType>
pub fn take_data(self) -> Option<AstarteDataType>
Takes the Payload::AstarteData variant value out of the payload enum.
sourcepub fn data(&self) -> Option<&AstarteDataType>
pub fn data(&self) -> Option<&AstarteDataType>
Returns a reference to the Payload::AstarteData variant value of the payload enum.
sourcepub fn data_mut(&mut self) -> Option<&mut AstarteDataType>
pub fn data_mut(&mut self) -> Option<&mut AstarteDataType>
Returns a mutable reference to the Payload::AstarteData variant value of the payload enum.
sourcepub fn take_unset(self) -> Option<AstarteUnset>
pub fn take_unset(self) -> Option<AstarteUnset>
Takes the Payload::AstarteUnset variant value out of the payload enum.
sourcepub fn unset(&self) -> Option<&AstarteUnset>
pub fn unset(&self) -> Option<&AstarteUnset>
Returns a reference to the Payload::AstarteUnset variant value of the payload enum.
sourcepub fn unset_mut(&mut self) -> Option<&mut AstarteUnset>
pub fn unset_mut(&mut self) -> Option<&mut AstarteUnset>
Returns a mutable reference to the Payload::AstarteUnset variant value of the payload enum.
Trait Implementations§
source§impl Clone for AstarteMessage
impl Clone for AstarteMessage
source§fn clone(&self) -> AstarteMessage
fn clone(&self) -> AstarteMessage
Returns a copy of the value. Read more
1.0.0 · source§fn clone_from(&mut self, source: &Self)
fn clone_from(&mut self, source: &Self)
Performs copy-assignment from
source
. Read moresource§impl Debug for AstarteMessage
impl Debug for AstarteMessage
source§impl Default for AstarteMessage
impl Default for AstarteMessage
source§impl From<AstarteMessage> for MessageHubEvent
impl From<AstarteMessage> for MessageHubEvent
source§fn from(value: AstarteMessage) -> Self
fn from(value: AstarteMessage) -> Self
Converts to this type from the input type.
source§impl Message for AstarteMessage
impl Message for AstarteMessage
source§fn encoded_len(&self) -> usize
fn encoded_len(&self) -> usize
Returns the encoded length of the message without a length delimiter.
source§fn encode<B>(&self, buf: &mut B) -> Result<(), EncodeError>
fn encode<B>(&self, buf: &mut B) -> Result<(), EncodeError>
Encodes the message to a buffer. Read more
source§fn encode_to_vec(&self) -> Vec<u8>where
Self: Sized,
fn encode_to_vec(&self) -> Vec<u8>where
Self: Sized,
Encodes the message to a newly allocated buffer.
source§fn encode_length_delimited<B>(&self, buf: &mut B) -> Result<(), EncodeError>
fn encode_length_delimited<B>(&self, buf: &mut B) -> Result<(), EncodeError>
Encodes the message with a length-delimiter to a buffer. Read more
source§fn encode_length_delimited_to_vec(&self) -> Vec<u8>where
Self: Sized,
fn encode_length_delimited_to_vec(&self) -> Vec<u8>where
Self: Sized,
Encodes the message with a length-delimiter to a newly allocated buffer.
source§fn decode<B>(buf: B) -> Result<Self, DecodeError>
fn decode<B>(buf: B) -> Result<Self, DecodeError>
Decodes an instance of the message from a buffer. Read more
source§fn decode_length_delimited<B>(buf: B) -> Result<Self, DecodeError>
fn decode_length_delimited<B>(buf: B) -> Result<Self, DecodeError>
Decodes a length-delimited instance of the message from the buffer.
source§fn merge<B>(&mut self, buf: B) -> Result<(), DecodeError>
fn merge<B>(&mut self, buf: B) -> Result<(), DecodeError>
Decodes an instance of the message from a buffer, and merges it into
self
. Read moresource§fn merge_length_delimited<B>(&mut self, buf: B) -> Result<(), DecodeError>
fn merge_length_delimited<B>(&mut self, buf: B) -> Result<(), DecodeError>
Decodes a length-delimited instance of the message from buffer, and
merges it into
self
.source§impl PartialEq for AstarteMessage
impl PartialEq for AstarteMessage
impl StructuralPartialEq for AstarteMessage
Auto Trait Implementations§
impl Freeze for AstarteMessage
impl RefUnwindSafe for AstarteMessage
impl Send for AstarteMessage
impl Sync for AstarteMessage
impl Unpin for AstarteMessage
impl UnwindSafe for AstarteMessage
Blanket Implementations§
source§impl<T> BorrowMut<T> for Twhere
T: ?Sized,
impl<T> BorrowMut<T> for Twhere
T: ?Sized,
source§fn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
Mutably borrows from an owned value. Read more
source§impl<T> CloneToUninit for Twhere
T: Clone,
impl<T> CloneToUninit for Twhere
T: Clone,
source§unsafe fn clone_to_uninit(&self, dst: *mut T)
unsafe fn clone_to_uninit(&self, dst: *mut T)
🔬This is a nightly-only experimental API. (
clone_to_uninit
)source§impl<T> Instrument for T
impl<T> Instrument for T
source§fn instrument(self, span: Span) -> Instrumented<Self>
fn instrument(self, span: Span) -> Instrumented<Self>
source§fn in_current_span(self) -> Instrumented<Self>
fn in_current_span(self) -> Instrumented<Self>
source§impl<T> IntoRequest<T> for T
impl<T> IntoRequest<T> for T
source§fn into_request(self) -> Request<T>
fn into_request(self) -> Request<T>
Wrap the input message
T
in a tonic::Request