Struct Resource

pub struct Resource<S>
where
    S: QueueStrategy,
{ /* private fields */ }

Represents a simple resource that gathers its statistics.

Implementations

impl<S> Resource<S>

where S: QueueStrategy,

pub fn new(strategy: S, count: isize) -> NewResource<S>

Create a new resource by the specified queue storage and initial count, where the latter becomes the capacity as well.

pub fn new_with_max_count( strategy: S, count: isize, max_count: Option<isize>, ) -> NewResource<S>

Create a new resource by the specified queue storage, initial count and optional maximum count, i.e. capacity.

pub fn count(resource: Grc<Self>) -> impl Event<Item = isize> + Clone

Return the current available count of the resource.

pub fn count_stats( resource: Grc<Self>, ) -> impl Event<Item = TimingStats<isize>> + Clone

Return the statistics for available count of the resource.

pub fn count_changed(&self) -> impl Observable<Message = isize> + Clone

Notifies when the count property changes.

pub fn count_changed_(&self) -> impl Observable<Message = ()> + Clone

Notifies when the count property changes.

pub fn util_count(resource: Grc<Self>) -> impl Event<Item = isize> + Clone

Return the current utilization count of the resource.

pub fn util_count_stats( resource: Grc<Self>, ) -> impl Event<Item = TimingStats<isize>> + Clone

Return the statistics for utilization count of the resource.

pub fn util_count_changed(&self) -> impl Observable<Message = isize> + Clone

Notifies when the util_count property changes.

pub fn util_count_changed_(&self) -> impl Observable<Message = ()> + Clone

Notifies when the util_count property changes.

pub fn queue_count(resource: Grc<Self>) -> impl Event<Item = isize> + Clone

Return the current queue length of the resource.

pub fn queue_count_stats( resource: Grc<Self>, ) -> impl Event<Item = TimingStats<isize>> + Clone

Return the statistics for queue length of the resource.

pub fn queue_count_changed(&self) -> impl Observable<Message = isize> + Clone

Notifies when the queue_count property changes.

pub fn queue_count_changed_(&self) -> impl Observable<Message = ()> + Clone

Notifies when the queue_count property changes.

pub fn total_wait_time(resource: Grc<Self>) -> impl Event<Item = f64> + Clone

Return the total wait time of the resource.

pub fn wait_time( resource: Grc<Self>, ) -> impl Event<Item = SamplingStats<f64>> + Clone

Return the statistics for wait time of the resource.

pub fn wait_time_changed( &self, ) -> impl Observable<Message = SamplingStats<f64>> + Clone

Notifies when the wait_time property changes.

pub fn wait_time_changed_(&self) -> impl Observable<Message = ()> + Clone

Notifies when the wait_time property changes.

pub fn changed_(&self) -> impl Observable<Message = ()> + Clone

Triggered when one of the Resource properties changes.

pub fn reset(resource: Grc<Self>) -> impl Event<Item = ()> + Clone

Reset the statistics.

Trait Implementations

impl<S> PartialEq for Resource<S>

where S: QueueStrategy,

fn eq(&self, other: &Self) -> bool

Tests for self and other values to be equal, and is used by ==.

fn ne(&self, other: &Rhs) -> bool

Tests for !=. The default implementation is almost always sufficient, and should not be overridden without very good reason.

impl<S> Eq for Resource<S>

where S: QueueStrategy,