Package com.linkedin.venice.controller.init

Class ClusterLeaderInitializationManager

java.lang.Object

com.linkedin.venice.controller.init.ClusterLeaderInitializationManager

All Implemented Interfaces:

ClusterLeaderInitializationRoutine

public class ClusterLeaderInitializationManager
extends Object
implements ClusterLeaderInitializationRoutine

Takes care of executing each routine once per cluster. If a routine fails, it will have another chance of executing next time the same controller becomes leader of the cluster for which the routine previously failed.

Constructor Summary

Constructors

Constructor	Description
ClusterLeaderInitializationManager(List<ClusterLeaderInitializationRoutine> initRoutines, boolean concurrentInit)

Method Summary

Modifier and Type	Method	Description
void	execute(String clusterToInit)

Methods inherited from class java.lang.Object

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

Constructor Details

ClusterLeaderInitializationManager

public ClusterLeaderInitializationManager(List<ClusterLeaderInitializationRoutine> initRoutines,
 boolean concurrentInit)

Method Details

execute

public void execute(String clusterToInit)

Specified by:

execute in interface ClusterLeaderInitializationRoutine

See Also:

• ClusterLeaderInitializationRoutine.execute(String)