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.Duration
getHeartbeatInitialDelay()
java.time.Duration
getHeartbeatSendInterval()
void
run()
void
start(java.lang.String storeName, int storeVersion)
void
stop()
-
-
-
Method Detail
-
getHeartbeatSendInterval
public java.time.Duration getHeartbeatSendInterval()
- Specified by:
getHeartbeatSendInterval
in interfacePushJobHeartbeatSender
-
getHeartbeatInitialDelay
public java.time.Duration getHeartbeatInitialDelay()
- Specified by:
getHeartbeatInitialDelay
in interfacePushJobHeartbeatSender
-
start
public void start(@Nonnull java.lang.String storeName, int storeVersion)
- Specified by:
start
in interfacePushJobHeartbeatSender
-
stop
public void stop()
- Specified by:
stop
in interfacePushJobHeartbeatSender
-
run
public void run()
- Specified by:
run
in interfacejava.lang.Runnable
-
getFirstSendHeartbeatException
public java.util.Optional<java.lang.Exception> getFirstSendHeartbeatException()
Description copied from interface:PushJobHeartbeatSender
Get 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:
getFirstSendHeartbeatException
in interfacePushJobHeartbeatSender
- Returns:
- Empty optional if no exception
-
-