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(params Params) fxutil.Module
• type Component
• type Mock
• type MockProvides
• 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(params Params) fxutil.Module

Module defines the fx options for this component.

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 MockProvides

type MockProvides struct {
	fx.Out

	Comp     Component
	Endpoint api.AgentEndpointProvider
}

MockProvides is the mock component output

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)