Struct Tracer 

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

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(state: T, path: Path, mode: FlowMode) -> Self

Create a new Tracer

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

Create a Push mode Tracer

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

Create a Pull mode Tracer

pub fn path(&self) -> &Path

Returns a reference to a Path of the Tracer.

pub fn description(&self) -> &Description

Returns a reference to a Description of the Tracer.

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

Send an event to a Recorder.

pub fn flush(&self)

Ask recorder to resend a state in the Pull mode.

pub fn sync_callback<F>(&self, callback: F)

where F: Fn(ActionEnvelope<T>) -> Result<(), Error> + Send + Sync + 'static,

Assign a sync callback

pub fn async_callback<F, Fut>(&self, callback: F)

where F: Fn(ActionEnvelope<T>) -> Fut + Send + Sync + 'static, Fut: Future<Output = Result<(), Error>> + Send + 'static,

Assign an async callback

pub fn detach_callback(&self)

Removes the callback

impl<T: Flow> Tracer<T>

pub fn forward<A, Tag>(&self, tag: Tag, ctx: &mut Context<A>)

where A: ActionHandler<TracerAction<T, Tag>> + Actor, Tag: Clone + Send + Sync + 'static,

Forward Tracer events to an Actor.

Trait Implementations

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

fn clone(&self) -> Self

Returns a duplicate 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 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

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