retryer

Documentation

Index

• Constants
• func GetDefaultRetryNumber() int
• type IMDSRetryer
  • func NewIMDSRetryer(imdsRetries int) IMDSRetryer
  • func (r IMDSRetryer) ShouldRetry(req *request.Request) bool
• type LogThrottleRetryer
  • func NewLogThrottleRetryer(logger telegraf.Logger) *LogThrottleRetryer
  • func (r *LogThrottleRetryer) ShouldRetry(req *request.Request) bool
  • func (r *LogThrottleRetryer) Stop()

Constants

const (
	DefaultImdsRetries = 1
)

Functions

func GetDefaultRetryNumber

func GetDefaultRetryNumber() int

Types

type IMDSRetryer

type IMDSRetryer struct {
	client.DefaultRetryer
}

func NewIMDSRetryer

func NewIMDSRetryer(imdsRetries int) IMDSRetryer

NewIMDSRetryer allows us to retry imds errors otel component layer retries should come from aws config settings translator layer should come from env vars see GetDefaultRetryNumber()

func (IMDSRetryer) ShouldRetry

func (r IMDSRetryer) ShouldRetry(req *request.Request) bool

type LogThrottleRetryer

type LogThrottleRetryer struct {
	Log telegraf.Logger

	client.DefaultRetryer
	// contains filtered or unexported fields
}

func NewLogThrottleRetryer

func NewLogThrottleRetryer(logger telegraf.Logger) *LogThrottleRetryer

func (*LogThrottleRetryer) ShouldRetry

func (r *LogThrottleRetryer) ShouldRetry(req *request.Request) bool

func (*LogThrottleRetryer) Stop

func (r *LogThrottleRetryer) Stop()