krpc-core 0.2.0

RPC framework for service registration and discovery through API exposure, compatible with Dubbo3 protocol, intertunable with Java projects
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21

use std::{collections::HashMap, sync::Arc};

use krpc_common::RpcServer;
use tokio::{
    net::TcpStream,
    sync::{broadcast, mpsc},
};

use crate::filter::RpcServerRoute;

pub mod server;
mod h2_handler;


pub struct StreamHandler {
    pub tcp_stream: TcpStream,
    pub filter_list: Vec<RpcServerRoute>,
    pub rpc_server: HashMap<String, Arc<Box<dyn RpcServer>>>,
    pub shutdown: broadcast::Receiver<()>,
    pub _shutdown_complete: mpsc::Sender<()>,
}