carbonserver

Documentation

Index

• Constants
• Variables
• func TraceContextToZap(ctx context.Context, logger *zap.Logger) *zap.Logger
• func TraceHandler(h http.HandlerFunc) http.HandlerFunc
• type CarbonserverListener
  • 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) SetFindCacheEnabled(enabled bool)
  • func (listener *CarbonserverListener) SetGraphiteWeb10(enabled bool)
  • func (listener *CarbonserverListener) SetIdleTimeout(idleTimeout time.Duration)
  • func (listener *CarbonserverListener) SetMaxGlobs(maxGlobs int)
  • func (listener *CarbonserverListener) SetMetricsAsCounters(metricsAsCounters bool)
  • func (listener *CarbonserverListener) SetQueryCacheEnabled(enabled bool)
  • func (listener *CarbonserverListener) SetQueryCacheSizeMB(size int)
  • func (listener *CarbonserverListener) SetReadTimeout(readTimeout time.Duration)
  • func (listener *CarbonserverListener) SetScanFrequency(scanFrequency time.Duration)
  • func (listener *CarbonserverListener) SetTrigramIndex(enabled bool)
  • 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)
  • func (listener *CarbonserverListener) UpdateMetricsAccessTimes(metrics []string)
• type IntervalSet
  • func (i *IntervalSet) MarshalPickle() ([]byte, error)
• type QueryItem
  • func (q *QueryItem) FetchOrLock() (interface{}, bool)
  • func (q *QueryItem) StoreAbort()
  • func (q *QueryItem) StoreAndUnlock(data interface{})

Constants

const (
	QueryIsPending uint64 = 1 << iota
	DataIsAvailable
)

Variables

var TraceHeaders = map[string]string{
	"X-CTX-CarbonAPI-UUID":    "carbonapi_uuid",
	"X-CTX-CarbonZipper-UUID": "carbonzipper_uuid",
	"X-Request-ID":            "request_id",
}

Functions

func TraceContextToZap

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

func TraceHandler

func TraceHandler(h http.HandlerFunc) http.HandlerFunc

Types

type CarbonserverListener

type CarbonserverListener struct {
	helper.Stoppable
	// contains filtered or unexported fields
}

func NewCarbonserverListener

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

func (*CarbonserverListener) CurrentFileIndex

func (listener *CarbonserverListener) CurrentFileIndex() *fileIndex

func (*CarbonserverListener) Listen

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

func (*CarbonserverListener) SetBuckets

func (listener *CarbonserverListener) SetBuckets(buckets int)

func (*CarbonserverListener) SetFindCacheEnabled

func (listener *CarbonserverListener) SetFindCacheEnabled(enabled bool)

func (*CarbonserverListener) SetGraphiteWeb10

func (listener *CarbonserverListener) SetGraphiteWeb10(enabled bool)

func (*CarbonserverListener) SetIdleTimeout

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

func (*CarbonserverListener) SetMaxGlobs

func (listener *CarbonserverListener) SetMaxGlobs(maxGlobs int)

func (*CarbonserverListener) SetMetricsAsCounters

func (listener *CarbonserverListener) SetMetricsAsCounters(metricsAsCounters bool)

func (*CarbonserverListener) SetQueryCacheEnabled

func (listener *CarbonserverListener) SetQueryCacheEnabled(enabled bool)

func (*CarbonserverListener) SetQueryCacheSizeMB

func (listener *CarbonserverListener) SetQueryCacheSizeMB(size int)

func (*CarbonserverListener) SetReadTimeout

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

func (*CarbonserverListener) SetScanFrequency

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

func (*CarbonserverListener) SetTrigramIndex

func (listener *CarbonserverListener) SetTrigramIndex(enabled bool)

func (*CarbonserverListener) SetWhisperData

func (listener *CarbonserverListener) SetWhisperData(whisperData string)

func (*CarbonserverListener) SetWriteTimeout

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

func (*CarbonserverListener) Stat

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

func (*CarbonserverListener) Stop

func (listener *CarbonserverListener) Stop() error

func (*CarbonserverListener) UpdateFileIndex

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

func (*CarbonserverListener) UpdateMetricsAccessTimes

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

type IntervalSet

type IntervalSet struct {
	Start int32
	End   int32
}

Fake single interval set for graphite

func (*IntervalSet) MarshalPickle

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

type QueryItem

type QueryItem struct {
	Data          atomic.Value
	Flags         uint64 // DataIsAvailable or QueryIsPending
	QueryFinished chan struct{}
}

func (*QueryItem) FetchOrLock

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

func (*QueryItem) StoreAbort

func (q *QueryItem) StoreAbort()

func (*QueryItem) StoreAndUnlock

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