Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func InstallNewPipeline

func InstallNewPipeline(config Config) (*controller.Controller, error)

    InstallNewPipeline instantiates a NewExportPipeline and registers it globally. Typically called as:

    pipeline, err := dogstatsd.InstallNewPipeline(dogstatsd.Config{...})
    if err != nil {
    	...
    }
    defer pipeline.Stop()
    ... Done
    

    func NewExportPipeline

    func NewExportPipeline(config Config, opts ...controller.Option) (*controller.Controller, error)

      NewExportPipeline sets up a complete export pipeline with the recommended setup, chaining a NewRawExporter into the recommended selectors and batchers.

      Types

      type Config

      type Config = statsd.Config

      type Exporter

      type Exporter struct {
      	*statsd.Exporter
      	// contains filtered or unexported fields
      }

        Exporter implements a dogstatsd-format statsd exporter, which encodes label sets as independent fields in the output.

        TODO: find a link for this syntax. It's been copied out of code, not a specification:

        https://github.com/stripe/veneur/blob/master/sinks/datadog/datadog.go

        func NewRawExporter

        func NewRawExporter(config Config) (*Exporter, error)

          NewRawExporter returns a new Dogstatsd-syntax exporter for use in a pipeline.

          func (*Exporter) AppendName

          func (*Exporter) AppendName(rec export.Record, buf *bytes.Buffer)

            AppendName is part of the stats-internal adapter interface.

            func (*Exporter) AppendTags

            func (e *Exporter) AppendTags(rec export.Record, res *resource.Resource, buf *bytes.Buffer)

              AppendTags is part of the stats-internal adapter interface.

              type LabelEncoder

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

                LabelEncoder encodes metric labels in the dogstatsd syntax.

                TODO: find a link for this syntax. It's been copied out of code, not a specification:

                https://github.com/stripe/veneur/blob/master/sinks/datadog/datadog.go

                func NewLabelEncoder

                func NewLabelEncoder() *LabelEncoder

                  NewLabelEncoder returns a new encoder for dogstatsd-syntax metric labels.

                  func (*LabelEncoder) Encode

                  func (e *LabelEncoder) Encode(iter label.Iterator) string

                    Encode emits a string like "|#key1:value1,key2:value2".

                    func (*LabelEncoder) ID

                    Directories

                    Path Synopsis
                    internal