backoff

May 5, 2023

Changes in this version

+ func GetComputeResourceAndQuantity(err error, resourceRegex *regexp.Regexp) v1.ResourceList

+ func IsResourceRequestsEligible(err error) bool

Oct 8, 2021

Changes in this version

+ type SyncResourceList struct

+ func NewSyncResourceList() *SyncResourceList

+ func (s *SyncResourceList) AddResourceList(list v1.ResourceList) *SyncResourceList

+ func (s *SyncResourceList) AsResourceList() v1.ResourceList

+ func (s *SyncResourceList) Load(resourceName v1.ResourceName) (quantity resource.Quantity, found bool)

+ func (s *SyncResourceList) Range(visitor func(key v1.ResourceName, value resource.Quantity) bool)

+ func (s *SyncResourceList) Store(resourceName v1.ResourceName, quantity resource.Quantity)

+ func (s *SyncResourceList) String() string

Mar 10, 2021

Changes in this version

+ func IsBackOffError(err error) bool

+ type AtomicTime struct

+ func NewAtomicTime(t time.Time) AtomicTime

+ func (a *AtomicTime) Load() time.Time

+ func (a *AtomicTime) Store(t time.Time)

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