Struct wrpc_interface_blobstore::ObjectId
source · pub struct ObjectId {
pub container: String,
pub object: String,
}
Fields§
§container: String
§object: String
Trait Implementations§
source§impl EncodeSync for ObjectId
impl EncodeSync for ObjectId
source§impl PartialEq for ObjectId
impl PartialEq for ObjectId
source§impl Receive for ObjectId
impl Receive for ObjectId
fn receive<'life0, 'async_trait, T>( payload: impl 'async_trait + Buf + Send + 'static, 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>)>> + Send + 'async_trait>>
fn receive_sync<'life0, 'async_trait>(
payload: impl Buf + Send + 'async_trait + 'static,
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>), Error>> + Send + 'async_trait>>where
'life0: 'async_trait,
Self: Send + 'async_trait,
impl Eq for ObjectId
impl StructuralPartialEq for ObjectId
Auto Trait Implementations§
impl RefUnwindSafe for ObjectId
impl Send for ObjectId
impl Sync for ObjectId
impl Unpin for ObjectId
impl UnwindSafe for ObjectId
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,
fn encode<'life0, 'async_trait>(
self,
payload: &'life0 mut (impl BufMut + Send + 'async_trait)
) -> Pin<Box<dyn Future<Output = Result<Option<AsyncValue>, Error>> + Send + 'async_trait>>where
'life0: 'async_trait,
T: 'async_trait,
fn encode_dynamic_future<'async_trait>(
fut: impl Future<Output = Result<Option<Value>, Error>> + Send + Unpin + 'async_trait + 'static,
payload: impl BufMut + Send + 'async_trait
) -> Pin<Box<dyn Future<Output = Result<Option<AsyncValue>, Error>> + Send + 'async_trait>>where
Self: Sized + 'async_trait,
§impl<Q, K> Equivalent<K> for Q
impl<Q, K> Equivalent<K> for Q
§fn equivalent(&self, key: &K) -> bool
fn equivalent(&self, key: &K) -> bool
Checks if this value is equivalent to the given key. Read more
§impl<Q, K> Equivalent<K> for Q
impl<Q, K> Equivalent<K> for Q
§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<R, Ctx> ReceiveContext<Ctx> for R
impl<R, Ctx> ReceiveContext<Ctx> for R
fn receive_context<'life0, 'life1, 'async_trait, T>( _cx: &'life0 Ctx, payload: impl Buf + Send + 'async_trait + 'static, 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>), Error>> + Send + 'async_trait>>
fn receive_context_sync<'life0, 'life1, 'async_trait>(
cx: &'life0 Ctx,
payload: impl Buf + Send + 'async_trait + 'static,
rx: &'life1 mut (impl Stream<Item = Result<Bytes, Error>> + Send + Sync + Unpin + 'async_trait)
) -> Pin<Box<dyn Future<Output = Result<(Self, Box<dyn Buf + Send>), Error>> + Send + 'async_trait>>where
'life0: 'async_trait,
'life1: 'async_trait,
Self: Send + 'async_trait,
source§fn receive_list_context<'life0, 'life1, 'async_trait, T>(
cx: &'life0 Ctx,
payload: impl Buf + Send + 'async_trait + 'static,
rx: &'life1 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>), Error>> + Send + 'async_trait>>
fn receive_list_context<'life0, 'life1, 'async_trait, T>( cx: &'life0 Ctx, payload: impl Buf + Send + 'async_trait + 'static, rx: &'life1 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>), Error>> + Send + 'async_trait>>
Receive a list
source§fn receive_tuple_context<'a, 'life0, 'async_trait, T, I>(
cx: I,
payload: impl Buf + Send + 'async_trait + 'static,
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>), Error>> + Send + 'async_trait>>where
'a: 'async_trait,
'life0: 'async_trait,
T: Stream<Item = Result<Bytes, Error>> + Send + Sync + Unpin + 'static + 'async_trait,
I: IntoIterator<Item = &'a Ctx> + Send + 'async_trait,
<I as IntoIterator>::IntoIter: ExactSizeIterator + Send,
Self: Send + 'async_trait,
fn receive_tuple_context<'a, 'life0, 'async_trait, T, I>(
cx: I,
payload: impl Buf + Send + 'async_trait + 'static,
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>), Error>> + Send + 'async_trait>>where
'a: 'async_trait,
'life0: 'async_trait,
T: Stream<Item = Result<Bytes, Error>> + Send + Sync + Unpin + 'static + 'async_trait,
I: IntoIterator<Item = &'a Ctx> + Send + 'async_trait,
<I as IntoIterator>::IntoIter: ExactSizeIterator + Send,
Self: Send + 'async_trait,
Receive a tuple