ratelimiter

type IndividualSerializer ¶

type IndividualSerializer struct {
	// contains filtered or unexported fields
}

IndividualSerializer instances serialize each metric individually using the serializer's Serialize() function and add the resulting output to the buffer until the limit is reached. This only works for serializers NOT requiring the serialization of a batch as-a-whole.

func NewIndividualSerializer(s telegraf.Serializer) *IndividualSerializer

func (s *IndividualSerializer) Serialize(metric telegraf.Metric, limit int64) ([]byte, error)

func (s *IndividualSerializer) SerializeBatch(metrics []telegraf.Metric, limit int64) ([]byte, error)

type RateLimitConfig ¶

type RateLimitConfig struct {
	Limit  config.Size     `toml:"rate_limit"`
	Period config.Duration `toml:"rate_limit_period"`
}

func (cfg *RateLimitConfig) CreateRateLimiter() (*RateLimiter, error)

type RateLimiter ¶

type RateLimiter struct {
	sync.Mutex
	// contains filtered or unexported fields
}

func (r *RateLimiter) Accept(t time.Time, used int64)

func (r *RateLimiter) Release()

func (r *RateLimiter) Remaining(t time.Time) int64

func (r *RateLimiter) Reserve(used int64)

func (r *RateLimiter) Undo(t time.Time, used int64)

type Serializer ¶

type Serializer interface {
	Serialize(metric telegraf.Metric, limit int64) ([]byte, error)
	SerializeBatch(metrics []telegraf.Metric, limit int64) ([]byte, error)
}

Serializer interface abstracting the different implementations of a limited-size serializer