pub struct ReceivedMessage {
pub message: PubsubMessage,
/* private fields */
}Fields§
§message: PubsubMessageImplementations§
Source§impl ReceivedMessage
impl ReceivedMessage
pub fn ack_id(&self) -> &str
pub async fn ack(&self) -> Result<(), Status>
pub async fn nack(&self) -> Result<(), Status>
pub async fn modify_ack_deadline( &self, ack_deadline_seconds: i32, ) -> Result<(), Status>
Sourcepub fn delivery_attempt(&self) -> Option<usize>
pub fn delivery_attempt(&self) -> Option<usize>
The approximate number of times that Cloud Pub/Sub has attempted to deliver the associated message to a subscriber.
The returned value, if present, will be greater than zero.
For more information refer to the protobuf definition.
Trait Implementations§
Auto Trait Implementations§
impl Freeze for ReceivedMessage
impl !RefUnwindSafe for ReceivedMessage
impl Send for ReceivedMessage
impl Sync for ReceivedMessage
impl Unpin for ReceivedMessage
impl !UnwindSafe for ReceivedMessage
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> 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