Package com.linkedin.venice.heartbeat

Class NoOpPushJobHeartbeatSender

java.lang.Object

com.linkedin.venice.heartbeat.NoOpPushJobHeartbeatSender

All Implemented Interfaces:

PushJobHeartbeatSender, Runnable

public class NoOpPushJobHeartbeatSender
extends Object
implements PushJobHeartbeatSender

Constructor Summary

Constructors

Constructor	Description
NoOpPushJobHeartbeatSender()

Method Summary

Modifier and Type	Method	Description
Optional<Exception>	getFirstSendHeartbeatException()	Get first exception encountered while it is sending heartbeats.
Duration	getHeartbeatInitialDelay()
Duration	getHeartbeatSendInterval()
void	run()
void	start(String storeName, int storeVersion)
void	stop()

Methods inherited from class java.lang.Object

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

Constructor Details

NoOpPushJobHeartbeatSender

public NoOpPushJobHeartbeatSender()

Method Details

getHeartbeatSendInterval

public Duration getHeartbeatSendInterval()

Specified by:

getHeartbeatSendInterval in interface PushJobHeartbeatSender

getHeartbeatInitialDelay

public Duration getHeartbeatInitialDelay()

Specified by:

getHeartbeatInitialDelay in interface PushJobHeartbeatSender

start

public void start(@Nonnull
 String storeName,
 int storeVersion)

Specified by:

start in interface PushJobHeartbeatSender

stop

public void stop()

Specified by:

stop in interface PushJobHeartbeatSender

run

public void run()

Specified by:

run in interface Runnable

getFirstSendHeartbeatException

public Optional<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 interface PushJobHeartbeatSender

Returns:

Empty optional if no exception