detector

Documentation

Index

• type DeviationDetector
  • func NewDeviationDetector[T any](expectedValue T, tolerance float64, duration time.Duration, ...) *DeviationDetector[T]
  • func (d *DeviationDetector[T]) AddRecord(at time.Time, value T) (bool, time.Duration)
  • func (d *DeviationDetector[T]) ClearRecords()
  • func (d *DeviationDetector[T]) GetRecords() []Record[T]
  • func (d *DeviationDetector[T]) SetLogger(logger logrus.FieldLogger)
  • func (d *DeviationDetector[T]) ShouldFix() (bool, time.Duration)
• type Record

Types

type DeviationDetector

type DeviationDetector[T any] struct {
	// contains filtered or unexported fields
}

func NewDeviationDetector

func NewDeviationDetector[T any](
	expectedValue T, tolerance float64, duration time.Duration, toFloat64 func(T) float64,
) *DeviationDetector[T]

NewDeviationDetector creates a new instance of DeviationDetector

func (*DeviationDetector[T]) AddRecord

func (d *DeviationDetector[T]) AddRecord(at time.Time, value T) (bool, time.Duration)

func (*DeviationDetector[T]) ClearRecords

func (d *DeviationDetector[T]) ClearRecords()

ClearRecords clears all deviation records

func (*DeviationDetector[T]) GetRecords

func (d *DeviationDetector[T]) GetRecords() []Record[T]

GetRecords retrieves all deviation records

func (*DeviationDetector[T]) SetLogger

func (d *DeviationDetector[T]) SetLogger(logger logrus.FieldLogger)

func (*DeviationDetector[T]) ShouldFix

func (d *DeviationDetector[T]) ShouldFix() (bool, time.Duration)

type Record

type Record[T any] struct {
	Value T
	Time  time.Time
}