sampler-fork/data/sampler.go

38 lines
553 B
Go
Raw Normal View History

2019-01-31 00:02:38 +00:00
package data
import (
"time"
)
2019-02-03 04:11:26 +00:00
type Sampler struct {
2019-01-31 00:02:38 +00:00
consumer Consumer
2019-01-31 23:40:05 +00:00
item Item
2019-01-31 00:02:38 +00:00
}
2019-02-03 04:11:26 +00:00
func NewSampler(consumer Consumer, item Item, rateMs int) Sampler {
2019-01-31 00:02:38 +00:00
2019-02-03 04:11:26 +00:00
sampler := Sampler{consumer, item}
2019-01-31 00:02:38 +00:00
go func() {
for t := time.Tick(time.Duration(rateMs * int(time.Millisecond))); ; <-t {
sampler.sample()
2019-01-31 00:02:38 +00:00
}
}()
2019-02-03 04:11:26 +00:00
return sampler
2019-01-31 00:02:38 +00:00
}
2019-02-03 04:11:26 +00:00
func (self *Sampler) sample() {
2019-01-31 00:02:38 +00:00
2019-01-31 23:40:05 +00:00
value, err := self.item.nextValue()
2019-01-31 00:02:38 +00:00
2019-02-03 03:30:45 +00:00
sample := Sample{
Value: value,
Error: err,
Color: self.item.Color,
Label: self.item.Label,
2019-01-31 00:02:38 +00:00
}
2019-02-03 03:30:45 +00:00
self.consumer.ConsumeSample(sample)
2019-01-31 00:02:38 +00:00
}