Package com.linkedin.venice.controllerapi

Class AdminCommandExecution

java.lang.Object

com.linkedin.venice.controllerapi.AdminCommandExecution

public class AdminCommandExecution
extends java.lang.Object

The execution object is a kind of context for a admin command including essential information used to track the status of this command.

Constructor Summary

Constructors

Constructor	Description
AdminCommandExecution()	CTOR used by JSON serializer.
AdminCommandExecution(long executionId, java.lang.String operation, java.lang.String clusterName, java.util.Collection<java.lang.String> fabrics)

Method Summary

Modifier and Type	Method	Description
void	checkAndUpdateStatusForRemoteFabric(java.lang.String fabric, ControllerClient controllerClient)
java.lang.String	getClusterName()
long	getExecutionId()
java.util.concurrent.ConcurrentMap<java.lang.String,AdminCommandExecutionStatus>	getFabricToExecutionStatusMap()
java.lang.String	getOperation()
java.lang.String	getStartTime()
boolean	isSucceedInAllFabric()
void	setClusterName(java.lang.String clusterName)
void	setExecutionId(long executionId)
void	setFabricToExecutionStatusMap(java.util.concurrent.ConcurrentMap<java.lang.String,AdminCommandExecutionStatus> fabricToExecutionStatusMap)
void	setOperation(java.lang.String operation)
void	setStartTime(java.lang.String startTime)
java.lang.String	toString()
void	updateCommandStatusForFabric(java.lang.String fabric, AdminCommandExecutionStatus status)

Methods inherited from class java.lang.Object

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

Constructor Detail

AdminCommandExecution

public AdminCommandExecution()

CTOR used by JSON serializer.

AdminCommandExecution

public AdminCommandExecution(long executionId,
                             java.lang.String operation,
                             java.lang.String clusterName,
                             java.util.Collection<java.lang.String> fabrics)

Method Detail

isSucceedInAllFabric

public boolean isSucceedInAllFabric()

checkAndUpdateStatusForRemoteFabric

public void checkAndUpdateStatusForRemoteFabric(java.lang.String fabric,
                                                ControllerClient controllerClient)

updateCommandStatusForFabric

public void updateCommandStatusForFabric(java.lang.String fabric,
                                         AdminCommandExecutionStatus status)

getExecutionId

public long getExecutionId()

setExecutionId

public void setExecutionId(long executionId)

getOperation

public java.lang.String getOperation()

setOperation

public void setOperation(java.lang.String operation)

getClusterName

public java.lang.String getClusterName()

setClusterName

public void setClusterName(java.lang.String clusterName)

getStartTime

public java.lang.String getStartTime()

setStartTime

public void setStartTime(java.lang.String startTime)

getFabricToExecutionStatusMap

public java.util.concurrent.ConcurrentMap<java.lang.String,AdminCommandExecutionStatus> getFabricToExecutionStatusMap()

setFabricToExecutionStatusMap

public void setFabricToExecutionStatusMap(java.util.concurrent.ConcurrentMap<java.lang.String,AdminCommandExecutionStatus> fabricToExecutionStatusMap)

toString

public java.lang.String toString()

Overrides:

toString in class java.lang.Object