Struct solana_metrics::metrics::MetricsAgent

pub struct MetricsAgent {
    sender: Sender<MetricsCommand>,
}

Fields

sender: Sender<MetricsCommand>

Implementations

impl MetricsAgent

pub fn new( writer: Arc<dyn MetricsWriter + Send + Sync>, write_frequency: Duration, max_points_per_sec: usize ) -> Self

fn collect_points( points: &mut Vec<DataPoint>, counters: &mut HashMap<(&'static str, u64), CounterPoint> ) -> Vec<DataPoint>

fn write( writer: &Arc<dyn MetricsWriter + Send + Sync>, points: Vec<DataPoint>, max_points: usize, max_points_per_sec: usize, last_write_time: Instant, points_buffered: usize )

fn run( receiver: &Receiver<MetricsCommand>, writer: &Arc<dyn MetricsWriter + Send + Sync>, write_frequency: Duration, max_points_per_sec: usize )

pub fn submit(&self, point: DataPoint, level: Level)

pub fn submit_counter(&self, counter: CounterPoint, level: Level, bucket: u64)

pub fn flush(&self)

Trait Implementations

impl Default for MetricsAgent

fn default() -> Self

Returns the “default value” for a type.

impl Drop for MetricsAgent

fn drop(&mut self)

Executes the destructor for this type.