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

Class InvalidDataRoutingService

java.lang.Object

com.illumon.iris.db.v2.routing.impl.InvalidDataRoutingService

All Implemented Interfaces:

DataRoutingService, DataRoutingService.NonListening, StorageLookup, EndpointResolver, ClaimsProvider, SafeCloseable, NamedImplementation, AutoCloseable

public class InvalidDataRoutingService
extends Object
implements DataRoutingService.NonListening

A non-functional DataRoutingService that can be used as a placeholder when a routing yml string cannot be parsed into a working DataRoutingService.

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.NonListening, DataRoutingService.NotReadyException, DataRoutingService.NullPropertyProvider, DataRoutingService.PropertyProvider

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

Constructor Summary

Constructors

Constructor	Description
InvalidDataRoutingService(String theYmlString, Exception exception)

Method Summary

Modifier and Type	Method	Description
String	about()	Information about a DataRoutingService instance.
String	asYamlString()	Serialize the data routing as a YAML string.
void	close()
Map<String,DataImportServiceConfig>	getAllDataImportServiceConfigs(boolean excludeCoreConfigs)	Get all DIS configs, optionally excluding core configs (those defined in the main routing yml file) For consumption by administrative tools.
Collection<? extends DataImportServiceConfig.EndpointConfig>	getAllDataImportServiceDestinationConfigs()	Get all known DataImportServer destination configs.
Collection<? extends LogAggregatorConfig>	getAllLogAggregatorServiceConfigs()	Return all log aggregator configurations.
CollectedClaims	getCollectedClaims()	Get the current claims for this owner (DataRoutingService).
DataImportServiceConfig	getDataImportServiceConfig(String name)	Get DIS parameters for this named DIS instance.
Collection<? extends DataImportServiceConfig.EndpointConfig>	getDataImportServiceDestinationConfigs(TableIdentifier tableIdentifier)	Get DIS destination configs for a table key.
LogAggregatorConfig	getLogAggregatorConfig(String configName)	Get configuration for the named log aggregator service instance.
LogAggregatorConfig.EndpointConfig	getLogAggregatorDestinationConfig(TableIdentifier tableIdentifier)	Get the single LAS destination configuration for the given table key.
StorageConfig	getStorage(String name)	Get the StorageConfig associated with the given name.
TableDataServiceConfig	getTableDataServiceConfig(String name)	Information needed to configure a table data service server.
Collection<? extends TableDataServiceConfig>	getTableDataServiceConfigs()	Get all known table data service configurations.
void	registerClaims(DataImportServiceConfig disConfig)	Register all claims for the given DataImportServiceConfig.
LogAggregatorConfig.DeferredEndpoint	resolveLogAggregatorEndpoint(LogAggregatorConfig.EndpointConfig config)	Perform any lookups and transformations required to convert a LogAggregatorConfig.EndpointConfig into a LogAggregatorConfig.Endpoint that can be used for logging to a log aggregator service.
DataRoutingService.DeferredEndpoint	resolveTableDataEndpoint(DataRoutingService.EndpointConfig config)	Perform any lookups and transformations required to convert a DataRoutingService.EndpointConfig into a DataRoutingService.Endpoint that can be used to connect to a remote table data service.
DataImportServiceConfig.DeferredEndpoint	resolveTailerEndpoint(DataImportServiceConfig.EndpointConfig config)	Perform any lookups and transformations required to convert a DataImportServiceConfig.EndpointConfig into a DataImportServiceConfig.Endpoint that can be used to connect to a DIS tailer service.

Methods inherited from class java.lang.Object

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

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

authenticate, authenticate, authenticate, getAllDataImportServiceConfigs, getAllDataImportServiceDeferredDestinations, getAllDataImportServiceDestinations, getDataImportServiceConfigWithStorage, getDataImportServiceDeferredDestinations, getDataImportServiceDestinations, getLocalInstance, getLogAggregatorDeferredDestination, getLogAggregatorDestination

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

listen, removeListener, supportsChangeNotification

Methods inherited from interface com.illumon.util.type.NamedImplementation

getImplementationName

Constructor Details

InvalidDataRoutingService

public InvalidDataRoutingService(@NotNull
 String theYmlString,
 @NotNull
 Exception exception)

Method Details

about

public String about()

Description copied from interface: DataRoutingService

Information about a DataRoutingService instance. Useful for debugging.

Specified by:

about in interface DataRoutingService

Returns:

a string containing information about the instance

getDataImportServiceConfig

@Nullable
public DataImportServiceConfig getDataImportServiceConfig(@NotNull
 String name)

Description copied from interface: DataRoutingService

Get DIS parameters for this named DIS instance. For consumption by a DIS instance or TableDataService consumer.

Specified by:

getDataImportServiceConfig in interface DataRoutingService

Parameters:

name - DIS configuration name

Returns:

the configuration for the named DIS, or null if it does not exist.

getDataImportServiceDestinationConfigs

@NotNull
public Collection<? extends DataImportServiceConfig.EndpointConfig> getDataImportServiceDestinationConfigs(@NotNull
 TableIdentifier tableIdentifier)

Description copied from interface: DataRoutingService

Get DIS destination configs for a table key. For consumption by a Tailer.

Specified by:

getDataImportServiceDestinationConfigs in interface DataRoutingService

Parameters:

tableIdentifier - the identifier of the data to be logged

Returns:

a possibly empty collection of DIS destinations that should receive data for the given table.

getAllDataImportServiceConfigs

@NotNull
public Map<String,DataImportServiceConfig> getAllDataImportServiceConfigs(boolean excludeCoreConfigs)

Description copied from interface: DataRoutingService

Get all DIS configs, optionally excluding core configs (those defined in the main routing yml file) For consumption by administrative tools.

