backoff

Dec 23, 2019

Changes in this version

+ func ComposeResourceKey(o k8s.Resource) string

+ func GetComputeResourceAndQuantityRequested(err error) v1.ResourceList

+ func IsBackoffError(err error) bool

+ func IsResourceQuotaExceeded(err error) bool

+ type ComputeResourceAwareBackOffHandler struct

+ func (h *ComputeResourceAwareBackOffHandler) Handle(ctx context.Context, operation func() error, ...) error

+ func (h *ComputeResourceAwareBackOffHandler) IsActive() bool

+ type ComputeResourceCeilings struct

+ type Controller struct

+ Clock clock.Clock

+ func NewController(ctx context.Context) *Controller

+ func (m *Controller) CreateBackOffHandler(ctx context.Context, key string, backOffBaseSecond int, ...) *ComputeResourceAwareBackOffHandler

+ func (m *Controller) GetBackOffHandler(key string) (*ComputeResourceAwareBackOffHandler, bool)

+ func (m *Controller) GetOrCreateHandler(ctx context.Context, key string, backOffBaseSecond int, ...) *ComputeResourceAwareBackOffHandler

+ type HandlerMap struct

+ func (m *HandlerMap) Get(key string) (*ComputeResourceAwareBackOffHandler, bool)

+ func (m *HandlerMap) Set(key string, value *ComputeResourceAwareBackOffHandler)

+ type SimpleBackOffBlocker struct

+ BackOffBaseSecond int

+ BackOffExponent int

+ Clock clock.Clock

+ MaxBackOffDuration time.Duration

+ NextEligibleTime time.Time