Package com.linkedin.venice.pushmonitor

Class ReplicaStatus

java.lang.Object

com.linkedin.venice.pushmonitor.ReplicaStatus

public class ReplicaStatus
extends java.lang.Object

Class stores replica status and history.

Field Summary

Fields

Modifier and Type	Field	Description
static int	MAX_HISTORY_LENGTH
static long	NO_PROGRESS

Constructor Summary

Constructors

Constructor	Description
ReplicaStatus(java.lang.String instanceId)
ReplicaStatus(java.lang.String instanceId, boolean enableStatusHistory)

Method Summary

Modifier and Type	Method	Description
boolean	equals(java.lang.Object o)
Pair<StatusSnapshot,StatusSnapshot>	findStartedAndCompletedStatus()
long	getCurrentProgress()
ExecutionStatus	getCurrentStatus()
java.lang.String	getIncrementalPushVersion()
java.lang.String	getInstanceId()
static java.lang.String	getInstanceIdFromReplicaId(java.lang.String replicaId)
static java.lang.String	getReplicaId(java.lang.String kafkaTopic, int partition, java.lang.String instanceId)
java.util.List<StatusSnapshot>	getStatusHistory()
int	hashCode()
void	setCurrentProgress(long currentProgress)
void	setCurrentStatus(ExecutionStatus currentStatus)
void	setIncrementalPushVersion(java.lang.String incrementalPushVersion)
void	setStatusHistory(java.util.List<StatusSnapshot> statusHistory)
void	updateStatus(ExecutionStatus newStatus)
void	updateStatus(ExecutionStatus newStatus, java.lang.String incrementalPushVersion)

Methods inherited from class java.lang.Object

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

Field Detail

MAX_HISTORY_LENGTH

public static final int MAX_HISTORY_LENGTH

See Also:

Constant Field Values

NO_PROGRESS

public static final long NO_PROGRESS

See Also:

Constant Field Values

Constructor Detail

ReplicaStatus

public ReplicaStatus(java.lang.String instanceId)

ReplicaStatus

public ReplicaStatus(java.lang.String instanceId,
                     boolean enableStatusHistory)

Method Detail

updateStatus

public void updateStatus(ExecutionStatus newStatus)

updateStatus

public void updateStatus(ExecutionStatus newStatus,
                         java.lang.String incrementalPushVersion)

getInstanceId

public java.lang.String getInstanceId()

getCurrentStatus

public ExecutionStatus getCurrentStatus()

setCurrentStatus

public void setCurrentStatus(ExecutionStatus currentStatus)

getCurrentProgress

public long getCurrentProgress()

setCurrentProgress

public void setCurrentProgress(long currentProgress)

getIncrementalPushVersion

public java.lang.String getIncrementalPushVersion()

setIncrementalPushVersion

public void setIncrementalPushVersion(java.lang.String incrementalPushVersion)

getStatusHistory

public java.util.List<StatusSnapshot> getStatusHistory()

setStatusHistory

public void setStatusHistory(java.util.List<StatusSnapshot> statusHistory)

equals

public boolean equals(java.lang.Object o)

Overrides:

equals in class java.lang.Object

hashCode

public int hashCode()

Overrides:

hashCode in class java.lang.Object

getReplicaId

public static java.lang.String getReplicaId(java.lang.String kafkaTopic,
                                            int partition,
                                            java.lang.String instanceId)

getInstanceIdFromReplicaId

public static java.lang.String getInstanceIdFromReplicaId(java.lang.String replicaId)

findStartedAndCompletedStatus

public Pair<StatusSnapshot,StatusSnapshot> findStartedAndCompletedStatus()

Returns:

the started and completed status snapshot from the status history.