Package com.linkedin.venice.pushmonitor

Class WaitNMinusOnePushStatusDecider

java.lang.Object

com.linkedin.venice.pushmonitor.PushStatusDecider

com.linkedin.venice.pushmonitor.WaitNMinusOnePushStatusDecider

public class WaitNMinusOnePushStatusDecider
extends PushStatusDecider

Wait N-1 strategy stands for Venice could tolerate one of replica to be failed for each partition. Otherwise, once more replica failed, Venice should fail the whole push.

Constructor Summary

Constructors

Constructor	Description
WaitNMinusOnePushStatusDecider()

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

WaitNMinusOnePushStatusDecider

public WaitNMinusOnePushStatusDecider()

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