statsd

package

Go to main page

Versions in this module

v5

v5.6.0

Dec 10, 2024

v5.5.0

Jan 24, 2024

Changes in this version

+ type ClientDirect struct

+ func NewDirect(addr string, options ...Option) (*ClientDirect, error)

+ func NewDirectWithWriter(writer io.WriteCloser, options ...Option) (*ClientDirect, error)

+ func (c *ClientDirect) DistributionSamples(name string, values []float64, tags []string, rate float64) error

+ type ClientDirectInterface interface

+ DistributionSamples func(name string, values []float64, tags []string, rate float64) error

+ type NoOpClientDirect struct

+ func (n *NoOpClientDirect) DistributionSamples(name string, values []float64, tags []string, rate float64) error

type Option

+ func WithConnectTimeout(connectTimeout time.Duration) Option

v5.4.0

Dec 7, 2023

Changes in this version

+ const UnixAddressDatagramPrefix

+ const UnixAddressStreamPrefix

+ var AddressPrefixes = []string

+ func LoggingErrorHandler(err error)

type Client

+ func (c *Client) GetTransport() string

+ type ErrorHandler func(error)

+ type ErrorInputChannelFull struct

+ ChannelSize int

+ Metric metric

+ Msg string

+ func (e ErrorInputChannelFull) Error() string

+ type ErrorSenderChannelFull struct

+ ChannelSize int

+ LostElements int

+ Msg string

+ func (e *ErrorSenderChannelFull) Error() string

type Option

+ func WithChannelModeErrorsWhenFull() Option

+ func WithErrorHandler(errorHandler ErrorHandler) Option

+ func WithMaxSamplesPerContext(maxSamplesPerDistribution int) Option

+ func WithoutChannelModeErrorsWhenFull() Option

+ type Transport interface

+ GetTransportName func() string

v5.3.0

Mar 7, 2023

v5.2.0

Dec 22, 2022

Changes in this version

+ const InvalidTimestamp

type Client

+ func (c *Client) CountWithTimestamp(name string, value int64, tags []string, rate float64, timestamp time.Time) error

+ func (c *Client) GaugeWithTimestamp(name string, value float64, tags []string, rate float64, timestamp time.Time) error

type ClientInterface

+ CountWithTimestamp func(name string, value int64, tags []string, rate float64, timestamp time.Time) error

+ GaugeWithTimestamp func(name string, value float64, tags []string, rate float64, timestamp time.Time) error

type NoOpClient

+ func (n *NoOpClient) CountWithTimestamp(name string, value int64, tags []string, rate float64, timestamp time.Time) error

+ func (n *NoOpClient) GaugeWithTimestamp(name string, value float64, tags []string, rate float64, timestamp time.Time) error

v5.1.1

May 5, 2022

v5.1.0

Mar 3, 2022

Changes in this version

type Client

+ func (c *Client) IsClosed() bool

type ClientInterface

+ GetTelemetry func() Telemetry

+ IsClosed func() bool

+ type MessageTooLongError struct

+ func (e MessageTooLongError) Error() string

type NoOpClient

+ func (n *NoOpClient) GetTelemetry() Telemetry

+ func (n *NoOpClient) IsClosed() bool

type Option

+ func WithContainerID(id string) Option

+ func WithOriginDetection() Option

+ func WithoutOriginDetection() Option

v5.0.2

Nov 29, 2021

v5.0.1

Oct 18, 2021

v5.0.0

Oct 4, 2021

Changes in this version

+ const DefaultMaxAgentPayloadSize

+ const DefaultUDPBufferPoolSize

+ const DefaultUDSBufferPoolSize

+ const ErrNoClient

+ const MaxUDPPayloadSize

+ const OptimalUDPPayloadSize

+ const UnixAddressPrefix

+ const WindowsPipeAddressPrefix

+ type Client struct

+ func CloneWithExtraOptions(c *Client, options ...Option) (*Client, error)

+ func New(addr string, options ...Option) (*Client, error)

+ func NewWithWriter(w io.WriteCloser, options ...Option) (*Client, error)

+ func (c *Client) Close() error

+ func (c *Client) Count(name string, value int64, tags []string, rate float64) error

+ func (c *Client) Decr(name string, tags []string, rate float64) error

+ func (c *Client) Distribution(name string, value float64, tags []string, rate float64) error

+ func (c *Client) Event(e *Event) error

+ func (c *Client) Flush() error

+ func (c *Client) Gauge(name string, value float64, tags []string, rate float64) error

+ func (c *Client) GetTelemetry() Telemetry

+ func (c *Client) Histogram(name string, value float64, tags []string, rate float64) error

+ func (c *Client) Incr(name string, tags []string, rate float64) error

+ func (c *Client) ServiceCheck(sc *ServiceCheck) error

+ func (c *Client) Set(name string, value string, tags []string, rate float64) error

+ func (c *Client) SimpleEvent(title, text string) error

+ func (c *Client) SimpleServiceCheck(name string, status ServiceCheckStatus) error

+ func (c *Client) TimeInMilliseconds(name string, value float64, tags []string, rate float64) error

+ func (c *Client) Timing(name string, value time.Duration, tags []string, rate float64) error

+ type ClientInterface interface

