sharedstate 0.4.4

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

use std::{fmt::Debug, future::Future, hash::Hash};
use message_encoding::MessageEncoding;
use tokio::io::{AsyncRead, AsyncWrite};

use crate::recoverable_state::SourceId;

pub trait SyncIO: Sized + Send + Sync + 'static {
    type Address: MessageEncoding + Debug + Hash + SourceId;
    type Read: AsyncRead + Send + Unpin + 'static;
    type Write: AsyncWrite + Send + Unpin + 'static;

    fn connect(&self, remote: &Self::Address) -> impl Future<Output = std::io::Result<SyncConnection<Self>>> + Send;

    fn next_client(&self) -> impl Future<Output = std::io::Result<SyncConnection<Self>>> + Send;
}

pub struct SyncConnection<I: SyncIO> {
    pub remote: I::Address,
    pub read: I::Read,
    pub write: I::Write,
}