carbon

Documentation

Overview

package carbon provides a traditional carbon input for metrictank note: it does not support the "carbon2.0" protocol that serializes metrics2.0 into a plaintext carbon-like protocol

Index

• Variables
• func ConfigProcess()
• func ConfigSetup()
• type Carbon
  • func New() *Carbon
  • func (c *Carbon) ExplainPriority() interface{}
  • func (c *Carbon) IntervalGetter(i IntervalGetter)
  • func (c *Carbon) MaintainPriority()
  • func (c *Carbon) Name() string
  • func (c *Carbon) Start(handler input.Handler, cancel context.CancelFunc) error
  • func (c *Carbon) Stop()
• type ConnTrack
  • func NewConnTrack() *ConnTrack
  • func (c *ConnTrack) Add(conn net.Conn)
  • func (c *ConnTrack) CloseAll()
  • func (c *ConnTrack) Remove(conn net.Conn)
• type IndexIntervalGetter
  • func (i IndexIntervalGetter) GetInterval(name string) int
• type IntervalGetter
  • func NewIndexIntervalGetter(idx idx.MetricIndex) IntervalGetter

Variables

var Enabled bool

Functions

func ConfigProcess

func ConfigProcess()

func ConfigSetup

func ConfigSetup()

Types

type Carbon

type Carbon struct {
	input.Handler
	// contains filtered or unexported fields
}

func New

func New() *Carbon

func (*Carbon) ExplainPriority

func (c *Carbon) ExplainPriority() interface{}

func (*Carbon) IntervalGetter

func (c *Carbon) IntervalGetter(i IntervalGetter)

func (*Carbon) MaintainPriority

func (c *Carbon) MaintainPriority()

MaintainPriority is very simplistic for carbon. there is no backfill, so mark as ready immediately.

func (*Carbon) Name

func (c *Carbon) Name() string

func (*Carbon) Start

func (c *Carbon) Start(handler input.Handler, cancel context.CancelFunc) error

func (*Carbon) Stop

func (c *Carbon) Stop()

type ConnTrack

type ConnTrack struct {
	sync.Mutex
	// contains filtered or unexported fields
}

func NewConnTrack

func NewConnTrack() *ConnTrack

func (*ConnTrack) Add

func (c *ConnTrack) Add(conn net.Conn)

func (*ConnTrack) CloseAll

func (c *ConnTrack) CloseAll()

func (*ConnTrack) Remove

func (c *ConnTrack) Remove(conn net.Conn)

type IndexIntervalGetter

type IndexIntervalGetter struct {
	// contains filtered or unexported fields
}

func (IndexIntervalGetter) GetInterval

func (i IndexIntervalGetter) GetInterval(name string) int

type IntervalGetter

type IntervalGetter interface {
	GetInterval(name string) int
}

IntervalGetter is anything that can return the interval for the given path we don't want the carbon plugin to directly talk to an index because the api surface is too big and it would couple too tightly which is annoying in unit tests

func NewIndexIntervalGetter

func NewIndexIntervalGetter(idx idx.MetricIndex) IntervalGetter