appinsights 0.2.3

Application Insights SDK for Rust
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35

mod command;

mod memory;
pub use memory::InMemoryChannel;

mod retry;

mod state;

use async_trait::async_trait;

use crate::contracts::Envelope;

/// An implementation of [TelemetryChannel](trait.TelemetryChannel.html) is responsible for queueing
/// and periodically submitting telemetry events.
#[async_trait]
pub trait TelemetryChannel: Send + Sync {
    /// Queues a single telemetry item.
    fn send(&self, envelop: Envelope);

    /// Forces all pending telemetry items to be submitted. The current task will not be blocked.
    fn flush(&self);

    /// Flushes and tears down the submission flow and closes internal channels.
    /// It blocks the current task until all pending telemetry items have been submitted and it is safe to
    /// shutdown without losing telemetry.
    async fn close(&mut self);

    /// Flushes and tears down the submission flow and closes internal channels.
    /// It blocks the current task until all pending telemetry items have been submitted and it is safe to
    /// shutdown without losing telemetry.
    /// Tears down the submission flow and closes internal channels. Any telemetry waiting to be sent is discarded.
    /// This is a more abrupt version of [close](#method.close).
    async fn terminate(&mut self);
}