Struct dvcompute::simulation::resource::stats::Resource

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

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: Rc<Self>) -> impl Event<Item = isize> + Clone

Return the current available count of the resource.

pub fn count_stats(
    resource: Rc<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: Rc<Self>) -> impl Event<Item = isize> + Clone

Return the current utilization count of the resource.

pub fn util_count_stats(
    resource: Rc<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: Rc<Self>) -> impl Event<Item = isize> + Clone

Return the current queue length of the resource.

pub fn queue_count_stats(
    resource: Rc<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: Rc<Self>) -> impl Event<Item = f64> + Clone

Return the total wait time of the resource.

pub fn wait_time(
    resource: Rc<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: Rc<Self>) -> impl Event<Item = ()> + Clone

Reset the statistics.

Trait Implementations

impl<S> PartialEq<Resource<S>> for Resource<S> where
    S: QueueStrategy, 

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

This method tests for self and other values to be equal, and is used by ==.

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

This method tests for !=.

impl<S> Eq for Resource<S> where
    S: QueueStrategy,