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, StorageLookup, DynamicResolverMixin, EndpointResolver, ClaimsProvider, WritableDataRoutingService, WritableDataRoutingServiceInternal, SafeCloseable, NamedImplementation, 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.ImmutablePropertyProvider, DataRoutingService.MapPropertyProvider, DataRoutingService.NonListening, 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

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

WritableDataRoutingService.Options

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()	Returns the implementation name for this data routing service.
static DataRoutingServiceKvInMemImpl	make(com.fishlib.configuration.Configuration configuration)	Creates a DataRoutingServiceKvInMemImpl instance with the specified configuration.
static DataRoutingServiceKvInMemImpl	make(com.fishlib.configuration.Configuration configuration, io.deephaven.kv.routing.RoutingFileContext context)	Creates a DataRoutingServiceKvInMemImpl instance with the specified configuration and routing context.
static DataRoutingServiceKvInMemImpl	make(com.fishlib.configuration.Configuration configuration, String filename)	Creates a DataRoutingServiceKvInMemImpl instance with the specified configuration and YAML filename.

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

about, addDises, addDises, asYamlString, asYamlStringRaw, close, getAllDataImportServiceConfigs, getAllDataImportServiceConfigsRaw, getDelegate, listen, removeDises, removeDises, removeListener, replaceConfiguration, replaceConfiguration, supportsChangeNotification, toString, update, update, updateDises, updateDises, validateDisNames

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

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

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.filter.claims.ClaimsProvider

getCollectedClaims, registerClaims

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

authenticate, authenticate, authenticate, getAllDataImportServiceConfigs, getAllDataImportServiceDeferredDestinations, getAllDataImportServiceDestinationConfigs, getAllDataImportServiceDestinations, getAllLogAggregatorServiceConfigs, 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

Methods inherited from interface com.illumon.iris.db.v2.routing.dynamicdis.StorageLookup

getStorage

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

addDis, removeDis, updateDis

Method Details

make

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

Creates a DataRoutingServiceKvInMemImpl instance with the specified configuration. Uses the default routing file context and primes the KV store with the YAML configuration file.

Parameters:

configuration - the configuration to use

Returns:

a new initialized DataRoutingServiceKvInMemImpl instance

Throws:

IOException - if an I/O error occurs while reading the routing configuration

make

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

Creates a DataRoutingServiceKvInMemImpl instance with the specified configuration and routing context. Primes the KV store with the YAML configuration file specified in the configuration.

Parameters:

configuration - the configuration to use

context - the routing file context

Returns:

a new initialized DataRoutingServiceKvInMemImpl instance

Throws:

IOException - if an I/O error occurs while reading the routing configuration

make

public static DataRoutingServiceKvInMemImpl make(@NotNull
 com.fishlib.configuration.Configuration configuration,
 @NotNull
 String filename)
                                          throws IOException

Creates a DataRoutingServiceKvInMemImpl instance with the specified configuration and YAML filename. Primes the KV store with the specified YAML configuration file.

Parameters:

configuration - the configuration to use

filename - the YAML configuration filename to load

Returns:

a new initialized DataRoutingServiceKvInMemImpl instance

Throws:

IOException - if an I/O error occurs while reading the routing configuration

getImplementationName

public String getImplementationName()

Returns the implementation name for this data routing service.

Specified by:

getImplementationName in interface NamedImplementation

Specified by:

getImplementationName in class DataRoutingServiceKvImpl

Returns:

the implementation name