Package com.linkedin.venice.router

Class RouterServer

java.lang.Object

com.linkedin.venice.service.AbstractVeniceService

com.linkedin.venice.router.RouterServer

All Implemented Interfaces:

Closeable, AutoCloseable

public class RouterServer
extends AbstractVeniceService

Nested Class Summary

Nested classes/interfaces inherited from class com.linkedin.venice.service.AbstractVeniceService

AbstractVeniceService.ServiceState

Field Summary

Fields

Modifier and Type	Field	Description
static final String	DEFAULT_CLUSTER_DISCOVERY_D2_SERVICE_NAME
static final Collection<MetricEntity>	ROUTER_SERVICE_METRIC_ENTITIES
static final String	ROUTER_SERVICE_METRIC_PREFIX
static final String	ROUTER_SERVICE_NAME

Fields inherited from class com.linkedin.venice.service.AbstractVeniceService

logger, serviceState

Constructor Summary

Constructors

Constructor	Description
RouterServer(VeniceProperties properties, HelixCustomizedViewOfflinePushRepository routingDataRepository, Optional<HelixHybridStoreQuotaRepository> hybridStoreQuotaRepository, HelixReadOnlyStoreRepository metadataRepository, HelixReadOnlySchemaRepository schemaRepository, HelixReadOnlyStoreConfigRepository storeConfigRepository, List<ServiceDiscoveryAnnouncer> serviceDiscoveryAnnouncers, Optional<SSLFactory> sslFactory, HelixLiveInstanceMonitor liveInstanceMonitor)	Only use this constructor for testing when you want to pass mock repositories Having separate constructors just for tests is hard to maintain, especially since in this case, the test constructor does not initialize manager...
RouterServer(VeniceProperties properties, List<ServiceDiscoveryAnnouncer> serviceDiscoveryAnnouncers, Optional<DynamicAccessController> accessController, Optional<SSLFactory> sslFactory)
RouterServer(VeniceProperties properties, List<ServiceDiscoveryAnnouncer> serviceDiscoveryAnnouncers, Optional<DynamicAccessController> accessController, Optional<SSLFactory> sslFactory, io.tehuti.metrics.MetricsRepository metricsRepository)
RouterServer(VeniceProperties properties, List<ServiceDiscoveryAnnouncer> serviceDiscoveryAnnouncers, Optional<DynamicAccessController> accessController, Optional<SSLFactory> sslFactory, io.tehuti.metrics.MetricsRepository metricsRepository, com.linkedin.d2.balancer.D2Client d2Client, String d2ServiceName)

Method Summary

Modifier and Type	Method	Description
void	addOptionalChannelHandler(String key, io.netty.channel.ChannelHandler channelHandler)
VeniceRouterConfig	getConfig()
ReadOnlyStoreRepository	getMetadataRepository()
io.tehuti.metrics.MetricsRepository	getMetricsRepository()
ZkRoutersClusterManager	getRoutersClusterManager()
HelixBaseRoutingRepository	getRoutingDataRepository()
ReadOnlySchemaRepository	getSchemaRepository()
static void	main(String[] args)
void	refresh()
static void	run(String routerConfigFilePath, boolean runForever)
void	setReadRequestThrottling(boolean throttle)
boolean	startInner()
void	stopInner()

Methods inherited from class com.linkedin.venice.service.AbstractVeniceService

close, getName, isRunning, start, stop

Methods inherited from class java.lang.Object

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

Field Details

DEFAULT_CLUSTER_DISCOVERY_D2_SERVICE_NAME

public static final String DEFAULT_CLUSTER_DISCOVERY_D2_SERVICE_NAME

See Also:

• Constant Field Values

ROUTER_SERVICE_NAME

public static final String ROUTER_SERVICE_NAME

See Also:

• Constant Field Values

ROUTER_SERVICE_METRIC_PREFIX

public static final String ROUTER_SERVICE_METRIC_PREFIX

See Also:

• Constant Field Values

ROUTER_SERVICE_METRIC_ENTITIES

public static final Collection<MetricEntity> ROUTER_SERVICE_METRIC_ENTITIES

Constructor Details

RouterServer

public RouterServer(VeniceProperties properties,
 List<ServiceDiscoveryAnnouncer> serviceDiscoveryAnnouncers,
 Optional<DynamicAccessController> accessController,
 Optional<SSLFactory> sslFactory)

RouterServer

public RouterServer(VeniceProperties properties,
 List<ServiceDiscoveryAnnouncer> serviceDiscoveryAnnouncers,
 Optional<DynamicAccessController> accessController,
 Optional<SSLFactory> sslFactory,
 io.tehuti.metrics.MetricsRepository metricsRepository)

RouterServer

public RouterServer(VeniceProperties properties,
 List<ServiceDiscoveryAnnouncer> serviceDiscoveryAnnouncers,
 Optional<DynamicAccessController> accessController,
 Optional<SSLFactory> sslFactory,
 io.tehuti.metrics.MetricsRepository metricsRepository,
 com.linkedin.d2.balancer.D2Client d2Client,
 String d2ServiceName)

RouterServer

public RouterServer(VeniceProperties properties,
 HelixCustomizedViewOfflinePushRepository routingDataRepository,
 Optional<HelixHybridStoreQuotaRepository> hybridStoreQuotaRepository,
 HelixReadOnlyStoreRepository metadataRepository,
 HelixReadOnlySchemaRepository schemaRepository,
 HelixReadOnlyStoreConfigRepository storeConfigRepository,
 List<ServiceDiscoveryAnnouncer> serviceDiscoveryAnnouncers,
 Optional<SSLFactory> sslFactory,
 HelixLiveInstanceMonitor liveInstanceMonitor)

Only use this constructor for testing when you want to pass mock repositories Having separate constructors just for tests is hard to maintain, especially since in this case, the test constructor does not initialize manager...

Method Details

main

public static void main(String[] args)
                 throws Exception

Throws:

Exception

run

public static void run(String routerConfigFilePath,
 boolean runForever)
                throws Exception

Throws:

Exception

getMetricsRepository

public io.tehuti.metrics.MetricsRepository getMetricsRepository()

startInner

public boolean startInner()
                   throws Exception

Specified by:

startInner in class AbstractVeniceService

Returns:

true if the service is completely started, false if it is still starting asynchronously (in this case, it is the implementer's responsibility to set AbstractVeniceService.serviceState to AbstractVeniceService.ServiceState.STARTED upon completion of the async work).

Throws:

Exception

addOptionalChannelHandler

public void addOptionalChannelHandler(String key,
 io.netty.channel.ChannelHandler channelHandler)

stopInner

public void stopInner()
               throws Exception

Specified by:

stopInner in class AbstractVeniceService

Throws:

Exception

getRoutingDataRepository

public HelixBaseRoutingRepository getRoutingDataRepository()

getMetadataRepository

public ReadOnlyStoreRepository getMetadataRepository()

getSchemaRepository

public ReadOnlySchemaRepository getSchemaRepository()

getRoutersClusterManager

public ZkRoutersClusterManager getRoutersClusterManager()

getConfig

public VeniceRouterConfig getConfig()

setReadRequestThrottling

public void setReadRequestThrottling(boolean throttle)

refresh

public void refresh()