server

Documentation

Overview

Package dogstatsd implements DogStatsD.

Package server implements a component to run the dogstatsd server

Package server implements a component to run the dogstatsd server

Index

• Variables
• func MockModule() fxutil.Module
• func Module() fxutil.Module
• func ScanLines(data []byte, atEOF bool) (advance int, token []byte, eol bool, err error)
• type Component
• type Mock
• type Params
• type ServerlessDogstatsd
  • func NewServerlessServer(demux aggregator.Demultiplexer) (ServerlessDogstatsd, error)

Variables

var (

	//nolint:revive // TODO(AML) Fix revive linter
	CardinalityTagPrefix = constants.CardinalityTagPrefix
)

Functions

func MockModule

func MockModule() fxutil.Module

MockModule defines the fx options for the mock component.

func Module

func Module() fxutil.Module

Module defines the fx options for this component.

func ScanLines

func ScanLines(data []byte, atEOF bool) (advance int, token []byte, eol bool, err error)

ScanLines is an almost identical reimplementation of bufio.ScanLines, but also reports if the returned line is newline-terminated

Types

type Component

type Component interface {
	// IsRunning returns true if the server is running
	IsRunning() bool

	// UdsListenerRunning returns true if the uds listener is running
	UdsListenerRunning() bool

	// ServerlessFlush flushes all the data to the aggregator to them send it to the Datadog intake.
	ServerlessFlush(time.Duration)

	// SetExtraTags sets extra tags. All metrics sent to the DogstatsD will be tagged with them.
	SetExtraTags(tags []string)

	// UDPLocalAddr returns the local address of the UDP statsd listener, if enabled.
	UDPLocalAddr() string
}

Component is the component type.

type Mock

type Mock interface {
	Component
}

Mock implements mock-specific methods.

type Params

type Params struct {
	Serverless bool
}

type ServerlessDogstatsd

type ServerlessDogstatsd interface {
	Component
	Stop()
}

ServerlessDogstatsd is the interface for the serverless dogstatsd server.

func NewServerlessServer

func NewServerlessServer(demux aggregator.Demultiplexer) (ServerlessDogstatsd, error)