apmsampling

package
v0.37.1 Latest Latest
Warning

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

Go to latest
Published: Jun 28, 2022 License: Apache-2.0 Imports: 1 Imported by: 2

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type APMSampling

type APMSampling struct {
	TargetTPS []TargetTPS `msgpack:"0"`
}

APMSampling is the list of target tps

func (*APMSampling) DecodeMsg

func (z *APMSampling) DecodeMsg(dc *msgp.Reader) (err error)

DecodeMsg implements msgp.Decodable

func (*APMSampling) EncodeMsg

func (z *APMSampling) EncodeMsg(en *msgp.Writer) (err error)

EncodeMsg implements msgp.Encodable

func (*APMSampling) MarshalMsg

func (z *APMSampling) MarshalMsg(b []byte) (o []byte, err error)

MarshalMsg implements msgp.Marshaler

func (*APMSampling) Msgsize

func (z *APMSampling) Msgsize() (s int)

Msgsize returns an upper bound estimate of the number of bytes occupied by the serialized message

func (*APMSampling) UnmarshalMsg

func (z *APMSampling) UnmarshalMsg(bts []byte) (o []byte, err error)

UnmarshalMsg implements msgp.Unmarshaler

type SamplingMechanism

type SamplingMechanism uint32

SamplingMechanism is the source of the sampling rates. Possible values

1: agent rate (Default)
2: dynamically calculated remote rate
6: remote rate defined by user
7: remote rate defined by Datadog

This list is not exhaustive.

func (*SamplingMechanism) DecodeMsg

func (z *SamplingMechanism) DecodeMsg(dc *msgp.Reader) (err error)

DecodeMsg implements msgp.Decodable

func (SamplingMechanism) EncodeMsg

func (z SamplingMechanism) EncodeMsg(en *msgp.Writer) (err error)

EncodeMsg implements msgp.Encodable

func (SamplingMechanism) MarshalMsg

func (z SamplingMechanism) MarshalMsg(b []byte) (o []byte, err error)

MarshalMsg implements msgp.Marshaler

func (SamplingMechanism) Msgsize

func (z SamplingMechanism) Msgsize() (s int)

Msgsize returns an upper bound estimate of the number of bytes occupied by the serialized message

func (*SamplingMechanism) UnmarshalMsg

func (z *SamplingMechanism) UnmarshalMsg(bts []byte) (o []byte, err error)

UnmarshalMsg implements msgp.Unmarshaler

type TargetTPS

type TargetTPS struct {
	Service string `msgpack:"0"`
	Env     string `msgpack:"1"`
	// Value contains the targetTPS value to apply (target traces per second).
	Value float64 `msgpack:"2"`
	// Rank is the rank associated to this TargetTPS. Lower ranks of a same (env, service) are discarded
	// in favor of the highest rank.
	Rank uint32 `msgpack:"3"`
	// Mechanism is the identifier of the mechanism that generated this TargetTPS
	Mechanism SamplingMechanism `msgpack:"4"`
}

TargetTPS contains the targeted traces per second the agent should try to sample for a particular service and env

func (*TargetTPS) DecodeMsg

func (z *TargetTPS) DecodeMsg(dc *msgp.Reader) (err error)

DecodeMsg implements msgp.Decodable

func (*TargetTPS) EncodeMsg

func (z *TargetTPS) EncodeMsg(en *msgp.Writer) (err error)

EncodeMsg implements msgp.Encodable

func (*TargetTPS) MarshalMsg

func (z *TargetTPS) MarshalMsg(b []byte) (o []byte, err error)

MarshalMsg implements msgp.Marshaler

func (*TargetTPS) Msgsize

func (z *TargetTPS) Msgsize() (s int)

Msgsize returns an upper bound estimate of the number of bytes occupied by the serialized message

func (*TargetTPS) UnmarshalMsg

func (z *TargetTPS) UnmarshalMsg(bts []byte) (o []byte, err error)

UnmarshalMsg implements msgp.Unmarshaler

Jump to

Keyboard shortcuts

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