Skip to main content

sharded_counter_service

hydro_test::tutorials::partitioned_counter

Function sharded_counter_service 

Source 
pub fn sharded_counter_service<'a>(
    leader: &Process<'a, CounterServer>,
    shard_servers: &Cluster<'a, CounterShard>,
    increment_requests: KeyedStream<u32, String, Process<'a, CounterServer>>,
    get_requests: KeyedStream<u32, String, Process<'a, CounterServer>>,
) -> (KeyedStream<u32, String, Process<'a, CounterServer>, Unbounded, NoOrder>, KeyedStream<u32, (String, usize), Process<'a, CounterServer>, Unbounded, NoOrder>)