asyncstatsd

README

An async wrapper around https://github.com/alexcesaro/statsd

Documentation

Index

• type Client
  • func New(c *statsd.Client, queueSize int) Client
  • func NewNoop() Client
• type RunQueue
  • func NewRunQueue(size int) *RunQueue
  • func (r *RunQueue) Close()
  • func (r *RunQueue) Queue(f func())
• type Timing

Types

type Client

type Client interface {
	Count(bucket string, n interface{})
	Gauge(bucket string, value interface{})
	Increment(bucket string)
	Histogram(bucket string, value interface{})
	Timing(bucket string, value interface{})

	Clone(opts ...statsd.Option) Client
	NewTiming() Timing
}

func New

func New(c *statsd.Client, queueSize int) Client

New returns a new statsdclient

func NewNoop

func NewNoop() Client

NewNoop returns a new noop client

type RunQueue

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

func NewRunQueue

func NewRunQueue(size int) *RunQueue

New returns a new runqueue

func (*RunQueue) Close

func (r *RunQueue) Close()

Close closes the run queue channel

func (*RunQueue) Queue

func (r *RunQueue) Queue(f func())

Queue queues a function to be run

type Timing

type Timing interface {
	Duration() time.Duration
	Send(bucket string)
}