persister

Jun 17, 2016

Changes in this version

+ type Schema struct

+ Name string

+ Pattern *regexp.Regexp

+ Priority int64

+ RetentionStr string

+ Retentions whisper.Retentions

type Whisper

+ func (p *Whisper) SetSparse(sparse bool)

type WhisperSchemas

+ func (s WhisperSchemas) Len() int

+ func (s WhisperSchemas) Less(i, j int) bool

+ func (s WhisperSchemas) Match(metric string) (Schema, bool)

+ func (s WhisperSchemas) Swap(i, j int)

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)