tempest 0.1.0

Realtime message handling framework inspired by Apache Storm and built with Actix
Documentation
1
2
3
4
5
6
7
use crate::metric::Metrics;
use std::sync::mpsc;

pub(crate) struct AggregateActor {
    // metrics
    metrics: Metrics,
}