minerva 0.2.0

Causal ordering for distributed systems
1
2
3
4
5
6
7
8
9
10

extern crate alloc;

use crate::kairos::{Clock, TickCounter};
use crate::metis::Producer;

/// A producer for `station_id` over a fresh, auto-ticking `TickCounter`.
pub(super) fn producer(station_id: u32) -> Producer<Clock<TickCounter>> {
    let clock = Clock::with_default_config(TickCounter::new(), station_id).unwrap();
    Producer::new(clock)
}