Struct grr_plugin::JsonRpcBroker

pub struct JsonRpcBroker { /* private fields */ }

Implementations

impl JsonRpcBroker

pub fn new(
    unique_port: UniquePort,
    bind_ip: String,
    advertise_ip: String,
    outgoing_conninfo_sender: UnboundedSender<Result<ConnInfo, Status>>,
    incoming_conninfo_stream_receiver_receiver: UnboundedReceiver<Streaming<ConnInfo>>
) -> Self

pub async fn new_server(&mut self, handler: IoHandler) -> Result<u32, Error>

pub async fn next_service_id(&mut self) -> u32

pub fn get_unused_port(&mut self) -> Option<u16>

pub async fn dial_to_host_service(
    &mut self,
    service_id: u32
) -> Result<Channel, Error>