Versions in this module Expand all Collapse all v0 v0.2.1 Feb 5, 2020 Changes in this version + const ErrorPrefix + const Fast + const Faster + const InfoPrefix + const Normal + const Slow + const Slower + const WarningPrefix + func CastBucketToBytes(buckets map[string]interface{}, key string) (data []byte, err error) + func GetColoredText(text string, textColor string) string + type Comparator interface + Compare func(c *Context) (fresh bool, err error) + type CompareFunc func(c *Context) (fresh bool, err error) + type Consolidator interface + Consolidate func(c *Context) error + type Context struct + Buckets map[string]interface{} + LastBuckets map[string]interface{} + StartTimestamp time.Time + type Dispatcher struct + func Default() *Dispatcher + func New() *Dispatcher + func (d *Dispatcher) AttachInstance(id InstanceID, instance *Instance) error + func (d *Dispatcher) GetInstance(id InstanceID) *Instance + func (d *Dispatcher) Run() + type FetchFrequency time.Duration + type Fetcher interface + Fetch func(c *Context) error + type Instance struct + LastBuckets map[string]interface{} + func NewInstance(frequency FetchFrequency) *Instance + func (i *Instance) Execute() + func (i *Instance) SetComparator(comparator Comparator) *Instance + func (i *Instance) UseConsolidator(consolidator Consolidator) *Instance + func (i *Instance) UseFetcher(fetcher Fetcher) *Instance + func (i *Instance) UseTranspiler(transpiler Transpiler) *Instance + type InstanceID string + type Logger struct + func (l *Logger) Errorf(format string, v ...interface{}) + func (l *Logger) Errorln(v ...interface{}) + func (l *Logger) Infof(format string, v ...interface{}) + func (l *Logger) Infoln(v ...interface{}) + func (l *Logger) Warnf(format string, v ...interface{}) + func (l *Logger) Warnln(v ...interface{}) + type TranspileFunc func(c *Context) error + type Transpiler interface + Transpile func(c *Context) error