trend_prediction

Documentation

Index

• Constants
• type AlertFunc
• type AlertSubscribe
  • func (s *AlertSubscribe) Inhibition()
  • func (s *AlertSubscribe) Recover()
  • func (s *AlertSubscribe) Silence()
• type DataSource
• type Option
  • func WithCheckAverage(target int) Option
  • func WithCheckDescending() Option
  • func WithCheckIncreasing() Option
  • func WithOnlyUseEscape() Option
  • func WithOnlyUseLength() Option
  • func WithThreshold(threshold int) Option
  • func WithWindowLength(length int) Option
  • func WithWindowTimeEscape(escape int) Option
• type TrendPrediction
  • func NewTrendPrediction(source *DataSource, opts ...Option) *TrendPrediction
  • func (t *TrendPrediction) RegisterSubscribe(sub *AlertSubscribe)
  • func (t *TrendPrediction) Watching()

Constants

const (
	DefaultWindowLength       = 3
	DefaultWindowEscapeLength = 60
)

Types

type AlertFunc

type AlertFunc func(...interface{})

type AlertSubscribe

type AlertSubscribe struct {
	AlertFunc AlertFunc
	// contains filtered or unexported fields
}

func (*AlertSubscribe) Inhibition

func (s *AlertSubscribe) Inhibition()

func (*AlertSubscribe) Recover

func (s *AlertSubscribe) Recover()

func (*AlertSubscribe) Silence

func (s *AlertSubscribe) Silence()

type DataSource

type DataSource struct {
	Source  chan interface{}
	KeyName string
}

type Option

type Option func(o *option)

func WithCheckAverage

func WithCheckAverage(target int) Option

func WithCheckDescending

func WithCheckDescending() Option

func WithCheckIncreasing

func WithCheckIncreasing() Option

func WithOnlyUseEscape

func WithOnlyUseEscape() Option

func WithOnlyUseLength

func WithOnlyUseLength() Option

func WithThreshold

func WithThreshold(threshold int) Option

func WithWindowLength

func WithWindowLength(length int) Option

func WithWindowTimeEscape

func WithWindowTimeEscape(escape int) Option

type TrendPrediction

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

func NewTrendPrediction

func NewTrendPrediction(source *DataSource, opts ...Option) *TrendPrediction

func (*TrendPrediction) RegisterSubscribe

func (t *TrendPrediction) RegisterSubscribe(sub *AlertSubscribe)

func (*TrendPrediction) Watching

func (t *TrendPrediction) Watching()