Package com.linkedin.venice.heartbeat
Class NoOpPushJobHeartbeatSender
- java.lang.Object
-
- com.linkedin.venice.heartbeat.NoOpPushJobHeartbeatSender
-
- All Implemented Interfaces:
PushJobHeartbeatSender,java.lang.Runnable
public class NoOpPushJobHeartbeatSender extends java.lang.Object implements PushJobHeartbeatSender
-
-
Constructor Summary
Constructors Constructor Description NoOpPushJobHeartbeatSender()
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description java.util.Optional<java.lang.Exception>getFirstSendHeartbeatException()Get first exception encountered while it is sending heartbeats.java.time.DurationgetHeartbeatInitialDelay()java.time.DurationgetHeartbeatSendInterval()voidrun()voidstart(java.lang.String storeName, int storeVersion)voidstop()
-
-
-
Method Detail
-
getHeartbeatSendInterval
public java.time.Duration getHeartbeatSendInterval()
- Specified by:
getHeartbeatSendIntervalin interfacePushJobHeartbeatSender
-
getHeartbeatInitialDelay
public java.time.Duration getHeartbeatInitialDelay()
- Specified by:
getHeartbeatInitialDelayin interfacePushJobHeartbeatSender
-
start
public void start(@Nonnull java.lang.String storeName, int storeVersion)- Specified by:
startin interfacePushJobHeartbeatSender
-
stop
public void stop()
- Specified by:
stopin interfacePushJobHeartbeatSender
-
run
public void run()
- Specified by:
runin interfacejava.lang.Runnable
-
getFirstSendHeartbeatException
public java.util.Optional<java.lang.Exception> getFirstSendHeartbeatException()
Description copied from interface:PushJobHeartbeatSenderGet first exception encountered while it is sending heartbeats. If there are multiple exceptions encountered during the process of sending heartbeats, only the first one is recorded and returned here.- Specified by:
getFirstSendHeartbeatExceptionin interfacePushJobHeartbeatSender- Returns:
- Empty optional if no exception
-
-