Package com.linkedin.venice.pushmonitor

Class WaitAllPushStatusDecider

java.lang.Object

com.linkedin.venice.pushmonitor.PushStatusDecider

com.linkedin.venice.pushmonitor.WaitAllPushStatusDecider

public class WaitAllPushStatusDecider
extends PushStatusDecider

Wait all strategy stands for Venice do not allow one replica to be failed. In case of failure, Venice fail the whole push.

Constructor Summary

Constructors

Constructor	Description
WaitAllPushStatusDecider()

Method Summary

Modifier and Type	Method	Description
protected int	getNumberOfToleratedErrors()
OfflinePushStrategy	getStrategy()
boolean	hasEnoughReplicasForOnePartition(int actual, int expected)

Methods inherited from class com.linkedin.venice.pushmonitor.PushStatusDecider

checkPushStatusAndDetailsByPartitionsStatus, getPartitionStatus, getReadyToServeInstances, getReadyToServeInstances, getReplicaCurrentStatus, hasEnoughNodesToStartPush

Methods inherited from class java.lang.Object

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

Constructor Details

WaitAllPushStatusDecider

public WaitAllPushStatusDecider()

Method Details

getStrategy

public OfflinePushStrategy getStrategy()

Specified by:

getStrategy in class PushStatusDecider

hasEnoughReplicasForOnePartition

public boolean hasEnoughReplicasForOnePartition(int actual,
 int expected)

Specified by:

hasEnoughReplicasForOnePartition in class PushStatusDecider

getNumberOfToleratedErrors

protected int getNumberOfToleratedErrors()

Specified by:

getNumberOfToleratedErrors in class PushStatusDecider