Struct ClientBuilder 

pub struct ClientBuilder { /* private fields */ }

Implementations

impl ClientBuilder

pub fn endpoints(endpoints: Vec<String>) -> Self

pub fn batch_flush_interval(self, flush_interval: Duration) -> Self

pub fn retry_policy(self, policy: RetryPolicy) -> Self

Override the default RetryPolicy.

The policy controls per-attempt deadlines, the overall deadline across all candidate endpoints, the cap on attempts, and the jittered backoff base. The per-attempt deadline is also pushed down to tonic::transport::Endpoint::connect_timeout and Endpoint::timeout for the built-in default and TLS transport paths so a blackholed peer fails fast at the transport layer. User-supplied Self::channel_connector closures own their own Endpoint config; the policy still bounds the retry loop’s outer tokio::time::timeout around them.

pub fn tls_config(self, cfg: ClientTlsConfig) -> Self

Configure the client to dial bare endpoints with TLS. Bare host:port becomes https://host:port; explicit http://... endpoints supplied in Self::endpoints remain plaintext; explicit https://... endpoints use the provided TLS config.

Wire-supplied http://... leader-hint trailers are NOT honored under tls_config — they are dropped to prevent a contacted peer from downgrading the transport. Operator-supplied configuration still wins; untrusted wire input does not.

Setting both Self::channel_connector and tls_config is allowed; the last call wins (standard builder semantics). Calling channel_connector after tls_config also clears the reject-plaintext-hint policy, since the caller-owned connector owns its own scheme policy.

pub fn channel_connector<F, Fut>(self, connector: F) -> Self

where F: Fn(&str) -> Fut + Send + Sync + 'static, Fut: Future<Output = Result<Channel, BoxError>> + Send + 'static,

Replace the default plaintext channel construction with a caller-owned closure. The closure is invoked on first use of each endpoint — configured endpoints and leader-hint redirects alike. Errors returned from the closure surface as ClientError::Connector.

See module docs for the interaction with Self::tls_config (last-wins) and the scheme matrix. A caller-owned connector replaces the built-in TLS plumbing entirely, including the reject-plaintext-leader-hint policy — the closure is responsible for whatever scheme policy it wants to enforce.

pub async fn build(self) -> Result<Client, ClientError>