meltdown

Documentation

Overview

Package meltdown is used by reconcilers to delay reconciling if too many updates happen to a resource

Index

• Variables
• func SetLastReconcile(objectMeta *metav1.ObjectMeta, now time.Time)
• type Window
  • func NewAnnotationWindow(duration time.Duration, annotations map[string]string) Window
  • func NewWindow(duration time.Duration, lastReconcile *metav1.Time) Window
  • func (w Window) Contains(now time.Time) bool

Variables

var AnnotationLastReconcile = fmt.Sprintf("%s/last-reconcile", names.GroupName)

AnnotationLastReconcile is the key name of the timestamp for the last successful reconcile

Functions

func SetLastReconcile

func SetLastReconcile(objectMeta *metav1.ObjectMeta, now time.Time)

SetLastReconcile annotation in object meta to the given time

Types

type Window

type Window struct {
	Start    time.Time
	Duration time.Duration
}

Window represents a time window starting at start and ending at duration

func NewAnnotationWindow

func NewAnnotationWindow(duration time.Duration, annotations map[string]string) Window

NewAnnotationWindow returns a window starting at lastReconcile contained in annotations, ending after duration

func NewWindow

func NewWindow(duration time.Duration, lastReconcile *metav1.Time) Window

NewWindow returns a new time window starting at lastReconcile, ending after duration

func (Window) Contains

func (w Window) Contains(now time.Time) bool

Contains returns true if the given time is in the specified time window