#[non_exhaustive]pub struct Ack {
pub queue: String,
pub key: Option<ListValue>,
pub ignore_not_found: bool,
/* private fields */
}Expand description
Arguments to ack operations.
Fields (Non-exhaustive)§
This struct is marked as non-exhaustive
Non-exhaustive structs could have additional fields added in future. Therefore, non-exhaustive structs cannot be constructed in external crates using the traditional
Struct { .. } syntax; cannot be matched against without a wildcard ..; and struct update syntax will not work.queue: StringRequired. The queue where the message to be acked is stored.
key: Option<ListValue>Required. The primary key of the message to be acked.
ignore_not_found: boolBy default, an attempt to ack a message that does not exist will fail
with a NOT_FOUND error. With ignore_not_found set to true, the ack
will succeed even if the message does not exist. This is useful for
unconditionally acking a message, even if it is missing or has already
been acked.
Implementations§
Source§impl Ack
impl Ack
Sourcepub fn set_or_clear_key<T>(self, v: Option<T>) -> Self
pub fn set_or_clear_key<T>(self, v: Option<T>) -> Self
Sets or clears the value of key.
Sourcepub fn set_ignore_not_found<T: Into<bool>>(self, v: T) -> Self
pub fn set_ignore_not_found<T: Into<bool>>(self, v: T) -> Self
Sets the value of ignore_not_found.
Trait Implementations§
impl StructuralPartialEq for Ack
Auto Trait Implementations§
impl Freeze for Ack
impl RefUnwindSafe for Ack
impl Send for Ack
impl Sync for Ack
impl Unpin for Ack
impl UnsafeUnpin for Ack
impl UnwindSafe for Ack
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
impl<ST, DT> CastableFrom<ST, Initialized, Initialized> for DT
impl<ST, DT> CastableFrom<ST, Uninit, Uninit> for DT
Source§impl<T> CloneToUninit for Twhere
T: Clone,
impl<T> CloneToUninit for Twhere
T: Clone,
impl<T> DeserializeOwned for Twhere
T: for<'de> Deserialize<'de>,
Source§impl<T> FutureExt for T
impl<T> FutureExt for T
Source§fn with_context(self, otel_cx: Context) -> WithContext<Self>
fn with_context(self, otel_cx: Context) -> WithContext<Self>
Source§fn with_current_context(self) -> WithContext<Self>
fn with_current_context(self) -> WithContext<Self>
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