Package com.linkedin.venice.controller

Class VeniceControllerService

java.lang.Object

com.linkedin.venice.service.AbstractVeniceService

com.linkedin.venice.controller.VeniceControllerService

All Implemented Interfaces:

Closeable, AutoCloseable

public class VeniceControllerService
extends AbstractVeniceService

A service venice controller. Wraps Helix Controller.

Nested Class Summary

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

AbstractVeniceService.ServiceState

Field Summary

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

logger, serviceState

Constructor Summary

Constructors

Constructor

Description

VeniceControllerService(VeniceControllerMultiClusterConfig multiClusterConfigs, io.tehuti.metrics.MetricsRepository metricsRepository, boolean sslEnabled, Optional<SSLConfig> sslConfig, Optional<DynamicAccessController> accessController, Optional<AuthorizerService> authorizerService, com.linkedin.d2.balancer.D2Client d2Client, Map<String,com.linkedin.d2.balancer.D2Client> d2Clients, Optional<ClientConfig> routerClientConfig, Optional<ICProvider> icProvider, Optional<SupersetSchemaGenerator> externalSupersetSchemaGenerator, PubSubTopicRepository pubSubTopicRepository, PubSubClientsFactory pubSubClientsFactory, PubSubPositionTypeRegistry pubSubPositionTypeRegistry, Optional<VeniceVersionLifecycleEventListener> versionLifecycleEventListener)

Method Summary

Modifier and Type	Method	Description
AdminConsumerService	getAdminConsumerServiceByCluster(String cluster)	This method is for testing.
KafkaValueSerializer	getKafkaValueSerializer()
Admin	getVeniceHelixAdmin()
boolean	startInner()	Causes VeniceControllerService to begin execution.
void	stopInner()	Causes VeniceControllerService to stop executing.

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

Constructor Details

VeniceControllerService

public VeniceControllerService(VeniceControllerMultiClusterConfig multiClusterConfigs,
 io.tehuti.metrics.MetricsRepository metricsRepository,
 boolean sslEnabled,
 Optional<SSLConfig> sslConfig,
 Optional<DynamicAccessController> accessController,
 Optional<AuthorizerService> authorizerService,
 com.linkedin.d2.balancer.D2Client d2Client,
 Map<String,com.linkedin.d2.balancer.D2Client> d2Clients,
 Optional<ClientConfig> routerClientConfig,
 Optional<ICProvider> icProvider,
 Optional<SupersetSchemaGenerator> externalSupersetSchemaGenerator,
 PubSubTopicRepository pubSubTopicRepository,
 PubSubClientsFactory pubSubClientsFactory,
 PubSubPositionTypeRegistry pubSubPositionTypeRegistry,
 Optional<VeniceVersionLifecycleEventListener> versionLifecycleEventListener)

Method Details

startInner

public boolean startInner()

Causes VeniceControllerService to begin execution.

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).

stopInner

public void stopInner()

Causes VeniceControllerService to stop executing.

Specified by:

stopInner in class AbstractVeniceService

getVeniceHelixAdmin

public Admin getVeniceHelixAdmin()

Returns:

a reference to the HelixAdmin object.

getAdminConsumerServiceByCluster

public AdminConsumerService getAdminConsumerServiceByCluster(String cluster)

This method is for testing.

Parameters:

cluster -

Returns:

the admin consumer service for the cluster

getKafkaValueSerializer

public KafkaValueSerializer getKafkaValueSerializer()