tags

Documentation

Index

• func FilePath(root string, s string, hashOnly bool) string
• func Normalize(s string) (string, error)
• type Options
• type Queue
  • func NewQueue(rootPath string, send func([]string) error, sendChunk int) (*Queue, error)
  • func (q *Queue) Add(metric string)
  • func (q *Queue) Lag() time.Duration
  • func (q *Queue) Stop()
• type Tags
  • func New(options *Options) *Tags
  • func (t *Tags) Add(value string, now bool)
  • func (t *Tags) Stat(send helper.StatCallback)
  • func (t *Tags) Stop()

Functions

func FilePath

func FilePath(root string, s string, hashOnly bool) string

func Normalize

func Normalize(s string) (string, error)

Types

type Options

type Options struct {
	LocalPath           string
	TagDB               string
	TagDBTimeout        time.Duration
	TagDBChunkSize      int
	TagDBUpdateInterval uint64
}

type Queue

type Queue struct {
	helper.Stoppable
	// contains filtered or unexported fields
}

func NewQueue

func NewQueue(rootPath string, send func([]string) error, sendChunk int) (*Queue, error)

func (*Queue) Add

func (q *Queue) Add(metric string)

func (*Queue) Lag

func (q *Queue) Lag() time.Duration

func (*Queue) Stop

func (q *Queue) Stop()

type Tags

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

func New

func New(options *Options) *Tags

func (*Tags) Add

func (t *Tags) Add(value string, now bool)

func (*Tags) Stat

func (t *Tags) Stat(send helper.StatCallback)

Collect metrics

func (*Tags) Stop

func (t *Tags) Stop()