Struct RpcServer 

pub struct RpcServer<T: RpcTransport + 'static> { /* private fields */ }

Implementations

impl<T: RpcTransport + 'static> RpcServer<T>

pub fn new( transport: Arc<T>, caller_actor: impl Into<String>, enforcer: Arc<dyn CapabilityEnforcer>, ) -> Self

pub fn register_unary( &self, method: impl Into<String>, capability: impl Into<String>, handler: UnaryHandler, )

pub fn register_stream( &self, method: impl Into<String>, capability: impl Into<String>, handler: StreamHandler, )

pub fn register_subscribe( &self, method: impl Into<String>, capability: impl Into<String>, handler: SubscribeHandler, )

pub fn register_client_stream( &self, method: impl Into<String>, capability: impl Into<String>, handler: ClientStreamHandler, )

pub fn register_bidi( &self, method: impl Into<String>, capability: impl Into<String>, handler: BidiHandler, )

pub fn register_command_channel( &self, method: impl Into<String>, capability: impl Into<String>, handler: CommandChannelHandler, initial_credit: u32, )

pub fn register_bulk_transfer( &self, method: impl Into<String>, capability: impl Into<String>, handler: BulkTransferHandler, )

pub fn register_telemetry( &self, method: impl Into<String>, capability: impl Into<String>, handler: TelemetryHandler, priority: StreamingPriority, )

pub fn register_remote_shell( &self, method: impl Into<String>, capability: impl Into<String>, handler: RemoteShellHandler, )

pub fn register_agent_session( &self, method: impl Into<String>, capability: impl Into<String>, handler: AgentSessionHandler, )

pub fn register_http_bridge( &self, method: impl Into<String>, capability: impl Into<String>, handler: HttpBridgeHandler, )

pub fn caller_actor(&self) -> &str

pub fn transport(&self) -> &Arc<T>

pub fn enforcer(&self) -> &Arc<dyn CapabilityEnforcer>

impl<T: RpcTransport + 'static> RpcServer<T>

pub fn check_authorization( &self, caller: &str, method: &str, capability: &str, ) -> CapabilityDecision

Run the CapabilityEnforcer against a synthetic call without going through the transport — useful for CLI tooling and tests that want to confirm what the server would decide for a given (caller, method, capability) triple.