Struct ginepro::LoadBalancedChannelBuilder

pub struct LoadBalancedChannelBuilder<T> { /* fields omitted */ }

Builder to configure and create a LoadBalancedChannel.

Implementations

impl LoadBalancedChannelBuilder<DnsResolver>

pub async fn new_with_service<H: Into<ServiceDefinition>>(
    service_definition: H
) -> Result<LoadBalancedChannelBuilder<DnsResolver>, Error>

Set the ServiceDefinition of the gRPC server service

• e.g. my.service.uri and 5000.

All the service endpoints of a ServiceDefinition will be constructed by resolving all ips from ServiceDefinition::hostname, and using the portnumber ServiceDefinition::port.

pub fn lookup_service<T: LookupService + Send + Sync + 'static>(
    self,
    lookup_service: T
) -> LoadBalancedChannelBuilder<T>

Set a custom LookupService.

impl<T: LookupService + Send + Sync + 'static + Sized> LoadBalancedChannelBuilder<T>

pub fn new<H: Into<ServiceDefinition>>(
    service_definition: H,
    lookup_service: T
) -> LoadBalancedChannelBuilder<T>

Returns a LoadBalancedChannelBuilder with the ServiceDefinition and the customized LookupService.

pub fn dns_probe_interval(
    self,
    interval: Duration
) -> LoadBalancedChannelBuilder<T>

Set the how often, the client should probe for changes to gRPC server endpoints. Default interval in seconds is 10.

pub fn timeout(self, timeout: Duration) -> LoadBalancedChannelBuilder<T>

Set a timeout that will be applied to every new Endpoint.

pub fn with_tls(
    self,
    tls_config: ClientTlsConfig
) -> LoadBalancedChannelBuilder<T>

Configure the channel to use tls. A tls_config MUST be specified to use the HTTPS scheme.

pub fn channel(self) -> LoadBalancedChannel

Construct a LoadBalancedChannel from the LoadBalancedChannelBuilder instance.