graphite

package
v0.8.7 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Nov 16, 2014 License: MIT Imports: 14 Imported by: 0

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

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

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 api.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)

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL