Package com.linkedin.davinci.ingestion

Interface VeniceIngestionBackend

All Superinterfaces:

java.lang.AutoCloseable, java.io.Closeable, IngestionBackendBase

All Known Implementing Classes:

DefaultIngestionBackend, IsolatedIngestionBackend

public interface VeniceIngestionBackend
extends IngestionBackendBase

Method Summary

Modifier and Type	Method	Description
void	addPushStatusNotifier(VeniceNotifier pushStatusNotifier)	Adds ingestion listener which reports ingestion status for different push monitors.
void	demoteToStandby(VeniceStoreVersionConfig storeConfig, int partition, LeaderFollowerPartitionStateModel.LeaderSessionIdChecker leaderSessionIdChecker)
default void	prepareForShutdown()
void	promoteToLeader(VeniceStoreVersionConfig storeConfig, int partition, LeaderFollowerPartitionStateModel.LeaderSessionIdChecker leaderSessionIdChecker)
default void	replaceAndAddTestPushStatusNotifier(VeniceNotifier pushStatusNotifier)

Methods inherited from interface java.io.Closeable

close

Methods inherited from interface com.linkedin.davinci.ingestion.IngestionBackendBase

addIngestionNotifier, dropStoragePartitionGracefully, dropStoragePartitionGracefully, getLoadedStoreUserPartitionsMapping, getStoreIngestionService, killConsumptionTask, shutdownIngestionTask, startConsumption, startConsumption, stopConsumption

Method Detail

promoteToLeader

void promoteToLeader(VeniceStoreVersionConfig storeConfig,
                     int partition,
                     LeaderFollowerPartitionStateModel.LeaderSessionIdChecker leaderSessionIdChecker)

demoteToStandby

void demoteToStandby(VeniceStoreVersionConfig storeConfig,
                     int partition,
                     LeaderFollowerPartitionStateModel.LeaderSessionIdChecker leaderSessionIdChecker)

addPushStatusNotifier

void addPushStatusNotifier(VeniceNotifier pushStatusNotifier)

Adds ingestion listener which reports ingestion status for different push monitors.

replaceAndAddTestPushStatusNotifier

default void replaceAndAddTestPushStatusNotifier(VeniceNotifier pushStatusNotifier)

prepareForShutdown

default void prepareForShutdown()