Struct GrpcCaller 

pub struct GrpcCaller { /* private fields */ }

gRPC 分支调用器，带 channel 缓存。

用 connect_lazy 而不是 connect：连接在首次真正发请求时才建立， 断了之后 tonic 自己重连。所以缓存里的 channel 不会因为对方重启而变成死的， 不需要额外的健康检查和淘汰逻辑。

Implementations

impl GrpcCaller

pub fn new(timeout: Duration) -> Self

DTMRS_GRPC_CA 指向一个 PEM 文件时，把它加进信任列表。

读不到就只是不加，不 panic —— 推进器是常驻的， 因为一个可选配置起不来比连不上更糟。

pub fn with_ca_pem(self, pem: impl Into<Vec<u8>>) -> Self

直接指定额外信任的 CA（PEM 内容）。测试和嵌入式宿主用，绕开环境变量。

pub async fn call( &self, target: &GrpcTarget, gid: &str, trans_type: &str, branch_id: &str, op: &str, ) -> BranchResult

调一个 gRPC 分支。任何失败都不会返回 BranchResult::Failure —— 只有对方明确返回 ABORTED 才算业务要求回滚。

Trait Implementations

impl Clone for GrpcCaller

fn clone(&self) -> GrpcCaller

Returns a duplicate of the value.

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

Performs copy-assignment from source.