Struct dipstick::InputQueue

pub struct InputQueue { /* private fields */ }

Wrap new scopes with an asynchronous metric write & flush dispatcher.

Implementations

impl InputQueue

pub fn new<OUT: Input + Send + Sync + 'static>(
    target: OUT,
    queue_length: usize
) -> Self

Wrap new scopes with an asynchronous metric write & flush dispatcher.

Trait Implementations

impl CachedInput for InputQueue

fn cached(self, max_size: usize) -> InputCache

Wrap an input with a metric definition cache. This can provide performance benefits for metrics that are dynamically defined at runtime on each access. Caching is useless if all metrics are statically declared or instantiated programmatically in advance and referenced by a long living variable.

impl Clone for InputQueue

fn clone(&self) -> InputQueue

Returns a copy of the value.

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

Performs copy-assignment from source.

impl Input for InputQueue

fn metrics(&self) -> Self::SCOPE

Wrap new scopes with an asynchronous metric write & flush dispatcher.

type SCOPE = InputQueueScope

The type of Scope returned byt this input.

fn input(&self) -> Self::SCOPE

👎Deprecated since 0.7.2: Use metrics()

Open a new scope from this input.

fn new_scope(&self) -> Self::SCOPE

👎Deprecated since 0.8.0: Use metrics()

Open a new scope from this input.

impl WithAttributes for InputQueue

fn get_attributes(&self) -> &Attributes

Return attributes of component.

fn mut_attributes(&mut self) -> &mut Attributes

Return attributes of component for mutation.

fn with_attributes<F: Fn(&mut Attributes)>(&self, edit: F) -> Self

Clone the component and mutate its attributes at once.