Package com.linkedin.venice.controller

Class StoreLifecycleHooksCache

java.lang.Object

com.linkedin.venice.controller.StoreLifecycleHooksCache

public class StoreLifecycleHooksCache
extends Object

Instantiates and caches StoreLifecycleHooks by class name, and dispatches StoreLifecycleHooks.postStoreVersionSwap(java.lang.String, java.lang.String, int, int, java.lang.String, com.linkedin.venice.utils.lazy.Lazy<com.linkedin.venice.controllerapi.JobStatusQueryResponse>, com.linkedin.venice.utils.VeniceProperties) for all hooks registered on a store.

Shared across DeferredVersionSwapService, VeniceHelixAdmin, and AbstractPushMonitor so hook instantiation and invocation logic is not duplicated.

Constructor Summary

Constructors

Constructor	Description
StoreLifecycleHooksCache(VeniceProperties globalProps)

Method Summary

Modifier and Type	Method	Description
StoreLifecycleHooks	getOrInstantiateHook(String className)	Returns a cached (or freshly constructed) StoreLifecycleHooks instance for the given fully-qualified class name.
StoreVersionLifecycleEventOutcome	invokePostVersionSwapHooks(String clusterName, Store store, int versionNumber, int previousVersion, String regionName, Lazy<JobStatusQueryResponse> jobStatus)	Invokes StoreLifecycleHooks.postStoreVersionSwap(java.lang.String, java.lang.String, int, int, java.lang.String, com.linkedin.venice.utils.lazy.Lazy<com.linkedin.venice.controllerapi.JobStatusQueryResponse>, com.linkedin.venice.utils.VeniceProperties) for every hook registered on store.

Methods inherited from class java.lang.Object

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

Constructor Details

StoreLifecycleHooksCache

public StoreLifecycleHooksCache(VeniceProperties globalProps)

Method Details

getOrInstantiateHook

@Nullable
public StoreLifecycleHooks getOrInstantiateHook(String className)

Returns a cached (or freshly constructed) StoreLifecycleHooks instance for the given fully-qualified class name. Returns null and logs a warning if the class cannot be loaded or instantiated.

Null or blank class names return null immediately. The name is trimmed before lookup so whitespace variants do not create separate cache entries.

Failed instantiations are cached in failedClasses so that a bad class name is only attempted once; subsequent calls return null immediately without re-attempting reflection.

invokePostVersionSwapHooks

public StoreVersionLifecycleEventOutcome invokePostVersionSwapHooks(String clusterName,
 Store store,
 int versionNumber,
 int previousVersion,
 String regionName,
 @Nullable
 Lazy<JobStatusQueryResponse> jobStatus)

Invokes StoreLifecycleHooks.postStoreVersionSwap(java.lang.String, java.lang.String, int, int, java.lang.String, com.linkedin.venice.utils.lazy.Lazy<com.linkedin.venice.controllerapi.JobStatusQueryResponse>, com.linkedin.venice.utils.VeniceProperties) for every hook registered on store. Returns StoreVersionLifecycleEventOutcome.ROLLBACK or StoreVersionLifecycleEventOutcome.ABORT immediately if any hook requests it (short-circuit — remaining hooks are not called). Returns StoreVersionLifecycleEventOutcome.WAIT if any hook requested it and none requested rollback/abort. Returns StoreVersionLifecycleEventOutcome.PROCEED otherwise.

Null or malformed LifecycleHooksRecords are skipped. Any exception thrown by a hook is caught, logged, and the hook is skipped without affecting the outcome.