raftify 0.1.34

Experimental High level Raft framework
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

use serde::{Deserialize, Serialize};
use std::net::{SocketAddr, ToSocketAddrs};
use tonic::transport::Channel;

use super::{create_client, error::Result, raft_service::raft_service_client::RaftServiceClient};

#[derive(Debug, Clone, Deserialize, Serialize)]
pub struct Peer {
    pub addr: SocketAddr,
    #[serde(skip_serializing, skip_deserializing)]
    pub client: Option<RaftServiceClient<Channel>>,
}

impl Peer {
    pub fn new<A: ToSocketAddrs>(addr: A) -> Self {
        let addr = addr.to_socket_addrs().unwrap().next().unwrap();
        Peer { addr, client: None }
    }

    pub async fn connect(&mut self) -> Result<()> {
        let client = create_client(&self.addr).await?;
        self.client = Some(client);
        Ok(())
    }
}