Package com.illumon.iris.db.v2.routing.impl.kv

Class DataRoutingServiceKvEtcdImpl

java.lang.Object

com.illumon.iris.db.v2.routing.DataRoutingService.Delegating

com.illumon.iris.db.v2.routing.impl.kv.DataRoutingServiceKvImpl

com.illumon.iris.db.v2.routing.impl.kv.DataRoutingServiceKvEtcdImpl

All Implemented Interfaces:

DataRoutingService, DynamicResolverMixin, EndpointResolver, WritableDataRoutingService, WritableDataRoutingServiceImpl, SafeCloseable, NamedImplementation, io.deephaven.kv.routing.RoutingFileContext.RoutingFileListener, io.deephaven.kv.WatchClient.StateListener<io.deephaven.kv.routing.RoutingFile>, AutoCloseable

public class DataRoutingServiceKvEtcdImpl
extends DataRoutingServiceKvImpl
implements DynamicResolverMixin

Implementation using an etcd kv implementation

Nested Class Summary

Nested classes/interfaces inherited from interface com.illumon.iris.db.v2.routing.DataRoutingService

DataRoutingService.DeferredEndpoint, DataRoutingService.Delegating, DataRoutingService.Endpoint, DataRoutingService.EndpointConfig, DataRoutingService.NotReadyException, DataRoutingService.NullPropertyProvider, DataRoutingService.PropertyProvider

Nested classes/interfaces inherited from interface com.illumon.iris.db.v2.routing.endpoint.DynamicResolverMixin

DynamicResolverMixin.DeferredDISEndpointServiceRegistryImpl, DynamicResolverMixin.DeferredEndpointServiceRegistryImpl, DynamicResolverMixin.DeferredLASEndpointServiceRegistryImpl

Field Summary

Fields inherited from interface com.illumon.iris.db.v2.routing.DataRoutingService

DEFAULT_LOCAL_TABLE_DATA_SERVICE, DEFAULT_QUERY_SERVER_TABLE_DATA_SERVICE, DEFAULT_SELECTION_TAG, HOST_TAG, MERGE_QUERY_TDS_TAG, NULL_PROPERTY_PROVIDER, PORT_TAG, QUERY_QUERY_TDS_TAG, SERVICE_REGISTRY_NONE, SERVICE_REGISTRY_SERVICE, TABLE_DATA_PORT_TAG, TABLE_DATA_SERVICE_CONFIG_PROP, TABLE_DATA_SERVICE_CONFIG_PROPS_WITH_LEGACY, TAILER_PORT_TAG, VALIDATE_QUERY_TDS_TAG

Method Summary

Modifier and Type	Method	Description
void	close()
static io.deephaven.kv.ClientCreator	doMakeKvCreator()	Static provider of this functionality, for use (indirectly) in initial bootstrap.
String	getImplementationName()	Get a name for the implementing class.
static DataRoutingServiceKvEtcdImpl	make(com.fishlib.configuration.Configuration configuration)
static DataRoutingServiceKvEtcdImpl	make(com.fishlib.configuration.Configuration configuration, boolean allowParseErrors)
static DataRoutingServiceKvEtcdImpl	make(com.fishlib.configuration.Configuration configuration, io.deephaven.kv.routing.RoutingFileContext context)

Methods inherited from class com.illumon.iris.db.v2.routing.impl.kv.DataRoutingServiceKvImpl

about, asYamlString, getDelegate, onCompleted, onError, onInitialState, onInitialStateNotPresent, onNextState, onNextStateNotPresent, toString, update, update

Methods inherited from class com.illumon.iris.db.v2.routing.DataRoutingService.Delegating

getAllDataImportServiceDestinationConfigs, getAllLogAggregatorServiceConfigs, getCollectedClaims, getDataImportServiceConfig, getDataImportServiceDestinationConfigs, getLogAggregatorConfig, getLogAggregatorDestinationConfig, getTableDataServiceConfig, getTableDataServiceConfigs

Methods inherited from class java.lang.Object

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

Methods inherited from interface com.illumon.iris.db.v2.routing.DataRoutingService

authenticate, authenticate, authenticate, getAllDataImportServiceDeferredDestinations, getAllDataImportServiceDestinationConfigs, getAllDataImportServiceDestinations, getAllLogAggregatorServiceConfigs, getCollectedClaims, getDataImportServiceConfig, getDataImportServiceConfigWithStorage, getDataImportServiceDeferredDestinations, getDataImportServiceDestinationConfigs, getDataImportServiceDestinations, getLocalInstance, getLogAggregatorConfig, getLogAggregatorDeferredDestination, getLogAggregatorDestination, getLogAggregatorDestinationConfig, getTableDataServiceConfig, getTableDataServiceConfigs

Methods inherited from interface com.illumon.iris.db.v2.routing.endpoint.DynamicResolverMixin

resolveLogAggregatorEndpoint, resolveTableDataEndpoint, resolveTailerEndpoint

Method Details

make

public static DataRoutingServiceKvEtcdImpl make(@NotNull
 com.fishlib.configuration.Configuration configuration)
                                         throws IOException

Throws:

IOException

make

public static DataRoutingServiceKvEtcdImpl make(@NotNull
 com.fishlib.configuration.Configuration configuration,
 boolean allowParseErrors)
                                         throws IOException

Throws:

IOException

make

public static DataRoutingServiceKvEtcdImpl make(@NotNull
 com.fishlib.configuration.Configuration configuration,
 @NotNull
 io.deephaven.kv.routing.RoutingFileContext context)
                                         throws IOException

Throws:

IOException

close

public void close()

Specified by:

close in interface AutoCloseable

Specified by:

close in interface SafeCloseable

Overrides:

close in class DataRoutingServiceKvImpl

getImplementationName

public String getImplementationName()

Description copied from interface: NamedImplementation

Get a name for the implementing class. Useful for abstract classes that implement LogOutputAppendable or override toString.

The default implementation is correct, but not suitable for high-frequency usage.

Specified by:

getImplementationName in interface NamedImplementation

Specified by:

getImplementationName in class DataRoutingServiceKvImpl

Returns:

A name for the implementing class

doMakeKvCreator

public static io.deephaven.kv.ClientCreator doMakeKvCreator()

Static provider of this functionality, for use (indirectly) in initial bootstrap.

Returns:

an etcd KVCreator