pub fn flush_timer_loop(chan: SyncSender<Event>, interval: u64) {
    let duration = Duration::new(interval, 0);
    loop {
        sleep(duration);
        chan.send(Event::TimerFlush).unwrap();
    }
}
/// Publishes an event on the channel every interval
///
/// This message is used to push data from the buckets to the backends.
Publishes an event on the channel every interval
This message is used to push data from the buckets to the backends.
Publishes an event on the channel every interval This message is used to push data from the buckets to the backends .
pub fn flush_timer_loop(chan: SyncSender<Event>, interval: u64) {
    let duration = Duration::new(interval, 0);
    loop {
        sleep(duration);
        chan.send(Event::TimerFlush).unwrap();
    }
}
pub fn flush_timer_loop ( chan : SyncSender < Event > , interval : u64 ) { let duration = Duration :: new ( interval , 0 ) ; loop { sleep ( duration ) ; chan . send ( Event :: TimerFlush ) . unwrap ( ) ; } }
Publishes an event on the channel every interval
This message is used to push data from the buckets to the backends.
Publishes an event on the channel every interval This message is used to push data from the buckets to the backends .
chan
SyncSender<Event>
interval
u64