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 java.lang.Object
implements LingeringStoreVersionChecker

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method	Description
boolean	isStoreVersionLingering(Store store, Version version, Time time, Admin controllerAdmin, java.util.Optional<java.security.cert.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 Detail

HeartbeatBasedLingeringStoreVersionChecker

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

Method Detail

isStoreVersionLingering

public boolean isStoreVersionLingering(Store store,
                                       Version version,
                                       Time time,
                                       Admin controllerAdmin,
                                       java.util.Optional<java.security.cert.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)