out

Documentation

Index

• func RegFlags()
• type BufferedWriter
  • func (b *BufferedWriter) GetChan() chan *schema.MetricData
  • func (b *BufferedWriter) Loop()
• type Carbon
  • func (c *Carbon) Put(metric *schema.MetricData)
  • func (c *Carbon) Start()
• type Kafka
  • func (k *Kafka) Loop() error
  • func (k *Kafka) Put(metric *schema.MetricData)
  • func (k *Kafka) Start()
• type Multiplexer
  • func (m *Multiplexer) AddOut(out Out)
  • func (m *Multiplexer) Put(metric *schema.MetricData)
  • func (m *Multiplexer) Start()
• type Out
  • func Get(name string, id int) Out
  • func GetMulti(names []string, id int) Out

Functions

func RegFlags

func RegFlags()

Types

type BufferedWriter

type BufferedWriter struct {
	FlushInterval   int
	MetricsPerFlush int
	FlushCB         funFlush
	WriteBufferSize int
	// contains filtered or unexported fields
}

func (*BufferedWriter) GetChan

func (b *BufferedWriter) GetChan() chan *schema.MetricData

func (*BufferedWriter) Loop

func (b *BufferedWriter) Loop()

type Carbon

type Carbon struct {
	Id int
	// contains filtered or unexported fields
}

func (*Carbon) Put

func (c *Carbon) Put(metric *schema.MetricData)

func (*Carbon) Start

func (c *Carbon) Start()

type Kafka

type Kafka struct {
	Id int
	// contains filtered or unexported fields
}

func (*Kafka) Loop

func (k *Kafka) Loop() error

func (*Kafka) Put

func (k *Kafka) Put(metric *schema.MetricData)

func (*Kafka) Start

func (k *Kafka) Start()

type Multiplexer

type Multiplexer struct {
	Id int
	// contains filtered or unexported fields
}

func (*Multiplexer) AddOut

func (m *Multiplexer) AddOut(out Out)

func (*Multiplexer) Put

func (m *Multiplexer) Put(metric *schema.MetricData)

func (*Multiplexer) Start

func (m *Multiplexer) Start()

type Out

type Out interface {
	Start()
	Put(*schema.MetricData)
}

func Get

func Get(name string, id int) Out

func GetMulti

func GetMulti(names []string, id int) Out