pub struct RemoteAcquisitionSource { /* private fields */ }Expand description
One described source’s acquisitions (3.10.3): an ordinary installed
AcquisitionSource whose descriptor is exactly the one describe
returned. It validates nothing spec 036 3.3.4 validates: a page’s bytes
go to the runtime as the endpoint sent them. Clones share the client’s
queue, so fetches and acquisitions share its in-flight limit (3.12.1).
Implementations§
Source§impl RemoteAcquisitionSource
impl RemoteAcquisitionSource
pub fn descriptor_id(&self) -> &SourceId
Sourcepub fn counters(&self) -> SeamCounters
pub fn counters(&self) -> SeamCounters
The shared client queue’s depth, refusals and late discards.
Trait Implementations§
Source§impl AcquisitionSource for RemoteAcquisitionSource
impl AcquisitionSource for RemoteAcquisitionSource
Source§fn cost_bound(&self, request: &AcquisitionRequest) -> CostBound
fn cost_bound(&self, request: &AcquisitionRequest) -> CostBound
The operation’s declared bound; an estimated or unknown cost model
states no units, so it is unknown.
fn descriptor(&self) -> &SourceDescriptor
fn acquire<'a>(&'a self, call: AcquireCall<'a>) -> BoxFuture<'a, AcquireReport>
Auto Trait Implementations§
impl !RefUnwindSafe for RemoteAcquisitionSource
impl !UnwindSafe for RemoteAcquisitionSource
impl Freeze for RemoteAcquisitionSource
impl Send for RemoteAcquisitionSource
impl Sync for RemoteAcquisitionSource
impl Unpin for RemoteAcquisitionSource
impl UnsafeUnpin for RemoteAcquisitionSource
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