carbonserver

Documentation

Index

• 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) 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
  • func (i *IntervalSet) MarshalPickle() ([]byte, error)

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) SetMaxGlobs

func (listener *CarbonserverListener) SetMaxGlobs(maxGlobs int)

func (*CarbonserverListener) SetMetricsAsCounters

func (listener *CarbonserverListener) SetMetricsAsCounters(metricsAsCounters bool)

func (*CarbonserverListener) SetReadTimeout

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

func (*CarbonserverListener) SetScanFrequency

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

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)

type IntervalSet

type IntervalSet struct {
	Start int32
	End   int32
}

Fake single interval set for graphite

func (*IntervalSet) MarshalPickle

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