queue

Documentation

Index

• func DetermineRequeueInterval(state shared.State, intervals RequeueIntervals) time.Duration
• type RequeueIntervals
• type RequeueJitter
  • func NewRequeueJitter(jitterProbability, jitterPercentage float64) *RequeueJitter
  • func (j *RequeueJitter) Apply(interval time.Duration) time.Duration
• type RequeueType

Functions

func DetermineRequeueInterval

func DetermineRequeueInterval(state shared.State, intervals RequeueIntervals) time.Duration

Types

type RequeueIntervals

type RequeueIntervals struct {
	Success time.Duration
	Busy    time.Duration
	Warning time.Duration
	Error   time.Duration
	Jitter  *RequeueJitter
}

type RequeueJitter

type RequeueJitter struct {
	JitterProbability float64
	JitterPercentage  float64
	RandFunc          func() float64
}

func NewRequeueJitter

func NewRequeueJitter(jitterProbability, jitterPercentage float64) *RequeueJitter

func (*RequeueJitter) Apply

func (j *RequeueJitter) Apply(interval time.Duration) time.Duration

type RequeueType

type RequeueType string

const (
	IntendedRequeue   RequeueType = "intended"
	UnexpectedRequeue RequeueType = "unexpected"
)