phidetector

Documentation

Index

• type Builder
  • func NewBuilder() *Builder
  • func (b *Builder) Build() (*PhiAccrualFailureDetector, error)
  • func (b *Builder) SetAcceptableHeartbeatPauseMillis(acceptableHeartbeatPauseMillis int64) *Builder
  • func (b *Builder) SetFirstHeartbeatEstimateMillis(firstHeartbeatEstimateMillis int64) *Builder
  • func (b *Builder) SetMaxSampleSize(maxSampleSize int) *Builder
  • func (b *Builder) SetMinStdDeviationMillis(minStdDeviationMillis float64) *Builder
  • func (b *Builder) SetThreshold(threshold float64) *Builder
• type HeartbeatHistory
  • func NewHeartbeatHistory(maxSampleSize int) *HeartbeatHistory
  • func (h *HeartbeatHistory) Add(interval int64)
  • func (h *HeartbeatHistory) Mean() float64
  • func (h *HeartbeatHistory) StdDeviation() float64
  • func (h *HeartbeatHistory) Variance() float64
• type PhiAccrualFailureDetector
  • func NewPhiAccrualFailureDetector(threshold float64, maxSampleSize int, minStdDeviationMillis float64, ...) (*PhiAccrualFailureDetector, error)
  • func (p *PhiAccrualFailureDetector) Heartbeat(timestampMillis int64)
  • func (p *PhiAccrualFailureDetector) IsAvailable(timestampMillis int64) bool
  • func (p *PhiAccrualFailureDetector) Phi(timestampMillis int64) float64

Types

type Builder

type Builder struct {
	// contains filtered or unexported fields
}

Builder for PhiAccrualFailureDetector

func NewBuilder

func NewBuilder() *Builder

func (*Builder) Build

func (b *Builder) Build() (*PhiAccrualFailureDetector, error)

func (*Builder) SetAcceptableHeartbeatPauseMillis

func (b *Builder) SetAcceptableHeartbeatPauseMillis(acceptableHeartbeatPauseMillis int64) *Builder

func (*Builder) SetFirstHeartbeatEstimateMillis

func (b *Builder) SetFirstHeartbeatEstimateMillis(firstHeartbeatEstimateMillis int64) *Builder

func (*Builder) SetMaxSampleSize

func (b *Builder) SetMaxSampleSize(maxSampleSize int) *Builder

func (*Builder) SetMinStdDeviationMillis

func (b *Builder) SetMinStdDeviationMillis(minStdDeviationMillis float64) *Builder

func (*Builder) SetThreshold

func (b *Builder) SetThreshold(threshold float64) *Builder

type HeartbeatHistory

type HeartbeatHistory struct {
	// contains filtered or unexported fields
}

HeartbeatHistory represents the history of heartbeats

func NewHeartbeatHistory

func NewHeartbeatHistory(maxSampleSize int) *HeartbeatHistory

func (*HeartbeatHistory) Add

func (h *HeartbeatHistory) Add(interval int64)

func (*HeartbeatHistory) Mean

func (h *HeartbeatHistory) Mean() float64

func (*HeartbeatHistory) StdDeviation

func (h *HeartbeatHistory) StdDeviation() float64

func (*HeartbeatHistory) Variance

func (h *HeartbeatHistory) Variance() float64

type PhiAccrualFailureDetector

type PhiAccrualFailureDetector struct {
	// contains filtered or unexported fields
}

PhiAccrualFailureDetector implements 'The Phi Accrual Failure Detector' by Hayashibara et al.

func NewPhiAccrualFailureDetector

func NewPhiAccrualFailureDetector(threshold float64, maxSampleSize int, minStdDeviationMillis float64,
	acceptableHeartbeatPauseMillis int64, firstHeartbeatEstimateMillis int64) (*PhiAccrualFailureDetector, error)

NewPhiAccrualFailureDetector creates a new PhiAccrualFailureDetector

func (*PhiAccrualFailureDetector) Heartbeat

func (p *PhiAccrualFailureDetector) Heartbeat(timestampMillis int64)

func (*PhiAccrualFailureDetector) IsAvailable

func (p *PhiAccrualFailureDetector) IsAvailable(timestampMillis int64) bool

func (*PhiAccrualFailureDetector) Phi

func (p *PhiAccrualFailureDetector) Phi(timestampMillis int64) float64