pipeline_rpc/
api.rs

1use crate::handlers::{PipelineHandler, UserHandler};
2
3pub struct RpcServer {
4    user_handler: UserHandler,
5    pipeline_handler: PipelineHandler,
6}
7
8impl RpcServer {
9    pub fn new() -> Self {
10        Self {
11            user_handler: UserHandler::new(),
12            pipeline_handler: PipelineHandler::new(),
13        }
14    }
15
16    pub fn start(&self) {
17        println!("RPC Server started");
18        // Your RPC server implementation would go here
19        // e.g., HTTP server, gRPC, tonic, tarpc, etc.
20    }
21
22    pub fn user_handler(&self) -> &UserHandler {
23        &self.user_handler
24    }
25
26    pub fn user_handler_mut(&mut self) -> &mut UserHandler {
27        &mut self.user_handler
28    }
29
30    pub fn pipeline_handler(&self) -> &PipelineHandler {
31        &self.pipeline_handler
32    }
33
34    pub fn pipeline_handler_mut(&mut self) -> &mut PipelineHandler {
35        &mut self.pipeline_handler
36    }
37}
38
39impl Default for RpcServer {
40    fn default() -> Self {
41        Self::new()
42    }
43}
pipeline_rpc/api.rs

pipeline_rpc/
api.rs
