window

type AddSampleFunc ¶

type AddSampleFunc func(current, new interface{}) interface{}

type AggregateBlocksFunc ¶

type AggregateBlocksFunc func(block []interface{}, start int, size int) interface{}

type AggregateSingleFunc ¶

type AggregateSingleFunc func(value interface{}, count int) interface{}

type BlockInfo ¶

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

type BlockMapData ¶

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

type DataInfo ¶

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

type MapData ¶

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

type Settings ¶

type Settings struct {
	Size          int
	Resolution    int
	ExternalTimer bool

	TotalCountModifier int

	NameKey  string
	ValueKey string
}

func (s *Settings) SetAdditionalSettings(as map[string]string) error

type SlidingTimeWindow ¶

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

SlidingTimeWindow - A sliding window based on time. Relies on external entity moving window along by calling NextBlock at the appropriate time. note: using interface{} 4x slower than using specific types, starting with interface{} for expediency

func (w *SlidingTimeWindow) AddSample(sample interface{}) (bool, interface{})

func (w *SlidingTimeWindow) NextBlock() (bool, interface{})

type SlidingWindow ¶

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

note: using interface{} 4x slower than using specific types, starting with interface{} for expediency todo split external vs on-add timer

func (w *SlidingWindow) AddSample(sample interface{}) (bool, interface{})

type TimeWindow ¶

type TimeWindow interface {
	Window

	// NextBlock tells the time window to advance
	NextBlock() (bool, interface{})
}

TimeWindow a time based sample window

func NewSlidingTimeWindow(addFunc AddSampleFunc, aggFunc AggregateBlocksFunc, settings *Settings) TimeWindow

func NewTumblingTimeWindow(addFunc AddSampleFunc, aggFunc AggregateSingleFunc, settings *Settings) TimeWindow

type TumblingTimeWindow ¶

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

TumblingTimeWindow - A tumbling window based on time. Relies on external entity moving window along by calling NextBlock at the appropriate time. note: using interface{} 4x slower than using specific types, starting with interface{} for expediency

func (w *TumblingTimeWindow) AddSample(sample interface{}) (bool, interface{})

func (w *TumblingTimeWindow) NextBlock() (bool, interface{})

type TumblingWindow ¶

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

note: using interface{} 4x slower than using specific types, starting with interface{} for expediency

func (w *TumblingWindow) AddSample(sample interface{}) (bool, interface{})

type Window ¶

type Window interface {
	// AddSample adds a sample to the window
	AddSample(sample interface{}) (bool, interface{})
}

Window is a basic sample window

func NewSlidingWindow(aggFunc AggregateBlocksFunc, settings *Settings) Window

func NewTumblingWindow(addFunc AddSampleFunc, aggFunc AggregateSingleFunc, settings *Settings) Window