apmsampling

Documentation

Index

• type APMSampling
  • func (z *APMSampling) DecodeMsg(dc *msgp.Reader) (err error)
  • func (z *APMSampling) EncodeMsg(en *msgp.Writer) (err error)
  • func (z *APMSampling) MarshalMsg(b []byte) (o []byte, err error)
  • func (z *APMSampling) Msgsize() (s int)
  • func (z *APMSampling) UnmarshalMsg(bts []byte) (o []byte, err error)
• type SamplingMechanism
  • func (z *SamplingMechanism) DecodeMsg(dc *msgp.Reader) (err error)
  • func (z SamplingMechanism) EncodeMsg(en *msgp.Writer) (err error)
  • func (z SamplingMechanism) MarshalMsg(b []byte) (o []byte, err error)
  • func (z SamplingMechanism) Msgsize() (s int)
  • func (z *SamplingMechanism) UnmarshalMsg(bts []byte) (o []byte, err error)
• type TargetTPS
  • func (z *TargetTPS) DecodeMsg(dc *msgp.Reader) (err error)
  • func (z *TargetTPS) EncodeMsg(en *msgp.Writer) (err error)
  • func (z *TargetTPS) MarshalMsg(b []byte) (o []byte, err error)
  • func (z *TargetTPS) Msgsize() (s int)
  • func (z *TargetTPS) UnmarshalMsg(bts []byte) (o []byte, err error)

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