Package com.illumon.iris.db.v2.configuration

Class DataRoutingServiceFactory

java.lang.Object

com.illumon.iris.db.v2.configuration.DataRoutingServiceFactory

public class DataRoutingServiceFactory
extends Object

Entry point for DataRoutingService access and implementation. This class encapsulates implementation details and provides system defaults.

Field Summary

Fields

Modifier and Type	Field	Description
static String	YAML_CONFIG_FILENAME_PROP
static String	YAML_IMPLEMENTATION_NAME

Constructor Summary

Constructors

Constructor	Description
DataRoutingServiceFactory()

Method Summary

Modifier and Type	Method	Description
static void	createDataRoutingFile(com.fishlib.configuration.Configuration configuration, byte[] ymldata, String user, String code, String comment)	Create the initial data routing configuration in etcd, using the given data.
static DataRoutingService	getDefault()
static DataRoutingService	getK8sDataRoutingService()
static WritableDataRoutingService	getKvEtcdDataRoutingService(com.fishlib.configuration.Configuration configuration)
static WritableDataRoutingService	getRemoteDataRoutingService()	Get a remote data routing service implementation (this will be grpc).
static DataRoutingService	getYamlDataRoutingService(com.fishlib.configuration.Configuration configuration)

Methods inherited from class java.lang.Object

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

Field Details

YAML_IMPLEMENTATION_NAME

public static final String YAML_IMPLEMENTATION_NAME

See Also:

Constant Field Values

YAML_CONFIG_FILENAME_PROP

public static final String YAML_CONFIG_FILENAME_PROP

See Also:

Constant Field Values

Constructor Details

DataRoutingServiceFactory

public DataRoutingServiceFactory()

Method Details

getDefault

public static DataRoutingService getDefault()

Returns:

the routing service instance defined by the Global configuration instance.

getYamlDataRoutingService

public static DataRoutingService getYamlDataRoutingService(@NotNull com.fishlib.configuration.Configuration configuration)

getK8sDataRoutingService

public static DataRoutingService getK8sDataRoutingService()

getRemoteDataRoutingService

@NotNull public static WritableDataRoutingService getRemoteDataRoutingService()

Get a remote data routing service implementation (this will be grpc).

Returns:

a remote implementation of WritableDataRoutingService

getKvEtcdDataRoutingService

public static WritableDataRoutingService getKvEtcdDataRoutingService(@NotNull com.fishlib.configuration.Configuration configuration)

createDataRoutingFile

public static void createDataRoutingFile(@NotNull com.fishlib.configuration.Configuration configuration, @NotNull byte[] ymldata, String user, String code, String comment)

Create the initial data routing configuration in etcd, using the given data. Without an initial data routing configuration, we cannot create a DataRoutingService instance, so the implementation here uses direct access to the KVClient creator.

Parameters:

ymldata - the new data to update

user - the user performing this operation

code - the code parameter to pass into the kv store api

comment - a comment for this change