Struct ginepro::LoadBalancedChannelBuilder

pub struct LoadBalancedChannelBuilder<T, S> { /* private fields */ }

Builder to configure and create a LoadBalancedChannel.

Implementations

impl<S> LoadBalancedChannelBuilder<DnsResolver, S>

where S: TryInto<ServiceDefinition> + 'static, S::Error: Into<Box<dyn Error + Send + Sync>> + Send + Sync,

pub fn new_with_service( service_definition: S ) -> LoadBalancedChannelBuilder<DnsResolver, S>

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, S>

Set a custom LookupService.

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

where S: TryInto<ServiceDefinition> + 'static, S::Error: Into<Box<dyn Error + Send + Sync>> + Send + Sync,

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

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, S>

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

pub fn connect_timeout( self, connection_timeout: Duration ) -> LoadBalancedChannelBuilder<T, S>

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

Defaults to the overall request timeout if not set.

pub fn resolution_strategy( self, resolution_strategy: ResolutionStrategy ) -> LoadBalancedChannelBuilder<T, S>

Set the ResolutionStrategy.

Default set to ResolutionStrategy::Lazy.

If ResolutionStrategy::Lazy the domain name will be resolved after-the-fact.

Instead, if ResolutionStrategy::Eager is set the domain name will be attempted resolved once before the LoadBalancedChannel is created, which ensures that the channel will have a non-empty of IPs on startup. If it fails the channel creation will also fail.

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

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

pub async fn channel(self) -> Result<LoadBalancedChannel, Error>

Construct a LoadBalancedChannel from the LoadBalancedChannelBuilder instance.