backoff

type ComputeResourceAwareBackOffHandler ¶

type ComputeResourceAwareBackOffHandler struct {
	*SimpleBackOffBlocker
	*ComputeResourceCeilings
}

ComputeResourceAwareBackOffHandler is an exponential back-off handler that also keeps track of the resource ceilings of the operations that are blocked or failed due to resource insufficiency

func (h *ComputeResourceAwareBackOffHandler) Handle(ctx context.Context, operation func() error, requestedResourceList v1.ResourceList) error

func (h *ComputeResourceAwareBackOffHandler) IsActive() bool

type ComputeResourceCeilings ¶

type ComputeResourceCeilings struct {
	// contains filtered or unexported fields
}

type Controller ¶

type Controller struct {
	// Controller.Clock allows the use of fake clock when testing
	Clock clock.Clock
	// contains filtered or unexported fields
}

Controller is a name-spaced collection of back-off handlers

func NewController(ctx context.Context) *Controller

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

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

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

type HandlerMap ¶

type HandlerMap struct {
	sync.Map
}

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

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

type SimpleBackOffBlocker ¶

type SimpleBackOffBlocker struct {
	Clock              clock.Clock
	BackOffBaseSecond  int
	BackOffExponent    int
	NextEligibleTime   time.Time
	MaxBackOffDuration time.Duration
}

SimpleBackOffBlocker is a simple exponential back-off timer that keeps track of the back-off period