sharedstate 1.1.0

Sync heavily read state across many servers
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28

use std::{
    hash::{Hash, Hasher},
    time::UNIX_EPOCH,
};

/// Generates an id for a state lineage that is unlikely to collide across
/// nodes, so recovery checks don't accept a follower from a different lineage.
pub fn unique_state_id<A: Hash>(addr: &A) -> u64 {
    let mut hasher = std::hash::DefaultHasher::new();
    addr.hash(&mut hasher);
    now_ms().hash(&mut hasher);
    hasher.finish()
}

pub fn now_ms() -> u64 {
    std::time::SystemTime::now()
        .duration_since(UNIX_EPOCH)
        .unwrap()
        .as_millis() as u64
}

pub fn unknown_id_err(id: u16, name: &str) -> std::io::Error {
    std::io::Error::new(std::io::ErrorKind::InvalidData, format!("unknown id for {}: {}", name, id))
}

pub fn unknown_version_err(version: u16, name: &str) -> std::io::Error {
    std::io::Error::new(std::io::ErrorKind::InvalidData, format!("unknown version for {}: {}", name, version))
}