carbonserver

Sep 6, 2017

Changes in this version

type CarbonserverListener

+ func (listener *CarbonserverListener) SetInternalStatsDir(dbPath string)

+ func (listener *CarbonserverListener) SetPercentiles(percentiles []int)

+ func (listener *CarbonserverListener) UpdateMetricsAccessTimesByRequest(metrics []string)

Jun 14, 2017

Changes in this version

+ const DataIsAvailable

+ const QueryIsPending

+ var TraceHeaders = map[string]string

+ func TraceContextToZap(ctx context.Context, logger *zap.Logger) *zap.Logger

+ func TraceHandler(h http.HandlerFunc) http.HandlerFunc

type CarbonserverListener

+ func (listener *CarbonserverListener) SetFindCacheEnabled(enabled bool)

+ func (listener *CarbonserverListener) SetGraphiteWeb10(enabled bool)

+ func (listener *CarbonserverListener) SetIdleTimeout(idleTimeout time.Duration)

+ func (listener *CarbonserverListener) SetQueryCacheEnabled(enabled bool)

+ func (listener *CarbonserverListener) SetQueryCacheSizeMB(size int)

+ func (listener *CarbonserverListener) SetTrigramIndex(enabled bool)

+ func (listener *CarbonserverListener) UpdateMetricsAccessTimes(metrics []string)

+ type QueryItem struct

+ Data atomic.Value

+ Flags uint64

+ QueryFinished chan struct{}

+ func (q *QueryItem) FetchOrLock() (interface{}, bool)

+ func (q *QueryItem) StoreAbort()

+ func (q *QueryItem) StoreAndUnlock(data interface{})

Jan 10, 2017

Changes in this version

+ type CarbonserverListener struct

+ func NewCarbonserverListener(cacheGetFunc func(key string) []points.Point) *CarbonserverListener

+ func (listener *CarbonserverListener) CurrentFileIndex() *fileIndex

+ func (listener *CarbonserverListener) Listen(listen string) error

+ func (listener *CarbonserverListener) SetBuckets(buckets int)

+ func (listener *CarbonserverListener) SetMaxGlobs(maxGlobs int)

+ func (listener *CarbonserverListener) SetMetricsAsCounters(metricsAsCounters bool)

+ func (listener *CarbonserverListener) SetReadTimeout(readTimeout time.Duration)

+ func (listener *CarbonserverListener) SetScanFrequency(scanFrequency time.Duration)

+ func (listener *CarbonserverListener) SetWhisperData(whisperData string)

+ func (listener *CarbonserverListener) SetWriteTimeout(writeTimeout time.Duration)

+ func (listener *CarbonserverListener) Stat(send helper.StatCallback)

+ func (listener *CarbonserverListener) Stop() error

+ func (listener *CarbonserverListener) UpdateFileIndex(fidx *fileIndex)

+ type IntervalSet struct

+ End int32

+ Start int32

+ func (i *IntervalSet) MarshalPickle() ([]byte, error)