Struct workflow_rpc::server::RpcServer

pub struct RpcServer { /* private fields */ }

RpcServer - a server-side object that listens for incoming websocket connections and delegates interaction with them to the supplied interfaces: RpcHandler (for RPC server management) and Interface (for method and notification dispatch).

Implementations

impl RpcServer

pub fn new<ServerContext, ConnectionContext, Protocol, Ops>(
rpc_handler: Arc<dyn RpcHandler<Context = ConnectionContext>>,
interface: Arc<Interface<ServerContext, ConnectionContext, Ops>>
) -> RpcServerwhere
ServerContext: Clone + Send + Sync + 'static,
ConnectionContext: Clone + Send + Sync + 'static,
Protocol: ProtocolHandler<ServerContext, ConnectionContext, Ops> + Send + Sync + 'static,
Ops: OpsT,

Create a new RpcServer supplying an Arc of the previsouly-created RpcHandler trait and the Interface struct. This method takes 4 generics:

• ConnectionContext: a struct used as RpcHandler::Context to represent the connection. This struct is passed to each RPC method and notification call.
• ServerContext: a struct supplied to the Interface at the Interface creation time. This struct is passed to each RPC method and notification call.
• Protocol: A protocol type used for the RPC message serialization and deserialization (this can be omitted by using RpcServer::new_with_encoding)
• Ops: A data type (index or an enum) representing the RPC method or notification.

pub fn new_with_encoding<ServerContext, ConnectionContext, Ops, Id>(
encoding: Encoding,
rpc_handler: Arc<dyn RpcHandler<Context = ConnectionContext>>,
interface: Arc<Interface<ServerContext, ConnectionContext, Ops>>
) -> RpcServerwhere
ServerContext: Clone + Send + Sync + 'static,
ConnectionContext: Clone + Send + Sync + 'static,
Ops: OpsT,
Id: IdT,

Create a new RpcServer supplying an Arc of the previsouly-created RpcHandler trait and the Interface struct. This method takes 4 generics:

• ConnectionContext: a struct used as RpcHandler::Context to represent the connection. This struct is passed to each RPC method and notification call.
• ServerContext: a struct supplied to the Interface at the Interface creation time. This struct is passed to each RPC method and notification call.
• Ops: A data type (index or an enum) representing the RPC method or notification.
• Id: A data type representing a message Id - this type must implement the id::Generator trait. Implementation for default Ids such as Id32 and Id64 can be found in the id module.

This function call receives an encoding: Encoding argument containing Encoding::Borsh or Encoding::SerdeJson, based on which it will instantiate the corresponding protocol handler (BorshProtocol or SerdeJsonProtocol respectively).

pub async fn listen(&self, addr: &str) -> WebSocketResult<()>

Start listening for incoming RPC connections on the addr

pub fn stop(&self) -> WebSocketResult<()>

Signal the listening task to stop

pub async fn join(&self) -> WebSocketResult<()>

Blocks until the listening task has stopped

pub async fn stop_and_join(&self) -> WebSocketResult<()>

Signal the listening task to stop and block until it has stopped

Trait Implementations

impl Clone for RpcServer

fn clone(&self) -> RpcServer

Returns a copy of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.