opentsdbhttp

Documentation

Index

• type Row
• type Rows
  • func (rs *Rows) Reset()
  • func (rs *Rows) Unmarshal(av *fastjson.Value)
• type Server
  • func MustServe(ln net.Listener, maxRequestSize int64) *Server
  • func MustStart(addr string, maxRequestSize int64) *Server
  • func (s *Server) MustStop()
  • func (s *Server) Wait()
• type Tag

Types

type Row

type Row struct {
	Metric    string
	Tags      []Tag
	Value     float64
	Timestamp int64
}

Row is a single OpenTSDB row.

type Rows

type Rows struct {
	Rows []Row
	// contains filtered or unexported fields
}

Rows contains parsed OpenTSDB rows.

func (*Rows) Reset

func (rs *Rows) Reset()

Reset resets rs.

func (*Rows) Unmarshal

func (rs *Rows) Unmarshal(av *fastjson.Value)

Unmarshal unmarshals OpenTSDB rows from av.

See http://opentsdb.net/docs/build/html/api_http/put.html

s must be unchanged until rs is in use.

type Server

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

Server represents HTTP OpenTSDB server.

func MustServe

func MustServe(ln net.Listener, maxRequestSize int64) *Server

MustServe serves OpenTSDB HTTP put requests from ln with up to maxRequestSize size.

MustStop must be called on the returned server when it is no longer needed.

func MustStart

func MustStart(addr string, maxRequestSize int64) *Server

MustStart starts HTTP OpenTSDB server on the given addr.

MustStop must be called on the returned server when it is no longer needed.

func (*Server) MustStop

func (s *Server) MustStop()

MustStop stops HTTP OpenTSDB server.

func (*Server) Wait

func (s *Server) Wait()

Wait waits until the server is stopped with MustStop.

type Tag

type Tag struct {
	Key   string
	Value string
}

Tag is an OpenTSDB tag.