Package com.linkedin.davinci.helix

Class HelixParticipationService

java.lang.Object

com.linkedin.venice.service.AbstractVeniceService

com.linkedin.davinci.helix.HelixParticipationService

All Implemented Interfaces:

StatusMessageHandler<KillOfflinePushMessage>, Closeable, AutoCloseable

public class HelixParticipationService
extends AbstractVeniceService
implements StatusMessageHandler<KillOfflinePushMessage>

Venice Participation Service wrapping Helix Participant.

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

HelixParticipationService(StoreIngestionService storeIngestionService, StorageService storageService, StorageMetadataService storageMetadataService, VeniceConfigLoader veniceConfigLoader, ReadOnlyStoreRepository helixReadOnlyStoreRepository, ReadOnlySchemaRepository helixReadOnlySchemaRepository, io.tehuti.metrics.MetricsRepository metricsRepository, String zkAddress, String clusterName, int port, String hostname, CompletableFuture<SafeHelixManager> managerFuture, HeartbeatMonitoringService heartbeatMonitoringService, BlobTransferManager blobTransferManager)

Method Summary

Modifier and Type	Method	Description
org.apache.helix.HelixManagerProperty	buildHelixManagerProperty(VeniceServerConfig config)
ReadOnlyStoreRepository	getHelixReadOnlyStoreRepository()
Instance	getInstance()
KafkaStoreIngestionService	getKafkaStoreIngestionService()
ThreadPoolExecutor	getLeaderFollowerHelixStateTransitionThreadPool()
PushStatusStoreWriter	getStatusStoreWriter()
VeniceOfflinePushMonitorAccessor	getVeniceOfflinePushMonitorAccessor()
void	handleMessage(KillOfflinePushMessage message)
void	replaceAndAddTestIngestionNotifier(VeniceNotifier notifier)
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 Details

HelixParticipationService

public HelixParticipationService(StoreIngestionService storeIngestionService,
 StorageService storageService,
 StorageMetadataService storageMetadataService,
 VeniceConfigLoader veniceConfigLoader,
 ReadOnlyStoreRepository helixReadOnlyStoreRepository,
 ReadOnlySchemaRepository helixReadOnlySchemaRepository,
 io.tehuti.metrics.MetricsRepository metricsRepository,
 String zkAddress,
 String clusterName,
 int port,
 String hostname,
 CompletableFuture<SafeHelixManager> managerFuture,
 HeartbeatMonitoringService heartbeatMonitoringService,
 BlobTransferManager blobTransferManager)

Method Details

getLeaderFollowerHelixStateTransitionThreadPool

public ThreadPoolExecutor getLeaderFollowerHelixStateTransitionThreadPool()

buildHelixManagerProperty

public org.apache.helix.HelixManagerProperty buildHelixManagerProperty(VeniceServerConfig config)

startInner

public boolean startInner()

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()
               throws IOException

Specified by:

stopInner in class AbstractVeniceService

Throws:

IOException

replaceAndAddTestIngestionNotifier

public void replaceAndAddTestIngestionNotifier(VeniceNotifier notifier)

getInstance

public Instance getInstance()

getVeniceOfflinePushMonitorAccessor

public VeniceOfflinePushMonitorAccessor getVeniceOfflinePushMonitorAccessor()

getStatusStoreWriter

public PushStatusStoreWriter getStatusStoreWriter()

getHelixReadOnlyStoreRepository

public ReadOnlyStoreRepository getHelixReadOnlyStoreRepository()

handleMessage

public void handleMessage(KillOfflinePushMessage message)

Specified by:

handleMessage in interface StatusMessageHandler<KillOfflinePushMessage>

getKafkaStoreIngestionService

public KafkaStoreIngestionService getKafkaStoreIngestionService()