Specified by:

getAllDataImportServiceConfigs in interface DataRoutingService

Parameters:

excludeCoreConfigs - if true, exclude core configs

Returns:

a possibly empty collection of all/non-core DIS configs

getAllDataImportServiceDestinationConfigs

@NotNull
public Collection<? extends DataImportServiceConfig.EndpointConfig> getAllDataImportServiceDestinationConfigs()

Description copied from interface: DataRoutingService

Get all known DataImportServer destination configs. This includes destination configs with disabled tailer ports. For consumption by a Tailer.

Specified by:

getAllDataImportServiceDestinationConfigs in interface DataRoutingService

Returns:

a possibly null collection of all known DIS destinations.

getLogAggregatorConfig

@Nullable
public LogAggregatorConfig getLogAggregatorConfig(@NotNull
 String configName)

Description copied from interface: DataRoutingService

Get configuration for the named log aggregator service instance.

Specified by:

getLogAggregatorConfig in interface DataRoutingService

Parameters:

configName - the LAS configuration name

Returns:

the configuration for the named log aggregator, no null if it does not exist

getAllLogAggregatorServiceConfigs

@NotNull
public Collection<? extends LogAggregatorConfig> getAllLogAggregatorServiceConfigs()

Description copied from interface: DataRoutingService

Return all log aggregator configurations.

Specified by:

getAllLogAggregatorServiceConfigs in interface DataRoutingService

Returns:

a collection of all configured log aggregators.

getLogAggregatorDestinationConfig

@Nullable
public LogAggregatorConfig.EndpointConfig getLogAggregatorDestinationConfig(@NotNull
 TableIdentifier tableIdentifier)

Description copied from interface: DataRoutingService

Get the single LAS destination configuration for the given table key.

Specified by:

getLogAggregatorDestinationConfig in interface DataRoutingService

Parameters:

tableIdentifier - the identifier of the data to be logged

Returns:

the LogAggregatorEndpoint for the given tableIdentifier, or null if none match the key.

getTableDataServiceConfig

@Nullable
public TableDataServiceConfig getTableDataServiceConfig(@NotNull
 String name)

Description copied from interface: DataRoutingService

Information needed to configure a table data service server. For use by a TableDataService provider (LocalTableDataServer, TableDataCacheProxy).

Specified by:

getTableDataServiceConfig in interface DataRoutingService

Parameters:

name - configuration name

Returns:

the named TableDataServiceConfig, or null if not found.

getTableDataServiceConfigs

@NotNull
public Collection<? extends TableDataServiceConfig> getTableDataServiceConfigs()

Description copied from interface: DataRoutingService

Get all known table data service configurations. The data includes name description and tags.

Specified by:

getTableDataServiceConfigs in interface DataRoutingService

Returns:

all known TableDataServiceConfigs

asYamlString

@NotNull
public String asYamlString()

Description copied from interface: DataRoutingService

Serialize the data routing as a YAML string. Internal use only.

Specified by:

asYamlString in interface DataRoutingService

Returns:

YAML representation of the configuration

getStorage

@Nullable
public StorageConfig getStorage(@Nullable
 String name)

Description copied from interface: StorageLookup

Get the StorageConfig associated with the given name.

Specified by:

getStorage in interface StorageLookup

Parameters:

name - The name of the storage to look up. May be null, in which case null will always be returned.

Returns:

The storage config, or null if not found

getCollectedClaims

@NotNull
public CollectedClaims getCollectedClaims()

Description copied from interface: ClaimsProvider

Get the current claims for this owner (DataRoutingService).

Specified by:

getCollectedClaims in interface ClaimsProvider

Returns:

the current CollectedClaims

registerClaims

public void registerClaims(@NotNull
 DataImportServiceConfig disConfig)

Description copied from interface: ClaimsProvider

Register all claims for the given DataImportServiceConfig.

Specified by:

registerClaims in interface ClaimsProvider

Parameters:

disConfig - The DIS config to register

resolveTailerEndpoint

@NotNull
public DataImportServiceConfig.DeferredEndpoint resolveTailerEndpoint(@NotNull
 DataImportServiceConfig.EndpointConfig config)

Description copied from interface: EndpointResolver

Perform any lookups and transformations required to convert a DataImportServiceConfig.EndpointConfig into a DataImportServiceConfig.Endpoint that can be used to connect to a DIS tailer service.

Specified by:

resolveTailerEndpoint in interface EndpointResolver

Parameters:

config - the endpoint configuration

Returns:

an Endpoint for tailing data

resolveLogAggregatorEndpoint

@NotNull
public LogAggregatorConfig.DeferredEndpoint resolveLogAggregatorEndpoint(LogAggregatorConfig.EndpointConfig config)

Description copied from interface: EndpointResolver

Perform any lookups and transformations required to convert a LogAggregatorConfig.EndpointConfig into a LogAggregatorConfig.Endpoint that can be used for logging to a log aggregator service.

Specified by:

resolveLogAggregatorEndpoint in interface EndpointResolver

Parameters:

config - the log aggregator endpoint configuration

Returns:

an Endpoint for the configuration

resolveTableDataEndpoint

@NotNull
public DataRoutingService.DeferredEndpoint resolveTableDataEndpoint(@NotNull
 DataRoutingService.EndpointConfig config)

Description copied from interface: EndpointResolver

Perform any lookups and transformations required to convert a DataRoutingService.EndpointConfig into a DataRoutingService.Endpoint that can be used to connect to a remote table data service.

Specified by:

resolveTableDataEndpoint in interface EndpointResolver

Parameters:

config - the table data service endpoint configuration

Returns:

the table data service endpoint

close

public void close()

Specified by:

close in interface AutoCloseable

Specified by:

close in interface SafeCloseable