Struct rill_engine::tracers::tracer::Tracer

pub struct Tracer<T: Flow> { /* fields omitted */ }

The generic provider that forwards metrics to worker and keeps a flag for checking the activitiy status of the Tracer.

Implementations

impl<T: Flow> Tracer<T>

pub fn new_push(state: T, path: Path) -> (Self, Watcher<T>)

Create a Push mode Tracer

pub fn new_pull(state: T, path: Path, interval: Duration) -> Self

Create a Pull mode Tracer

pub fn path(&self) -> &Path

Returns a reference to a Path of the Tracer.

pub fn send(
    &self,
    data: T::Event,
    opt_system_time: Option<SystemTime>,
    direction: Option<Direction<ProviderProtocol>>
)

Send an event to a Recorder.

pub fn subscribe(&mut self) -> Result<Watcher<T>, Error>

Subscribe to the stream of the watcher.

pub fn callback<F>(&mut self, func: F) where
    F: Fn(ActionEnvelope<T>) + Send + 'static, 

Registers a callback to the flow.

impl<T: Flow> Tracer<T>

pub fn is_active(&self) -> bool

Returns true is the Tracer has to send data.

Trait Implementations

impl<T: Flow> Clone for Tracer<T>

fn clone(&self) -> Self

Returns a copy of the value.

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

Performs copy-assignment from source.

impl<T: Debug + Flow> Debug for Tracer<T>

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

Formats the value using the given formatter.

impl<T: Flow> PartialEq<Tracer<T>> for Tracer<T>

Both tracers are equal only if they use the same description. That means they both have the same recorder/channel.

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<T: Flow> Eq for Tracer<T>