Type Alias OverseerHandle

pub type OverseerHandle = MeteredSender<Event>;

Handle for an orchestra.

Aliased Type

struct OverseerHandle { /* private fields */ }

Implementations

impl<T> MeteredSender<T>

pub fn meter(&self) -> &Meter

Get an updated accessor object for all metrics collected.

pub async fn send(&mut self, msg: T) -> Result<(), SendError<T>>

where MeteredSender<T>: Unpin,

Send message in bulk channel, wait until capacity is available.

pub async fn priority_send(&mut self, msg: T) -> Result<(), SendError<T>>

where MeteredSender<T>: Unpin,

Send message in priority channel (if configured), wait until capacity is available.

pub fn try_send(&mut self, msg: T) -> Result<(), TrySendError<T>>

Attempt to send message or fail immediately.

pub fn try_priority_send(&mut self, msg: T) -> Result<(), TrySendError<T>>

Attempt to send message or fail immediately.

pub fn len(&self) -> usize

Returns the current number of messages in the channel based on meter approximation

Trait Implementations

impl<T> Clone for MeteredSender<T>

fn clone(&self) -> MeteredSender<T>

Returns a copy of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl<T> Debug for MeteredSender<T>

where T: Debug,

fn fmt(&self, f: &mut Formatter<'_>) -> Result<(), Error>

Formats the value using the given formatter.

impl<T> Deref for MeteredSender<T>

type Target = Sender<MaybeTimeOfFlight<T>>

The resulting type after dereferencing.

fn deref(&self) -> &<MeteredSender<T> as Deref>::Target

Dereferences the value.

impl<T> DerefMut for MeteredSender<T>

fn deref_mut(&mut self) -> &mut <MeteredSender<T> as Deref>::Target

Mutably dereferences the value.