catalyser

Documentation

Index

• Constants
• func GraphiteHTTP(url *url.URL, header *http.Header, r io.Reader, send func([]byte) error, ...) (int, int, error)
• func HandlePing(c echo.Context) error
• func HandleRemoteWrite(url *url.URL, headers *http.Header, r io.Reader, send func([]byte) error, ...) (int, int, error)
• func InfluxDB(url *url.URL, header *http.Header, r io.Reader, send func([]byte) error, ...) (int, int, error)
• func OpenTSDB(url *url.URL, header *http.Header, reader io.Reader, send func([]byte) error, ...) (int, int, error)
• func Prometheus(url *url.URL, headers *http.Header, r io.Reader, send func([]byte) error, ...) (int, int, error)
• func Warp(url *url.URL, header *http.Header, r io.Reader, send func([]byte) error, ...) (int, int, error)
• func WarpError(err error) error
• type Graphite
  • func NewGraphite(listen string, p bool) *Graphite
  • func (g *Graphite) OpenTCPServer()
  • func (g *Graphite) OpenWarp(token string, txn string) (*core.Warp, error)

Constants

const (
	// InfluxDBVersion fixed INfluxDB supported version
	InfluxDBVersion = "1.4.x"
)

Functions

func GraphiteHTTP

func GraphiteHTTP(url *url.URL, header *http.Header, r io.Reader, send func([]byte) error, dpCounter prometheus.Counter) (int, int, error)

GraphiteHTTP returns a Graphite catalyser.

func HandlePing

func HandlePing(c echo.Context) error

HandlePing handle /ping call

func HandleRemoteWrite

func HandleRemoteWrite(url *url.URL, headers *http.Header, r io.Reader, send func([]byte) error, dpCounter prometheus.Counter) (int, int, error)

HandleRemoteWrite support remote_write protocol https://github.com/prometheus/prometheus/tree/0e0fc5a7f45ce28632f43f1ead0183ee82c7afca/documentation/examples/remote_storage/remote_storage_adapter

func InfluxDB

func InfluxDB(url *url.URL, header *http.Header, r io.Reader, send func([]byte) error, dpCounter prometheus.Counter) (int, int, error)

InfluxDB returns an InfluxDB catalyser.

func OpenTSDB

func OpenTSDB(url *url.URL, header *http.Header, reader io.Reader, send func([]byte) error, dpCounter prometheus.Counter) (int, int, error)

OpenTSDB returns an OpenTSDB catalyser.

func Prometheus

func Prometheus(url *url.URL, headers *http.Header, r io.Reader, send func([]byte) error, dpCounter prometheus.Counter) (int, int, error)

Prometheus returns a Prometheus catalyser.

func Warp

func Warp(url *url.URL, header *http.Header, r io.Reader, send func([]byte) error, dpCounter prometheus.Counter) (int, int, error)

Warp returns a Warp catalyser.

func WarpError

func WarpError(err error) error

WarpError handle errors.

Types

type Graphite

type Graphite struct {
	Listen string
	Parse  bool

	ReqTCPCounter       prometheus.Counter
	ReqTCPOKCounter     prometheus.Counter
	ReqTCPErrorCounter  prometheus.Counter
	ReqTCPNoAuthCounter prometheus.Counter
	ReqTCPdp            prometheus.Counter
	ReqTimes            prometheus.Counter
}

Graphite is a Graphite socket who parse to sensision format

func NewGraphite

func NewGraphite(listen string, p bool) *Graphite

NewGraphite return a new Graphite initialized with his output chan

func (*Graphite) OpenTCPServer

func (g *Graphite) OpenTCPServer()

OpenTCPServer opens the Graphite TCP input format and starts processing data.

func (*Graphite) OpenWarp

func (g *Graphite) OpenWarp(token string, txn string) (*core.Warp, error)

OpenWarp Get warp connection