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

Class DataImportServiceEndpointConfigImpl

java.lang.Object

com.illumon.iris.db.v2.routing.impl.yaml.DataImportServiceEndpointConfigImpl

All Implemented Interfaces:

DataImportServiceConfig.EndpointConfig, DataRoutingService.EndpointConfig, DataRoutingService.PropertyProvider

public class DataImportServiceEndpointConfigImpl
extends Object
implements DataImportServiceConfig.EndpointConfig

YAML based implementation of DataImportServiceConfig.EndpointConfig.

Method Summary

Modifier and Type	Method	Description
DataRoutingService.EndpointConfig	asTableDataServiceEndpointConfig()	DataImportServiceEndpointConfigImpl represents tailer and tds endpoints.
String	getName()	Return the name of this configuration, which is likely to be a service name.
Map<String,String>	getProperties()	Return all properties as a map.
String	getProperty(String name)	Return the named property value, or null.
String	getServiceRegistryType()	Return the string representation of the service registry scheme.
int	getThrottleKBps()
String	toString()

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.DataImportServiceConfig.EndpointConfig

isTableDataPortEnabled, isTailerPortEnabled

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

getName, getServiceRegistryType

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

getProperties, getProperty, getProperty

Method Details

getThrottleKBps

public int getThrottleKBps()

Specified by:

getThrottleKBps in interface DataImportServiceConfig.EndpointConfig

asTableDataServiceEndpointConfig

public DataRoutingService.EndpointConfig asTableDataServiceEndpointConfig()

DataImportServiceEndpointConfigImpl represents tailer and tds endpoints. By default, the "port" is the tailer port. When we use this object as a TableDataServiceConfig, we need to change that.

Returns:

the endpoint config as a table data service endpoint

toString

public String toString()

getServiceRegistryType

@NotNull
public String getServiceRegistryType()

Description copied from interface: DataRoutingService.EndpointConfig

Return the string representation of the service registry scheme. Service and client implementations should be able to register new services or look up registered services based on this string.

Specified by:

getServiceRegistryType in interface DataRoutingService.EndpointConfig

Returns:

the name of the service registry scheme

getProperty

@Nullable
public String getProperty(@NotNull
 String name)

Description copied from interface: DataRoutingService.PropertyProvider

Return the named property value, or null.

Specified by:

getProperty in interface DataRoutingService.PropertyProvider

Parameters:

name - the name of the property to fetch

Returns:

the value of the property, or null if not set

getProperties

@NotNull
public Map<String,String> getProperties()

Description copied from interface: DataRoutingService.PropertyProvider

Return all properties as a map. This is useful for interactions outside the DB project.

Specified by:

getProperties in interface DataRoutingService.PropertyProvider

Returns:

a map containing all keys and values for this provider

getName

@NotNull
public String getName()

Description copied from interface: DataRoutingService.EndpointConfig

Return the name of this configuration, which is likely to be a service name.

Specified by:

getName in interface DataRoutingService.EndpointConfig

Returns:

the configuration name