frugalos_segment 1.2.0

A segment in a bucket in a Frugalos cluster
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23

use crate::ServiceHandle;
use fibers_rpc::server::{HandleCall, Reply, ServerBuilder as RpcServerBuilder};
use libfrugalos::repair::RepairConfig;
use libfrugalos::schema::frugalos as rpc;

#[derive(Clone)]
pub struct RpcServer {
    service_handle: ServiceHandle,
}

impl RpcServer {
    pub fn register(service_handle: ServiceHandle, builder: &mut RpcServerBuilder) {
        let this = RpcServer { service_handle };
        builder.add_call_handler::<rpc::SetRepairConfigRpc, _>(this);
    }
}

impl HandleCall<rpc::SetRepairConfigRpc> for RpcServer {
    fn handle_call(&self, repair_config: RepairConfig) -> Reply<rpc::SetRepairConfigRpc> {
        self.service_handle.set_repair_config(repair_config);
        Reply::done(Ok(()))
    }
}