Package com.linkedin.venice.controller

Class VeniceController

java.lang.Object

com.linkedin.venice.controller.VeniceController

public class VeniceController
extends Object

Venice Controller to manage the cluster. Internally wraps Helix Controller.

Field Summary

Fields

Modifier and Type	Field	Description
static final Collection<MetricEntity>	CONTROLLER_SERVICE_METRIC_ENTITIES
static final String	CONTROLLER_SERVICE_METRIC_PREFIX
static final String	CONTROLLER_SERVICE_NAME

Constructor Summary

Constructors

Constructor	Description
VeniceController(VeniceControllerContext ctx)
VeniceController(List<VeniceProperties> propertiesList, io.tehuti.metrics.MetricsRepository metricsRepository, List<ServiceDiscoveryAnnouncer> serviceDiscoveryAnnouncers, Optional<DynamicAccessController> accessController, Optional<AuthorizerService> authorizerService, com.linkedin.d2.balancer.D2Client d2Client, Optional<ClientConfig> routerClientConfig, Optional<ICProvider> icProvider, Optional<SupersetSchemaGenerator> externalSupersetSchemaGenerator)	Deprecated.

Method Summary

Modifier and Type	Method	Description
VeniceControllerService	getVeniceControllerService()
static void	main(String[] args)
static void	run(String clusterConfigFilePath, String controllerConfigFilePath, boolean joinThread)
void	start()	Causes venice controller and its associated services to begin execution.
void	stop()	Causes venice controller and its associated services to stop executing.

Methods inherited from class java.lang.Object

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

Field Details

CONTROLLER_SERVICE_NAME

public static final String CONTROLLER_SERVICE_NAME

See Also:

• Constant Field Values

CONTROLLER_SERVICE_METRIC_PREFIX

public static final String CONTROLLER_SERVICE_METRIC_PREFIX

See Also:

• Constant Field Values

CONTROLLER_SERVICE_METRIC_ENTITIES

public static final Collection<MetricEntity> CONTROLLER_SERVICE_METRIC_ENTITIES

Constructor Details

VeniceController

@Deprecated
public VeniceController(List<VeniceProperties> propertiesList,
 io.tehuti.metrics.MetricsRepository metricsRepository,
 List<ServiceDiscoveryAnnouncer> serviceDiscoveryAnnouncers,
 Optional<DynamicAccessController> accessController,
 Optional<AuthorizerService> authorizerService,
 com.linkedin.d2.balancer.D2Client d2Client,
 Optional<ClientConfig> routerClientConfig,
 Optional<ICProvider> icProvider,
 Optional<SupersetSchemaGenerator> externalSupersetSchemaGenerator)

Deprecated.

Allocates a new VeniceController object.

Parameters:

propertiesList - config properties coming from ConfigKeys.

metricsRepository - a metric repository to emit metrics.

serviceDiscoveryAnnouncers - a list of ServiceDiscoveryAnnouncer for service discovery announcement. Can be empty.

accessController - an optional DynamicAccessController for auth/auth. Deprecated, use authorizerService instead.

authorizerService - an optional AuthorizerService for auth/auth.

d2Client - a D2Client used for interacting with child controllers.

routerClientConfig - an optional ClientConfig used for reading schema from routers.

icProvider - an optional invocation-context provider class for calls between various deployable services.

externalSupersetSchemaGenerator - an optional SupersetSchemaGenerator used for generating superset schema.

VeniceController

public VeniceController(VeniceControllerContext ctx)

Method Details

start

public void start()

Causes venice controller and its associated services to begin execution.

stop

public void stop()

Causes venice controller and its associated services to stop executing.

getVeniceControllerService

public VeniceControllerService getVeniceControllerService()

Returns:

the Venice controller service.

main

public static void main(String[] args)

run

public static void run(String clusterConfigFilePath,
 String controllerConfigFilePath,
 boolean joinThread)