Struct RpcClient 

pub struct RpcClient { /* private fields */ }

Client for making requests to Batata/Nacos server

Implementations

impl RpcClient

pub fn new(server_addresses: Vec<String>) -> Result<Self>

Create a new RPC client

pub fn with_namespace(self, namespace: &str) -> Self

Set namespace

pub fn with_app_name(self, app_name: &str) -> Self

Set app name

pub fn with_labels(self, labels: HashMap<String, String>) -> Self

Set labels

pub fn with_timeout(self, timeout_ms: u64) -> Self

Set timeout

pub fn with_retry(self, retry_times: u32) -> Self

Set retry times

pub async fn start(&self) -> Result<()>

Start the client and establish connection

pub async fn stop(&self)

Stop the client

pub fn is_connected(&self) -> bool

Check if connected

pub fn connection_id(&self) -> Option<String>

Get connection ID

pub async fn request<Req, Resp>(&self, request: &Req) -> Result<Resp>

where Req: RequestTrait + Serialize + Clone, Resp: for<'de> Deserialize<'de> + Default + ResponseTrait,

Send request with retry

pub async fn send(&self, payload: Payload) -> Result<()>

Send request without retry (for fire-and-forget)

pub fn connection(&self) -> Option<Arc<GrpcConnection>>

Get the current connection

pub async fn unary_request<Req, Resp>(&self, request: &Req) -> Result<Resp>

where Req: RequestTrait + Serialize, Resp: for<'de> Deserialize<'de> + Default + ResponseTrait,

Simple unary request without connection state