Struct HttpRpcClient 

pub struct HttpRpcClient { /* private fields */ }

HTTP RPC client

Makes RPC calls to the gateway over HTTP POST requests. Supports both plain HTTP (dev mode) and mTLS (production).

Implementations

impl HttpRpcClient

pub fn new( gateway_url: impl Into<String>, content_type: ContentType, ) -> HttpRpcClient

Create a new HTTP RPC client (plain HTTP, no TLS)

pub fn with_timeout(self, timeout: Duration) -> HttpRpcClient

Set the request timeout

pub fn with_mtls( gateway_url: impl Into<String>, content_type: ContentType, cert_path: impl AsRef<Path>, key_path: impl AsRef<Path>, ca_cert_path: impl AsRef<Path>, ) -> Result<HttpRpcClient, Error>

Create a new HTTP RPC client with mTLS

pub fn json(gateway_url: impl Into<String>) -> HttpRpcClient

Create a JSON client (human-readable, debugging)

pub fn protobuf(gateway_url: impl Into<String>) -> HttpRpcClient

Create a Protobuf client (efficient, production)

pub fn json_mtls( gateway_url: impl Into<String>, cert_path: impl AsRef<Path>, key_path: impl AsRef<Path>, ca_cert_path: impl AsRef<Path>, ) -> Result<HttpRpcClient, Error>

Create a JSON client with mTLS

pub fn protobuf_mtls( gateway_url: impl Into<String>, cert_path: impl AsRef<Path>, key_path: impl AsRef<Path>, ca_cert_path: impl AsRef<Path>, ) -> Result<HttpRpcClient, Error>

Create a Protobuf client with mTLS

pub async fn call(&self, request: RpcRequest) -> Result<RpcResponse, Error>

Make an RPC call

pub fn gateway_url(&self) -> &str

Get the gateway URL

pub fn content_type(&self) -> ContentType

Get the content type

pub async fn send( &self, message: &SynapseMessage, ) -> Result<SynapseMessage, Error>

Send a raw SynapseMessage and receive a response

pub async fn send_raw(&self, body: Bytes) -> Result<Bytes, Error>

Send raw bytes and receive raw bytes