Class PhiAccrual

java.lang.Object
pt.unl.fct.di.novasys.channel.accrual.PhiAccrual

public class PhiAccrual extends Object
Based on the akka implementation of the Phi Accrual Failure Detector: https://github.com/akka/akka/blob/main/akka-remote/src/main/scala/akka/remote/PhiAccrualFailureDetector.scala
  • Constructor Details

    • PhiAccrual

      public PhiAccrual(int windowSize, double threshold, int minStdDeviationMs, int acceptableHbPauseMs, int firstHbEstimateMs)
  • Method Details

    • receivedHb

      public void receivedHb(long hbCounter)
    • isAvailable

      public boolean isAvailable(long timestamp)
    • phi

      public Map<String,Double> phi(long timestamp)