persister

Apr 5, 2016

Changes in this version

type Whisper

+ func (p *Whisper) GetMaxUpdatesPerSecond() int

+ func (p *Whisper) SetMetricInterval(interval time.Duration)

Apr 23, 2015

Changes in this version

type Whisper

+ func (p *Whisper) SetMaxUpdatesPerSecond(maxUpdatesPerSecond int)

Apr 8, 2015

Changes in this version

+ func ParseRetentionDefs(retentionDefs string) (whisper.Retentions, error)

+ type CreateOpener interface

+ Create func(string, whisper.Retentions, whisper.AggregationMethod, float32) (*whisper.Whisper, error)

+ Open func(string) (*whisper.Whisper, error)

+ type Persister struct

+ Clock clock.Clock

+ Whisper CreateOpener

+ type Whisper struct

+ func NewWhisper(rootPath string, schemas *WhisperSchemas, aggregation *WhisperAggregation, ...) *Whisper

+ func (p *Whisper) SetGraphPrefix(prefix string)

+ func (p *Whisper) SetWorkers(count int)

+ func (p *Whisper) Start()

+ func (p *Whisper) Stat(metric string, value float64)

+ func (p *Whisper) Stop()

+ type WhisperAggregation struct

+ Data []*whisperAggregationItem

+ Default *whisperAggregationItem

+ func NewWhisperAggregation() *WhisperAggregation

+ func ReadWhisperAggregation(file string) (*WhisperAggregation, error)

+ type WhisperFactory struct

+ func (WhisperFactory) Create(path string, retentions whisper.Retentions, ...) (*whisper.Whisper, error)

+ func (WhisperFactory) Open(path string) (*whisper.Whisper, error)

+ type WhisperSchemas struct

+ Data []*whisperSchemaItem

+ func NewWhisperSchemas() *WhisperSchemas

+ func ReadWhisperSchemas(file string) (*WhisperSchemas, error)