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

Class DataRoutingServiceKvInMemImpl

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.DataRoutingServiceKvInMemImpl

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 DataRoutingServiceKvInMemImpl
extends DataRoutingServiceKvImpl
implements DynamicResolverMixin

Implementation using an in-memory kv implementation. This implementation primes the kv store using the yaml file as from the YAML implementation.
Useful for testing.

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
String	getImplementationName()	Get a name for the implementing class.
static DataRoutingServiceKvInMemImpl	make(com.fishlib.configuration.Configuration configuration)
static DataRoutingServiceKvInMemImpl	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, close, 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 DataRoutingServiceKvInMemImpl make(@NotNull
 com.fishlib.configuration.Configuration configuration)
                                          throws IOException

Throws:

IOException

make

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

Throws:

IOException

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