tempest 0.1.1

Realtime message handling framework inspired by Apache Storm and built with Actix
1
2
3
4
5
6
7
8

use crate::metric::Metrics;
use std::sync::mpsc;

/// Main actor for aggregating flushed metrics
pub(crate) struct AggregateActor {
    /// Aggregate metrics
    metrics: Metrics,
}