Struct Insights 

pub struct Insights { /* private fields */ }

Implementations

impl Insights

pub fn new(options: &TopicOptions, tether_agent: &mut TetherAgent) -> Self

Examples found in repository

examples/api.rs (line 62)

fn demo_topics() {
    let mut tether_agent = TetherAgentOptionsBuilder::new("demoTopics")
        .build()
        .expect("failed to init/connect Tether Agent");

    let options = TopicOptions {
        topic: "#".into(),
        sampler_interval: 1000,
        graph_enable: false,
    };

    let mut insights = Insights::new(&options, &mut tether_agent);

    loop {
        while let Some((topic, payload)) = tether_agent.check_messages() {
            if insights.update(&topic, payload) {
                println!("TOPICS: Insights update: \n{}", insights);
            }
        }
    }
}

pub fn sample(&mut self) -> bool

pub fn sampler(&self) -> &Sampler

pub fn update(&mut self, topic: &TetherOrCustomTopic, payload: Vec<u8>) -> bool

Examples found in repository

examples/api.rs (line 66)

fn demo_topics() {
    let mut tether_agent = TetherAgentOptionsBuilder::new("demoTopics")
        .build()
        .expect("failed to init/connect Tether Agent");

    let options = TopicOptions {
        topic: "#".into(),
        sampler_interval: 1000,
        graph_enable: false,
    };

    let mut insights = Insights::new(&options, &mut tether_agent);

    loop {
        while let Some((topic, payload)) = tether_agent.check_messages() {
            if insights.update(&topic, payload) {
                println!("TOPICS: Insights update: \n{}", insights);
            }
        }
    }
}

pub fn topics(&self) -> &[String]

pub fn roles(&self) -> &[String]

pub fn ids(&self) -> &[String]

pub fn plugs(&self) -> &[String]

pub fn trees(&self) -> &[AgentTree]

pub fn message_count(&self) -> u128

pub fn message_log( &self, ) -> &CircularBuffer<MONITOR_LOG_LENGTH, (String, String)>

pub fn since_log_start(&self) -> Option<Duration>

pub fn get_rate(&self) -> Option<f32>

Messages per second, since log_start was (re)set

Trait Implementations

impl Display for Insights

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

Formats the value using the given formatter.