asyncstatsd

README

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

Documentation

Index

• type Client
  • func New(c *statsd.Client, queueSize int) *Client
  • func (c *Client) Clone(opts ...statsd.Option) *Client
  • func (c *Client) Count(bucket string, n interface{})
  • func (c *Client) Gauge(bucket string, value interface{})
  • func (c *Client) Histogram(bucket string, value interface{})
  • func (c *Client) Increment(bucket string)
  • func (c *Client) NewTiming() Timing
  • func (c *Client) Timing(bucket string, value interface{})
• type RunQueue
  • func NewRunQueue(size int) *RunQueue
  • func (r *RunQueue) Close()
  • func (r *RunQueue) Queue(f func())
• type Timing
  • func (t Timing) Duration() time.Duration
  • func (t Timing) Send(bucket string)

Types

type Client

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

func New

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

New returns a new client

func (*Client) Clone

func (c *Client) Clone(opts ...statsd.Option) *Client

func (*Client) Count

func (c *Client) Count(bucket string, n interface{})

func (*Client) Gauge

func (c *Client) Gauge(bucket string, value interface{})

func (*Client) Histogram

func (c *Client) Histogram(bucket string, value interface{})

func (*Client) Increment

func (c *Client) Increment(bucket string)

func (*Client) NewTiming

func (c *Client) NewTiming() Timing

NewTiming returns a new wrapped timing struct

func (*Client) Timing

func (c *Client) Timing(bucket string, value interface{})

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 struct {
	// contains filtered or unexported fields
}

func (Timing) Duration

func (t Timing) Duration() time.Duration

func (Timing) Send

func (t Timing) Send(bucket string)