pub struct CompletableQueueMessage {
pub id: u64,
pub name: String,
pub body: Vec<u8>,
pub created_at: i64,
pub trace_context: IncomingTraceContext,
/* private fields */
}Fields§
§id: u64§name: String§body: Vec<u8>§created_at: i64§trace_context: IncomingTraceContextImplementations§
Source§impl CompletableQueueMessage
impl CompletableQueueMessage
pub async fn complete(self, response: Option<Vec<u8>>) -> Result<()>
pub fn into_message(self) -> QueueMessage
Trait Implementations§
Source§impl Clone for CompletableQueueMessage
impl Clone for CompletableQueueMessage
Auto Trait Implementations§
impl !RefUnwindSafe for CompletableQueueMessage
impl !UnwindSafe for CompletableQueueMessage
impl Freeze for CompletableQueueMessage
impl Send for CompletableQueueMessage
impl Sync for CompletableQueueMessage
impl Unpin for CompletableQueueMessage
impl UnsafeUnpin for CompletableQueueMessage
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,
impl<T> ErasedDestructor for Twhere
T: 'static,
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