Documentation ¶
Index ¶
- func ParseRetentionDefs(retentionDefs string) (whisper.Retentions, error)
- type Whisper
- func (p *Whisper) GetMaxUpdatesPerSecond() int
- func (p *Whisper) SetGraphPrefix(prefix string)
- func (p *Whisper) SetMaxUpdatesPerSecond(maxUpdatesPerSecond int)
- func (p *Whisper) SetMetricInterval(interval time.Duration)
- func (p *Whisper) SetWorkers(count int)
- func (p *Whisper) Start() error
- func (p *Whisper) Stat(metric string, value float64)
- type WhisperAggregation
- type WhisperSchemas
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func ParseRetentionDefs ¶
ParseRetentionDefs copy of original ParseRetentionDefs from go-whisper With support where old format:
secondsPerPoint:numberOfPoints
Types ¶
type Whisper ¶
Whisper write data to *.wsp files
func NewWhisper ¶
func NewWhisper(rootPath string, schemas *WhisperSchemas, aggregation *WhisperAggregation, in chan *points.Points, confirm chan *points.Points) *Whisper
NewWhisper create instance of Whisper
func (*Whisper) GetMaxUpdatesPerSecond ¶ added in v0.7.1
GetMaxUpdatesPerSecond returns current throttling speed
func (*Whisper) SetGraphPrefix ¶
SetGraphPrefix for internal cache metrics
func (*Whisper) SetMaxUpdatesPerSecond ¶ added in v0.4.3
SetMaxUpdatesPerSecond enable throttling
func (*Whisper) SetMetricInterval ¶ added in v0.7.1
SetMetricInterval sets doChekpoint interval
type WhisperAggregation ¶
type WhisperAggregation struct { Data []*whisperAggregationItem Default *whisperAggregationItem }
WhisperAggregation ...
func NewWhisperAggregation ¶
func NewWhisperAggregation() *WhisperAggregation
NewWhisperAggregation create instance of WhisperAggregation
func ReadWhisperAggregation ¶
func ReadWhisperAggregation(file string) (*WhisperAggregation, error)
ReadWhisperAggregation ...
type WhisperSchemas ¶
type WhisperSchemas struct {
Data []*whisperSchemaItem
}
WhisperSchemas ...
func NewWhisperSchemas ¶
func NewWhisperSchemas() *WhisperSchemas
NewWhisperSchemas create instance of WhisperSchemas
func ReadWhisperSchemas ¶
func ReadWhisperSchemas(file string) (*WhisperSchemas, error)
ReadWhisperSchemas ...
Click to show internal directories.
Click to hide internal directories.