Package com.linkedin.venice.controller.lingeringjob

Class HeartbeatBasedLingeringStoreVersionChecker

java.lang.Object

com.linkedin.venice.controller.lingeringjob.HeartbeatBasedLingeringStoreVersionChecker

All Implemented Interfaces:

LingeringStoreVersionChecker

public class HeartbeatBasedLingeringStoreVersionChecker
extends Object
implements LingeringStoreVersionChecker

Constructor Summary

Constructors

Constructor	Description
HeartbeatBasedLingeringStoreVersionChecker(Duration heartbeatTimeout, Duration initialHeartbeatBufferTime, DefaultLingeringStoreVersionChecker defaultLingeringStoreVersionChecker, HeartbeatBasedCheckerStats heartbeatBasedCheckerStats)

Method Summary

Modifier and Type	Method	Description
boolean	isStoreVersionLingering(Store store, Version version, Time time, Admin controllerAdmin, Optional<X509Certificate> requesterCert, IdentityParser identityParser)	Check if a version has been lingering around

Methods inherited from class java.lang.Object

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

Constructor Details

HeartbeatBasedLingeringStoreVersionChecker

public HeartbeatBasedLingeringStoreVersionChecker(@Nonnull
 Duration heartbeatTimeout,
 @Nonnull
 Duration initialHeartbeatBufferTime,
 @Nonnull
 DefaultLingeringStoreVersionChecker defaultLingeringStoreVersionChecker,
 @Nonnull
 HeartbeatBasedCheckerStats heartbeatBasedCheckerStats)

Method Details

isStoreVersionLingering

public boolean isStoreVersionLingering(Store store,
 Version version,
 Time time,
 Admin controllerAdmin,
 Optional<X509Certificate> requesterCert,
 IdentityParser identityParser)

Description copied from interface: LingeringStoreVersionChecker

Check if a version has been lingering around

Specified by:

isStoreVersionLingering in interface LingeringStoreVersionChecker

Returns:

true if the provided version is has been lingering (so that it can be killed potentially)