Package com.linkedin.venice.server

Class VeniceServer

java.lang.Object

com.linkedin.venice.server.VeniceServer

public class VeniceServer
extends Object

Class that represents the Venice server. It is responsible for maintaining the lifecycle of multiple internal services including e.g. service start/stop operations and making sure that it is done in the right order based on their dependencies.

Constructor Summary

Constructors

Constructor	Description
VeniceServer(VeniceConfigLoader veniceConfigLoader, io.tehuti.metrics.MetricsRepository metricsRepository, Optional<SSLFactory> sslFactory, Optional<StaticAccessController> routerAccessController, Optional<DynamicAccessController> storeAccessController, Optional<ClientConfig> clientConfigForConsumer, ICProvider icProvider, List<ServiceDiscoveryAnnouncer> serviceDiscoveryAnnouncers)	Deprecated. Use VeniceServer(VeniceServerContext) instead.
VeniceServer(VeniceServerContext ctx)

Method Summary

Modifier and Type	Method	Description
protected ListenerService	createListenerService(StorageEngineRepository storageEngineRepository, ReadOnlyStoreRepository storeMetadataRepository, ReadOnlySchemaRepository schemaRepository, CompletableFuture<HelixCustomizedViewOfflinePushRepository> customizedViewRepository, IngestionMetadataRetriever ingestionMetadataRetriever, ReadMetadataRetriever readMetadataRetriever, VeniceServerConfig serverConfig, io.tehuti.metrics.MetricsRepository metricsRepository, Optional<SSLFactory> sslFactory, Optional<StaticAccessController> routerAccessController, Optional<DynamicAccessController> storeAccessController, DiskHealthCheckService diskHealthService, StorageEngineBackedCompressorFactory compressorFactory, Optional<ResourceReadUsageTracker> resourceReadUsageTracker)
protected VeniceConfigLoader	getConfigLoader()
HeartbeatMonitoringService	getHeartbeatMonitoringService()
HelixParticipationService	getHelixParticipationService()
KafkaStoreIngestionService	getKafkaStoreIngestionService()
io.tehuti.metrics.MetricsRepository	getMetricsRepository()
StorageMetadataService	getStorageMetadataService()
StorageService	getStorageService()
protected static boolean	isServerInAllowList(String zkAddress, String clusterName, String hostname, int listenPort, boolean enableServerAllowlist)
boolean	isStarted()
static void	main(String[] args)
static void	run(VeniceConfigLoader veniceConfigService, boolean joinThread)
static void	run(String configDirectory, boolean joinThread)
void	shutdown()	Method which closes VeniceServer, shuts down its resources, and exits the JVM.
void	start()	Method which starts the services instantiate earlier.

Methods inherited from class java.lang.Object

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

Constructor Details

VeniceServer

@Deprecated
public VeniceServer(VeniceConfigLoader veniceConfigLoader,
 io.tehuti.metrics.MetricsRepository metricsRepository,
 Optional<SSLFactory> sslFactory,
 Optional<StaticAccessController> routerAccessController,
 Optional<DynamicAccessController> storeAccessController,
 Optional<ClientConfig> clientConfigForConsumer,
 ICProvider icProvider,
 List<ServiceDiscoveryAnnouncer> serviceDiscoveryAnnouncers)

Deprecated.

Use VeniceServer(VeniceServerContext) instead. Constructor kept for maintaining the backward compatibility Allocates a new VeniceServer object.

Parameters:

veniceConfigLoader - a config loader to load configs related to cluster and server.

metricsRepository - a registry for reporting metrics.

sslFactory - ssl certificate for enabling HTTP2.

routerAccessController - validates the accesses/requests from routers.

storeAccessController - validates the accesses/requests from clients.

clientConfigForConsumer - kafka client configurations.

icProvider - Provide IC(invocation-context) to remote calls inside services.

serviceDiscoveryAnnouncers - list of server discovery announcers

See Also:

• VeniceConfigLoader
• ServerStoreAclHandler

VeniceServer

public VeniceServer(VeniceServerContext ctx)
             throws VeniceException

Throws:

VeniceException

Method Details

getStorageService

public StorageService getStorageService()

getStorageMetadataService

public StorageMetadataService getStorageMetadataService()

getKafkaStoreIngestionService

public KafkaStoreIngestionService getKafkaStoreIngestionService()

getHelixParticipationService

public HelixParticipationService getHelixParticipationService()

getHeartbeatMonitoringService

public HeartbeatMonitoringService getHeartbeatMonitoringService()

isStarted

public boolean isStarted()

Returns:

true if the VeniceServer and all of its inner services are fully started false if the VeniceServer was not started or if any of its inner services are not finished starting.

start

public void start()
           throws VeniceException

Method which starts the services instantiate earlier.

Throws:

Exception

VeniceException

shutdown

public void shutdown()
              throws VeniceException

Method which closes VeniceServer, shuts down its resources, and exits the JVM.

Throws:

VeniceException

isServerInAllowList

protected static boolean isServerInAllowList(String zkAddress,
 String clusterName,
 String hostname,
 int listenPort,
 boolean enableServerAllowlist)

getConfigLoader

protected VeniceConfigLoader getConfigLoader()

getMetricsRepository

public io.tehuti.metrics.MetricsRepository getMetricsRepository()

createListenerService

protected ListenerService createListenerService(StorageEngineRepository storageEngineRepository,
 ReadOnlyStoreRepository storeMetadataRepository,
 ReadOnlySchemaRepository schemaRepository,
 CompletableFuture<HelixCustomizedViewOfflinePushRepository> customizedViewRepository,
 IngestionMetadataRetriever ingestionMetadataRetriever,
 ReadMetadataRetriever readMetadataRetriever,
 VeniceServerConfig serverConfig,
 io.tehuti.metrics.MetricsRepository metricsRepository,
 Optional<SSLFactory> sslFactory,
 Optional<StaticAccessController> routerAccessController,
 Optional<DynamicAccessController> storeAccessController,
 DiskHealthCheckService diskHealthService,
 StorageEngineBackedCompressorFactory compressorFactory,
 Optional<ResourceReadUsageTracker> resourceReadUsageTracker)

main

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

Throws:

Exception

run

public static void run(String configDirectory,
 boolean joinThread)
                throws Exception

Throws:

Exception

run

public static void run(VeniceConfigLoader veniceConfigService,
 boolean joinThread)
                throws Exception

Throws:

Exception