Versions in this module Expand all Collapse all v1 v1.0.1 Feb 21, 2024 v1.0.0 Feb 21, 2024 Changes in this version + func ComposeResourceKey(o client.Object) string + func GetComputeResourceAndQuantity(err error, resourceRegex *regexp.Regexp) v1.ResourceList + func IsBackOffError(err error) bool + func IsResourceQuotaExceeded(err error) bool + func IsResourceRequestsEligible(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) + 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) 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 stdAtomic.Uint32 + Clock clock.Clock + MaxBackOffDuration time.Duration + NextEligibleTime AtomicTime + 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
Go to main page