input

Documentation

Overview

Package input contains input plugins for collecting metrics and passing them to analysis functions.

TODO: replace sleep with the design in http://talks.golang.org/2013/advconc.slide#1, which would also provide a quit channel.

Index

• type GraphiteFetch
  • func (gf *GraphiteFetch) Init(host string, metric string, initRange string, receivers []chan data.Datapoint) error
  • func (gf *GraphiteFetch) Run() error
• type GraphiteMetric
• type GraphiteResponse

Types

type GraphiteFetch

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

func (*GraphiteFetch) Init

func (gf *GraphiteFetch) Init(host string, metric string, initRange string, receivers []chan data.Datapoint) error

func (*GraphiteFetch) Run

func (gf *GraphiteFetch) Run() error

type GraphiteMetric

type GraphiteMetric struct {
	Target     string           `json:"target"`
	Datapoints [][]*json.Number `json:"datapoints"`
}

type GraphiteResponse

type GraphiteResponse []GraphiteMetric

Structure of graphite-webapp JSON response:

[

{
  "target": "host.metric.a",
  "datapoints": [[<metric> <timestamp>]]
},
{...}

]