pub struct ContainerMetadata {
pub created_at: u64,
}
Fields§
§created_at: u64
Trait Implementations§
source§impl Clone for ContainerMetadata
impl Clone for ContainerMetadata
source§fn clone(&self) -> ContainerMetadata
fn clone(&self) -> ContainerMetadata
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 ContainerMetadata
impl Debug for ContainerMetadata
source§impl EncodeSync for ContainerMetadata
impl EncodeSync for ContainerMetadata
source§impl PartialEq for ContainerMetadata
impl PartialEq for ContainerMetadata
source§fn eq(&self, other: &ContainerMetadata) -> bool
fn eq(&self, other: &ContainerMetadata) -> bool
This method tests for
self
and other
values to be equal, and is used
by ==
.source§impl<'a> Receive<'a> for ContainerMetadata
impl<'a> Receive<'a> for ContainerMetadata
fn receive<'life0, 'async_trait, T>( payload: impl 'async_trait + Buf + Send + 'a, rx: &'life0 mut (impl 'async_trait + Stream<Item = Result<Bytes>> + Send + Sync + Unpin), _sub: Option<AsyncSubscription<T>> ) -> Pin<Box<dyn Future<Output = Result<(Self, Box<dyn Buf + Send + 'a>)>> + Send + 'async_trait>>
fn receive_sync<'life0, 'async_trait>(
payload: impl Buf + Send + 'async_trait + 'a,
rx: &'life0 mut (impl Stream<Item = Result<Bytes, Error>> + Send + Sync + Unpin + 'async_trait)
) -> Pin<Box<dyn Future<Output = Result<(Self, Box<dyn Buf + Send + 'a>), Error>> + Send + 'async_trait>>where
'life0: 'async_trait,
Self: Send + 'async_trait,
impl Eq for ContainerMetadata
impl StructuralPartialEq for ContainerMetadata
Auto Trait Implementations§
impl Freeze for ContainerMetadata
impl RefUnwindSafe for ContainerMetadata
impl Send for ContainerMetadata
impl Sync for ContainerMetadata
impl Unpin for ContainerMetadata
impl UnwindSafe for ContainerMetadata
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> Encode for Twhere
T: EncodeSync + Send,
impl<T> Encode for Twhere
T: EncodeSync + Send,
source§impl<Q, K> Equivalent<K> for Q
impl<Q, K> Equivalent<K> for Q
source§impl<Q, K> Equivalent<K> for Q
impl<Q, K> Equivalent<K> for Q
source§fn equivalent(&self, key: &K) -> bool
fn equivalent(&self, key: &K) -> bool
Compare self to
key
and return true
if they are equal.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<'a, R, Ctx> ReceiveContext<'a, Ctx> for R
impl<'a, R, Ctx> ReceiveContext<'a, Ctx> for R
fn receive_context<'life0, 'life1, 'async_trait, T>( _cx: &'life0 Ctx, payload: impl Buf + Send + 'async_trait + 'a, rx: &'life1 mut (impl Stream<Item = Result<Bytes, Error>> + Send + Sync + Unpin + 'async_trait), sub: Option<AsyncSubscription<T>> ) -> Pin<Box<dyn Future<Output = Result<(R, Box<dyn Buf + Send + 'a>), Error>> + Send + 'async_trait>>
fn receive_context_sync(
cx: &'a Ctx,
payload: impl Buf + Send + 'a,
rx: &'a mut (impl Stream<Item = Result<Bytes, Error>> + Send + Sync + Unpin + 'a)
) -> impl Future<Output = Result<(Self, Box<dyn Buf + Send + 'a>), Error>> + Send + 'awhere
Self: 'a,
source§fn receive_list_context<T>(
cx: &Ctx,
payload: impl Buf + Send + 'a,
rx: &mut (impl Stream<Item = Result<Bytes, Error>> + Send + Sync + Unpin),
sub: Option<AsyncSubscription<T>>
) -> impl Future<Output = Result<(Vec<Self>, Box<dyn Buf + Send + 'a>), Error>> + Send
fn receive_list_context<T>( cx: &Ctx, payload: impl Buf + Send + 'a, rx: &mut (impl Stream<Item = Result<Bytes, Error>> + Send + Sync + Unpin), sub: Option<AsyncSubscription<T>> ) -> impl Future<Output = Result<(Vec<Self>, Box<dyn Buf + Send + 'a>), Error>> + Send
Receive<’a> a list
source§fn receive_tuple_context<'life0, 'async_trait, T, I>(
cx: I,
payload: impl Buf + Send + 'async_trait + 'a,
rx: &'life0 mut (impl Stream<Item = Result<Bytes, Error>> + Send + Sync + Unpin + 'async_trait),
sub: Option<AsyncSubscription<T>>
) -> Pin<Box<dyn Future<Output = Result<(Vec<Self>, Box<dyn Buf + Send + 'a>), Error>> + Send + 'async_trait>>where
'life0: 'async_trait,
T: Stream<Item = Result<Bytes, Error>> + Send + Sync + 'static + 'async_trait,
I: IntoIterator<Item = &'a Ctx> + Send + 'async_trait,
<I as IntoIterator>::IntoIter: ExactSizeIterator + Send,
Self: 'async_trait,
fn receive_tuple_context<'life0, 'async_trait, T, I>(
cx: I,
payload: impl Buf + Send + 'async_trait + 'a,
rx: &'life0 mut (impl Stream<Item = Result<Bytes, Error>> + Send + Sync + Unpin + 'async_trait),
sub: Option<AsyncSubscription<T>>
) -> Pin<Box<dyn Future<Output = Result<(Vec<Self>, Box<dyn Buf + Send + 'a>), Error>> + Send + 'async_trait>>where
'life0: 'async_trait,
T: Stream<Item = Result<Bytes, Error>> + Send + Sync + 'static + 'async_trait,
I: IntoIterator<Item = &'a Ctx> + Send + 'async_trait,
<I as IntoIterator>::IntoIter: ExactSizeIterator + Send,
Self: 'async_trait,
Receive<’a> a tuple