io.servicetalk.dns.discovery.netty

Class RetryingDnsServiceDiscovererFilter

java.lang.Object

io.servicetalk.client.api.ServiceDiscovererFilter<java.lang.String,java.net.InetAddress,ServiceDiscovererEvent<java.net.InetAddress>>

io.servicetalk.dns.discovery.netty.RetryingDnsServiceDiscovererFilter

All Implemented Interfaces:

ServiceDiscoverer<java.lang.String,java.net.InetAddress,ServiceDiscovererEvent<java.net.InetAddress>>, AsyncCloseable, ListenableAsyncCloseable

public class RetryingDnsServiceDiscovererFilter
extends ServiceDiscovererFilter<java.lang.String,java.net.InetAddress,ServiceDiscovererEvent<java.net.InetAddress>>

Applies a retry strategy to a DNS ServiceDiscoverer.

Throwables that pass shouldRetry(Throwable) are logged, and the retry strategy is invoked. All other Throwables will result in the Publisher terminating with the Throwable.

Constructor Summary

Constructors

Constructor and Description
RetryingDnsServiceDiscovererFilter(ServiceDiscoverer<java.lang.String,java.net.InetAddress,ServiceDiscovererEvent<java.net.InetAddress>> delegate, BiIntFunction<java.lang.Throwable,Completable> retryStrategy) Create an instance of the filter.

Method Summary

Modifier and Type	Method and Description
Publisher<ServiceDiscovererEvent<java.net.InetAddress>>	discover(java.lang.String unresolvedAddress) Subscribe to the service discovery system for changes in the available ResolvedAddress associated with address.
protected boolean	shouldRetry(java.lang.Throwable cause) Determines which Throwables should be retried.

Methods inherited from class io.servicetalk.client.api.ServiceDiscovererFilter

closeAsync, closeAsyncGracefully, onClose

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

RetryingDnsServiceDiscovererFilter

public RetryingDnsServiceDiscovererFilter(ServiceDiscoverer<java.lang.String,java.net.InetAddress,ServiceDiscovererEvent<java.net.InetAddress>> delegate,
                                          BiIntFunction<java.lang.Throwable,Completable> retryStrategy)

Create an instance of the filter.

Parameters:

delegate - the ServiceDiscoverer to delegate to

retryStrategy - the retry strategy to apply

Method Detail

discover

public Publisher<ServiceDiscovererEvent<java.net.InetAddress>> discover(java.lang.String unresolvedAddress)

Description copied from interface: ServiceDiscoverer

Subscribe to the service discovery system for changes in the available ResolvedAddress associated with address.

In general a call to this method will continue to discover changes related to address until the PublisherSource.Subscription corresponding to the return value is cancelled via Cancellable.cancel() or there are no more changes to publish.

Specified by:

discover in interface ServiceDiscoverer<java.lang.String,java.net.InetAddress,ServiceDiscovererEvent<java.net.InetAddress>>

Overrides:

discover in class ServiceDiscovererFilter<java.lang.String,java.net.InetAddress,ServiceDiscovererEvent<java.net.InetAddress>>

Parameters:

unresolvedAddress - the service address to discover. Examples of what this address maybe are:

• hostname/port (e.g. InetAddress)
• service name
• it may be a list of attributes which describe the service attributes to resolve
• something else

Returns:

a Publisher that represents a stream of events from the service discovery system.

shouldRetry

protected boolean shouldRetry(java.lang.Throwable cause)

Determines which Throwables should be retried.

Parameters:

cause - the Throwable to check

Returns:

true to retry, false to terminate the Publisher