common

package
v0.31.1 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Mar 16, 2021 License: AGPL-3.0 Imports: 10 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

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 (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

Directories

Path Synopsis

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL