graphite

Documentation

Index

• Constants
• Variables
• func RunCarbon(ShareDir string, DataDir string, GraphiteCarbonPort int, ...)
• func RunCarbonApi(z string, port int, l int, cacheType string, mc string, memsize int, cpus int, ...)
• type Graphite
  • func GraphiteFactory(protocol string, host string, port int, prefix string) (*Graphite, error)
  • func NewGraphite(host string, port int) (*Graphite, error)
  • func NewGraphiteNop(host string, port int) *Graphite
  • func NewGraphiteUDP(host string, port int) (*Graphite, error)
  • func NewGraphiteWithMetricPrefix(host string, port int, prefix string) (*Graphite, error)
  • func (graphite *Graphite) Connect() error
  • func (graphite *Graphite) Disconnect() error
  • func (graphite *Graphite) IsNop() bool
  • func (graphite *Graphite) SendMetric(metric Metric) error
  • func (graphite *Graphite) SendMetrics(metrics []Metric) error
  • func (graphite *Graphite) SimpleSend(stat string, value string) error
• type Metric
  • func NewMetric(name, value string, timestamp int64) Metric
  • func (metric Metric) String() string
• Bugs

Constants

const Version = "0.9.0"

Variables

var BuildVersion = "(development build)"

BuildVersion is provided to be overridden at build time. Eg. go build -ldflags -X 'main.BuildVersion=...'

var Limiter limiter

Limiter limits concurrent zipper requests

var Metrics = struct {
	Requests         *expvar.Int
	RequestCacheHits *expvar.Int

	FindRequests  *expvar.Int
	FindCacheHits *expvar.Int

	RenderRequests *expvar.Int

	MemcacheTimeouts *expvar.Int

	CacheSize  expvar.Func
	CacheItems expvar.Func
}{
	Requests:         expvar.NewInt("requests"),
	RequestCacheHits: expvar.NewInt("request_cache_hits"),

	FindRequests:  expvar.NewInt("find_requests"),
	FindCacheHits: expvar.NewInt("find_cache_hits"),

	RenderRequests: expvar.NewInt("render_requests"),

	MemcacheTimeouts: expvar.NewInt("memcache_timeouts"),
}

Metrics contains exported counters and values for graphite

var Zipper zipper

Zipper is API entry to carbonzipper

Functions

func RunCarbon

func RunCarbon(ShareDir string, DataDir string, GraphiteCarbonPort int, GraphiteCarbonLinkPort int, GraphiteCarbonPicklePort int, GraphiteCarbonPprofPort int, GraphiteCarbonServerPort int)

func RunCarbonApi

func RunCarbonApi(z string, port int, l int, cacheType string, mc string, memsize int, cpus int, tz string, logdir string)

Types

type Graphite

type Graphite struct {
	Host     string
	Port     int
	Protocol string
	Timeout  time.Duration
	Prefix   string
	// contains filtered or unexported fields
}

Graphite is a struct that defines the relevant properties of a graphite connection

func GraphiteFactory

func GraphiteFactory(protocol string, host string, port int, prefix string) (*Graphite, error)

func NewGraphite

func NewGraphite(host string, port int) (*Graphite, error)

NewGraphite is a factory method that's used to create a new Graphite

func NewGraphiteNop

func NewGraphiteNop(host string, port int) *Graphite

NewGraphiteNop is a factory method that returns a Graphite struct but will not actually try to send any packets to a remote host and, instead, will just log. This is useful if you want to use Graphite in a project but don't want to make Graphite a requirement for the project.

func NewGraphiteUDP

func NewGraphiteUDP(host string, port int) (*Graphite, error)

When a UDP connection to Graphite is required

func NewGraphiteWithMetricPrefix

func NewGraphiteWithMetricPrefix(host string, port int, prefix string) (*Graphite, error)

NewGraphiteWithMetricPrefix is a factory method that's used to create a new Graphite with a metric prefix

func (*Graphite) Connect

func (graphite *Graphite) Connect() error

Given a Graphite struct, Connect populates the Graphite.conn field with an appropriate TCP connection

func (*Graphite) Disconnect

func (graphite *Graphite) Disconnect() error

Given a Graphite struct, Disconnect closes the Graphite.conn field

func (*Graphite) IsNop

func (graphite *Graphite) IsNop() bool

IsNop is a getter for *graphite.Graphite.nop

func (*Graphite) SendMetric

func (graphite *Graphite) SendMetric(metric Metric) error

Given a Metric struct, the SendMetric method sends the supplied metric to the Graphite connection that the method is called upon

func (*Graphite) SendMetrics

func (graphite *Graphite) SendMetrics(metrics []Metric) error

Given a slice of Metrics, the SendMetrics method sends the metrics, as a batch, to the Graphite connection that the method is called upon

func (*Graphite) SimpleSend

func (graphite *Graphite) SimpleSend(stat string, value string) error

The SimpleSend method can be used to just pass a metric name and value and have it be sent to the Graphite host with the current timestamp

type Metric

type Metric struct {
	Name      string
	Value     string
	Timestamp int64
}

Metric is a struct that defines the relevant properties of a graphite metric

func NewMetric

func NewMetric(name, value string, timestamp int64) Metric

func (Metric) String

func (metric Metric) String() string

Notes

Bugs

• doesn't handle timezones the same as graphite-web