Package com.linecorp.centraldogma.client.armeria

Class AbstractArmeriaCentralDogmaBuilder<B extends AbstractArmeriaCentralDogmaBuilder<B>>

java.lang.Object

com.linecorp.centraldogma.client.AbstractCentralDogmaBuilder<B>

com.linecorp.centraldogma.client.armeria.AbstractArmeriaCentralDogmaBuilder<B>

Direct Known Subclasses:

ArmeriaCentralDogmaBuilder, LegacyCentralDogmaBuilder

public class AbstractArmeriaCentralDogmaBuilder<B extends AbstractArmeriaCentralDogmaBuilder<B>>
extends AbstractCentralDogmaBuilder<B>

Builds a CentralDogma client.

Constructor Summary

Constructors

Constructor	Description
AbstractArmeriaCentralDogmaBuilder()

Method Summary

Modifier and Type	Method	Description
protected final ScheduledExecutorService	blockingTaskExecutor()	Returns the ScheduledExecutorService dedicated to the execution of blocking tasks or invocations.
final B	blockingTaskExecutor(ScheduledExecutorService blockingTaskExecutor)	Sets the ScheduledExecutorService dedicated to the execution of blocking tasks or invocations.
final B	clientConfigurator(ArmeriaClientConfigurator clientConfigurator)	Sets the ArmeriaClientConfigurator that will configure an underlying Armeria client which performs the actual socket I/O.
protected final ClientFactory	clientFactory()	Returns the ClientFactory that will create an underlying Armeria client which performs the actual socket I/O.
final B	clientFactory(ClientFactory clientFactory)	Sets the ClientFactory that will create an underlying Armeria client which performs the actual socket I/O.
final B	dnsAddressEndpointGroupConfigurator(DnsAddressEndpointGroupConfigurator dnsAddressEndpointGroupConfigurator)	Sets the DnsAddressEndpointGroupConfigurator that will configure the DNS lookup done by the Armeria client.
protected final EndpointGroup	endpointGroup()	Returns the EndpointGroup this client will connect to, derived from AbstractCentralDogmaBuilder.hosts().
final B	healthCheckInterval(Duration healthCheckInterval)	Sets the interval between health check requests.
final B	healthCheckIntervalMillis(long healthCheckIntervalMillis)	Sets the interval between health check requests in milliseconds.
protected final ClientBuilder	newClientBuilder(String scheme, EndpointGroup endpointGroup, Consumer<ClientBuilder> customizer, String path)	Returns a newly created ClientBuilder configured with the specified customizer and then with the ArmeriaClientConfigurator specified with clientConfigurator(ArmeriaClientConfigurator).

Methods inherited from class com.linecorp.centraldogma.client.AbstractCentralDogmaBuilder

accessToken, accessToken, host, host, hosts, isUseTls, maxNumRetriesOnReplicationLag, maxNumRetriesOnReplicationLag, meterRegistry, meterRegistry, profile, profile, profile, profile, profileResources, profileResources, retryIntervalOnReplicationLag, retryIntervalOnReplicationLagMillis, retryIntervalOnReplicationLagMillis, selectedProfile, self, uri, useTls, useTls

Methods inherited from class java.lang.Object

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

Constructor Details

AbstractArmeriaCentralDogmaBuilder

public AbstractArmeriaCentralDogmaBuilder()

Method Details

clientFactory

protected final ClientFactory clientFactory()

Returns the ClientFactory that will create an underlying Armeria client which performs the actual socket I/O.

clientFactory

public final B clientFactory(ClientFactory clientFactory)

Sets the ClientFactory that will create an underlying Armeria client which performs the actual socket I/O.

clientConfigurator

public final B clientConfigurator(ArmeriaClientConfigurator clientConfigurator)

Sets the ArmeriaClientConfigurator that will configure an underlying Armeria client which performs the actual socket I/O.

dnsAddressEndpointGroupConfigurator

public final B dnsAddressEndpointGroupConfigurator(DnsAddressEndpointGroupConfigurator dnsAddressEndpointGroupConfigurator)

Sets the DnsAddressEndpointGroupConfigurator that will configure the DNS lookup done by the Armeria client.

healthCheckInterval

public final B healthCheckInterval(Duration healthCheckInterval)

Sets the interval between health check requests.

Parameters:

healthCheckInterval - the interval between health check requests. Duration.ZERO disables health check requests.

healthCheckIntervalMillis

public final B healthCheckIntervalMillis(long healthCheckIntervalMillis)

Sets the interval between health check requests in milliseconds.

Parameters:

healthCheckIntervalMillis - the interval between health check requests in milliseconds. 0 disables health check requests.

endpointGroup

protected final EndpointGroup endpointGroup()
                                     throws UnknownHostException

Returns the EndpointGroup this client will connect to, derived from AbstractCentralDogmaBuilder.hosts().

Throws:

UnknownHostException - if failed to resolve the host names from the DNS servers

blockingTaskExecutor

protected final ScheduledExecutorService blockingTaskExecutor()

Returns the ScheduledExecutorService dedicated to the execution of blocking tasks or invocations.

blockingTaskExecutor

public final B blockingTaskExecutor(ScheduledExecutorService blockingTaskExecutor)

Sets the ScheduledExecutorService dedicated to the execution of blocking tasks or invocations. If not set, the common pool is used. The ScheduledExecutorService which will be used for scheduling the tasks related with automatic retries and invoking the callbacks for watched changes.

newClientBuilder

protected final ClientBuilder newClientBuilder(String scheme,
 EndpointGroup endpointGroup,
 Consumer<ClientBuilder> customizer,
 String path)

Returns a newly created ClientBuilder configured with the specified customizer and then with the ArmeriaClientConfigurator specified with clientConfigurator(ArmeriaClientConfigurator).