+ Close func() error

+ Count func(name string, value int64, tags []string, rate float64) error

+ Decr func(name string, tags []string, rate float64) error

+ Distribution func(name string, value float64, tags []string, rate float64) error

+ Event func(e *Event) error

+ Flush func() error

+ Gauge func(name string, value float64, tags []string, rate float64) error

+ Histogram func(name string, value float64, tags []string, rate float64) error

+ Incr func(name string, tags []string, rate float64) error

+ ServiceCheck func(sc *ServiceCheck) error

+ Set func(name string, value string, tags []string, rate float64) error

+ SimpleEvent func(title, text string) error

+ SimpleServiceCheck func(name string, status ServiceCheckStatus) error

+ TimeInMilliseconds func(name string, value float64, tags []string, rate float64) error

+ Timing func(name string, value time.Duration, tags []string, rate float64) error

+ type Event struct

+ AggregationKey string

+ AlertType EventAlertType

+ Hostname string

+ Priority EventPriority

+ SourceTypeName string

+ Tags []string

+ Text string

+ Timestamp time.Time

+ Title string

+ func NewEvent(title, text string) *Event

+ func (e *Event) Check() error

+ type EventAlertType string

+ const Error

+ const Info

+ const Success

+ const Warning

+ type EventPriority string

+ const Low

+ const Normal

+ type NoOpClient struct

+ func (n *NoOpClient) Close() error

+ func (n *NoOpClient) Count(name string, value int64, tags []string, rate float64) error

+ func (n *NoOpClient) Decr(name string, tags []string, rate float64) error

+ func (n *NoOpClient) Distribution(name string, value float64, tags []string, rate float64) error

+ func (n *NoOpClient) Event(e *Event) error

+ func (n *NoOpClient) Flush() error

+ func (n *NoOpClient) Gauge(name string, value float64, tags []string, rate float64) error

+ func (n *NoOpClient) Histogram(name string, value float64, tags []string, rate float64) error

+ func (n *NoOpClient) Incr(name string, tags []string, rate float64) error

+ func (n *NoOpClient) ServiceCheck(sc *ServiceCheck) error

+ func (n *NoOpClient) Set(name string, value string, tags []string, rate float64) error

+ func (n *NoOpClient) SimpleEvent(title, text string) error

+ func (n *NoOpClient) SimpleServiceCheck(name string, status ServiceCheckStatus) error

+ func (n *NoOpClient) TimeInMilliseconds(name string, value float64, tags []string, rate float64) error

+ func (n *NoOpClient) Timing(name string, value time.Duration, tags []string, rate float64) error

+ type Option func(*Options) error

+ func WithAggregationInterval(interval time.Duration) Option

+ func WithBufferFlushInterval(bufferFlushInterval time.Duration) Option

+ func WithBufferPoolSize(bufferPoolSize int) Option

+ func WithChannelMode() Option

+ func WithChannelModeBufferSize(bufferSize int) Option

+ func WithClientSideAggregation() Option

+ func WithExtendedClientSideAggregation() Option

+ func WithMaxBytesPerPayload(MaxBytesPerPayload int) Option

+ func WithMaxMessagesPerPayload(maxMessagesPerPayload int) Option

+ func WithMutexMode() Option

+ func WithNamespace(namespace string) Option

+ func WithSenderQueueSize(senderQueueSize int) Option

+ func WithTags(tags []string) Option

+ func WithTelemetryAddr(addr string) Option

+ func WithWorkersCount(workersCount int) Option

+ func WithWriteTimeout(writeTimeout time.Duration) Option

+ func WithoutClientSideAggregation() Option

+ func WithoutTelemetry() Option

+ type Options struct

+ type ServiceCheck struct

+ Hostname string

+ Message string

+ Name string

+ Status ServiceCheckStatus

+ Tags []string

+ Timestamp time.Time

+ func NewServiceCheck(name string, status ServiceCheckStatus) *ServiceCheck

+ func (sc *ServiceCheck) Check() error

+ type ServiceCheckStatus byte

+ const Critical

+ const Ok

+ const Unknown

+ const Warn

+ type Telemetry struct

+ AggregationNbContext uint64

+ AggregationNbContextCount uint64

+ AggregationNbContextDistribution uint64

+ AggregationNbContextGauge uint64

+ AggregationNbContextHistogram uint64

+ AggregationNbContextSet uint64

+ AggregationNbContextTiming uint64

+ TotalBytesDropped uint64

+ TotalBytesDroppedQueueFull uint64

+ TotalBytesDroppedWriter uint64

+ TotalBytesSent uint64

+ TotalDroppedOnReceive uint64

+ TotalEvents uint64

+ TotalMetrics uint64

+ TotalMetricsCount uint64

+ TotalMetricsDistribution uint64

+ TotalMetricsGauge uint64

+ TotalMetricsHistogram uint64

+ TotalMetricsSet uint64

+ TotalMetricsTiming uint64

+ TotalPayloadsDropped uint64

+ TotalPayloadsDroppedQueueFull uint64

+ TotalPayloadsDroppedWriter uint64

+ TotalPayloadsSent uint64

+ TotalServiceChecks uint64

Other modules containing this package

github.com/DataDog/datadog-go

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