metrics

Documentation

Index

• Variables
• func Connect() error
• func Decr(key string)
• func Incr(key string)
• func RecordHTTPResponse(process func() (*http.Response, error)) (*http.Response, error)
• func Stats(interval time.Duration)
• func Write(name string, tags map[string]string, fields map[string]interface{}) error
• type MetricWriter
• type NullWriter
  • func (nw NullWriter) Close() error
  • func (nw NullWriter) Ping(timeout time.Duration) (time.Duration, string, error)
  • func (nw NullWriter) Query(q influx.Query) (*influx.Response, error)
  • func (nw NullWriter) Write(bp influx.BatchPoints) error

Variables

var (
	Database string
)

Functions

func Connect

func Connect() error

func Decr

func Decr(key string)

func Incr

func Incr(key string)

func RecordHTTPResponse

func RecordHTTPResponse(process func() (*http.Response, error)) (*http.Response, error)

func Stats

func Stats(interval time.Duration)

func Write

func Write(name string, tags map[string]string, fields map[string]interface{}) error

Types

type MetricWriter

type MetricWriter interface {
	Write(influx.BatchPoints) error
}

type NullWriter

type NullWriter struct{}

The writer used for testing

func (NullWriter) Close

func (nw NullWriter) Close() error

func (NullWriter) Ping

func (nw NullWriter) Ping(timeout time.Duration) (time.Duration, string, error)

Ping checks that status of cluster, and will always return 0 time and no error for UDP clients

func (NullWriter) Query

func (nw NullWriter) Query(q influx.Query) (*influx.Response, error)

func (NullWriter) Write

func (nw NullWriter) Write(bp influx.BatchPoints) error