Package com.linkedin.venice.controller

Class VeniceVersionLifecycleEventManager

java.lang.Object

com.linkedin.venice.controller.VeniceVersionLifecycleEventManager

public class VeniceVersionLifecycleEventManager
extends Object

Event manager for VeniceVersionLifecycleEventListener. To start and to keep it simple we are only passing the read-only version to the listeners along with the isSourceCluster flag to indicate if the event is from the source cluster or not. This is useful for certain listeners that only care about the source cluster events during a store migration. If needed we can also pass along the corresponding HelixVeniceClusterResources to the listeners for more complex use cases.

Constructor Summary

Constructors

Constructor	Description
VeniceVersionLifecycleEventManager()

Method Summary

Modifier and Type	Method	Description
void	addListener(VeniceVersionLifecycleEventListener listener)
static void	onCurrentVersionChanged(VeniceVersionLifecycleEventManager manager, String clusterName, Store store, int newCurrentVersion, int previousCurrentVersion, boolean isFutureVersion, boolean isMigrating, BiFunction<String,String,Boolean> isSourceClusterFn)

Methods inherited from class java.lang.Object

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

Constructor Details

VeniceVersionLifecycleEventManager

public VeniceVersionLifecycleEventManager()

Method Details

onCurrentVersionChanged

public static void onCurrentVersionChanged(VeniceVersionLifecycleEventManager manager,
 String clusterName,
 Store store,
 int newCurrentVersion,
 int previousCurrentVersion,
 boolean isFutureVersion,
 boolean isMigrating,
 BiFunction<String,String,Boolean> isSourceClusterFn)

addListener

public void addListener(VeniceVersionLifecycleEventListener listener)