Package io.deephaven.enterprise.resolver

Class EtcdResolverContext.Builder

java.lang.Object

io.deephaven.enterprise.resolver.ResolverContext.BuilderCommon<EtcdResolverContext.Builder>

io.deephaven.enterprise.resolver.EtcdResolverContext.Builder

Enclosing class:

EtcdResolverContext

public static class EtcdResolverContext.Builder
extends ResolverContext.BuilderCommon<EtcdResolverContext.Builder>

Field Summary

Fields

Modifier and Type	Field	Description
final io.deephaven.shadow.jetcd.io.etcd.jetcd.Client	etcdClient
boolean	serializableEtcdGetOption
double	watchRetryBackoffFactor
double	watchRetryJitterFactor
long	watchRetryMaxDelayMillis
long	watchRetryMinDelayMillis

Fields inherited from class io.deephaven.enterprise.resolver.ResolverContext.BuilderCommon

attrAuthorityOverrideToHost, defaultPort, getTimeoutMillis, localHostFirstIfPresent, logErrorMethod, logInfoMethod, logWarningMethod, scLoadBalancingPolicy, scMaxHedgingAttempts, scMaxRetryAttempts, scRetryEnabled, serviceAuthority, shuffle

Constructor Summary

Constructors

Constructor	Description
Builder(io.deephaven.shadow.jetcd.io.etcd.jetcd.Client etcdClient, Consumer<String> logInfoMethod, Consumer<String> logWarningMethod, Consumer<String> logErrorMethod)

Method Summary

Modifier and Type	Method	Description
EtcdResolverContext	build()
EtcdResolverContext.Builder	setSerializableEtcdGetOption(boolean serializableEtcdGetOption)	Resolution is based on etcd reads via get calls.
EtcdResolverContext.Builder	setWatchRetryBackoffFactor(double v)
EtcdResolverContext.Builder	setWatchRetryJitterFactor(double v)
EtcdResolverContext.Builder	setWatchRetryMaxDelayMillis(long v)
EtcdResolverContext.Builder	setWatchRetryMinDelayMillis(long v)

Methods inherited from class io.deephaven.enterprise.resolver.ResolverContext.BuilderCommon

setAttrAuthorityOverrideToHost, setDefaultPort, setGetTimeoutMillis, setLocalHostFirstIfPresent, setScLoadBalancingPolicy, setScMaxHedgingAttempts, setScMaxRetryAttempts, setScRetryEnabled, setServiceAuthority, setShuffle

Methods inherited from class java.lang.Object

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

Field Details

etcdClient

public final io.deephaven.shadow.jetcd.io.etcd.jetcd.Client etcdClient

serializableEtcdGetOption

public boolean serializableEtcdGetOption

watchRetryMinDelayMillis

public long watchRetryMinDelayMillis

watchRetryMaxDelayMillis

public long watchRetryMaxDelayMillis

watchRetryBackoffFactor

public double watchRetryBackoffFactor

watchRetryJitterFactor

public double watchRetryJitterFactor

Constructor Details

Builder

public Builder(io.deephaven.shadow.jetcd.io.etcd.jetcd.Client etcdClient,
 Consumer<String> logInfoMethod,
 Consumer<String> logWarningMethod,
 Consumer<String> logErrorMethod)

Method Details

setSerializableEtcdGetOption

public EtcdResolverContext.Builder setSerializableEtcdGetOption(boolean serializableEtcdGetOption)

Resolution is based on etcd reads via get calls. See the etcd documentation for serializable reads Etcd can perform linearizable reads (can be served only from the master) or serializable reads (can be served directly from slaves). The default is false, implying to do linearizable reads; if the etcd server connected to this client is a slave, this will require it to forward the read call to the master.

Parameters:

serializableEtcdGetOption - true if linearizable reads are not necessary, and thus can be traded off for lower latency.

Returns:

the builder object, for chaining

setWatchRetryMinDelayMillis

public EtcdResolverContext.Builder setWatchRetryMinDelayMillis(long v)

setWatchRetryMaxDelayMillis

public EtcdResolverContext.Builder setWatchRetryMaxDelayMillis(long v)

setWatchRetryBackoffFactor

public EtcdResolverContext.Builder setWatchRetryBackoffFactor(double v)

setWatchRetryJitterFactor

public EtcdResolverContext.Builder setWatchRetryJitterFactor(double v)

build

public EtcdResolverContext build()