common

Documentation

Index

• type Collector
  • func (c *Collector) Collect(containers []stats.SampleContainer)
  • func (c *Collector) Init() (err error)
  • func (c *Collector) Link() string
  • func (c *Collector) Run(ctx context.Context)
• type Config
• type Sample

Types

type Collector

type Collector struct {
	Config Config
	Type   string
	// ProcessTags is called on a map of all tags for each metric and returns a slice representation
	// of those tags that should be sent. No tags are send in case of ProcessTags being null
	ProcessTags func(map[string]string) []string

	Logger logrus.FieldLogger
	// contains filtered or unexported fields
}

Collector sends result data to statsd daemons with the ability to send to datadog as well

func (*Collector) Collect

func (c *Collector) Collect(containers []stats.SampleContainer)

Collect metrics

func (*Collector) Init

func (c *Collector) Init() (err error)

Init sets up the collector

func (*Collector) Link

func (c *Collector) Link() string

Link returns the address of the client

func (*Collector) Run

func (c *Collector) Run(ctx context.Context)

Run the collector

type Config

type Config interface {
	GetAddr() null.String
	GetBufferSize() null.Int
	GetNamespace() null.String
	GetPushInterval() types.NullDuration
}

Config is the common configuration interface for StatsD/Datadog.

type Sample

type Sample struct {
	Type   stats.MetricType  `json:"type"`
	Metric string            `json:"metric"`
	Time   time.Time         `json:"time"`
	Value  float64           `json:"value"`
	Tags   map[string]string `json:"tags,omitempty"`
}

Sample defines a sample type