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) *Server
  • func MustStart(addr string) *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) *Server

MustServe serves OpenTSDB HTTP put requests from ln.

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

func MustStart

func MustStart(addr string) *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.