graphite

Documentation

Overview

no rounding of timestamps to the nearest interval. Upon ingestion of multiple datapoints for a given key within the same interval (possibly but not necessarily the same timestamp), graphite would use one (the latest received) value with a rounded timestamp representing that interval. We store values for every timestamp we receive (only the latest value for a given metric-timestamp pair) so it's up to the user to feed the data in proper intervals (and use round intervals if you plan to rely on that)

Index

• type GraphiteMetric
  • func (self *GraphiteMetric) Read(reader *bufio.Reader) error
• type Record
• type Server
  • func NewServer(config *configuration.Configuration, coord coordinator.Coordinator, ...) *Server
  • func (self *Server) Close()
  • func (self *Server) ListenAndServe()
  • func (self *Server) Serve(listener net.Listener)
  • func (self *Server) ServeUdp(conn *net.UDPConn)

Types

type GraphiteMetric

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

func (*GraphiteMetric) Read

func (self *GraphiteMetric) Read(reader *bufio.Reader) error

returns err == io.EOF when we hit EOF without any further data

type Record

type Record struct {
	Name string
	*protocol.Point
}

holds a point to be added into series by Name

type Server

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

func NewServer

func NewServer(config *configuration.Configuration, coord coordinator.Coordinator, clusterConfig *cluster.ClusterConfiguration) *Server

TODO: check that database exists and create it if not

func (*Server) Close

func (self *Server) Close()

func (*Server) ListenAndServe

func (self *Server) ListenAndServe()

func (*Server) Serve

func (self *Server) Serve(listener net.Listener)

func (*Server) ServeUdp

func (self *Server) ServeUdp(conn *net.UDPConn)