Package com.linkedin.venice.listener

Class ListenerService

java.lang.Object

com.linkedin.venice.service.AbstractVeniceService

com.linkedin.venice.listener.ListenerService

All Implemented Interfaces:

java.io.Closeable, java.lang.AutoCloseable

public class ListenerService
extends AbstractVeniceService

Service that listens on configured port to accept incoming GET requests

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

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

Method Summary

Modifier and Type	Method	Description
protected StorageReadRequestHandler	createRequestHandler(java.util.concurrent.ThreadPoolExecutor executor, java.util.concurrent.ThreadPoolExecutor computeExecutor, StorageEngineRepository storageEngineRepository, ReadOnlyStoreRepository metadataRepository, ReadOnlySchemaRepository schemaRepository, IngestionMetadataRetriever ingestionMetadataRetriever, ReadMetadataRetriever readMetadataRetriever, DiskHealthCheckService diskHealthService, boolean fastAvroEnabled, boolean parallelBatchGetEnabled, int parallelBatchGetChunkSize, StorageEngineBackedCompressorFactory compressorFactory, java.util.Optional<ResourceReadUsageTracker> resourceReadUsageTracker)
protected java.util.concurrent.ThreadPoolExecutor	createThreadPool(int threadCount, java.lang.String threadNamePrefix, int capacity)
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

Constructor Detail

ListenerService

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

Method Detail

startInner

public boolean startInner()
                   throws java.lang.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:

java.lang.Exception

stopInner

public void stopInner()
               throws java.lang.Exception

Specified by:

stopInner in class AbstractVeniceService

Throws:

java.lang.Exception

createThreadPool

protected java.util.concurrent.ThreadPoolExecutor createThreadPool(int threadCount,
                                                                   java.lang.String threadNamePrefix,
                                                                   int capacity)

createRequestHandler

protected StorageReadRequestHandler createRequestHandler(java.util.concurrent.ThreadPoolExecutor executor,
                                                         java.util.concurrent.ThreadPoolExecutor computeExecutor,
                                                         StorageEngineRepository storageEngineRepository,
                                                         ReadOnlyStoreRepository metadataRepository,
                                                         ReadOnlySchemaRepository schemaRepository,
                                                         IngestionMetadataRetriever ingestionMetadataRetriever,
                                                         ReadMetadataRetriever readMetadataRetriever,
                                                         DiskHealthCheckService diskHealthService,
                                                         boolean fastAvroEnabled,
                                                         boolean parallelBatchGetEnabled,
                                                         int parallelBatchGetChunkSize,
                                                         StorageEngineBackedCompressorFactory compressorFactory,
                                                         java.util.Optional<ResourceReadUsageTracker> resourceReadUsageTracker)