reconcile

Dec 27, 2022

Changes in this version

+ type BackoffResetCallbackFunc func(key K)

+ type BackoffStartCallbackFunc func(key K, reason error)

Jan 24, 2021

Changes in this version

type Core

+ func (c *Core) Reconcile(stop <-chan struct{})

Nov 2, 2020

Changes in this version

+ type BackoffResetCallback func(key interface{})

+ type BackoffStartCallback func(key interface{}, err error)

+ type Cache struct

+ func NewCache() *Cache

+ func (r *Cache) Delete(key interface{})

+ func (r *Cache) Freeze(key interface{}, freeze bool)

+ func (r *Cache) Get(key interface{}) (old, latest interface{})

+ func (r *Cache) Update(key interface{}, old, latest interface{})

+ type CompareObjectHandleFunc func(old, new interface{}) *Result

+ type Core struct

+ func NewCore(ctx context.Context, resolvedOpts *Options) *Core

+ func (c *Core) CancelSchedule(job queue.Job) bool

+ func (c *Core) ReconcileUntil(stop <-chan struct{})

+ func (c *Core) Schedule(job queue.Job, delay time.Duration) error

+ func (c *Core) Start() error

+ type HandleFuncs struct

+ OnAdded SingleObjectHandleFunc

+ OnDeleted SingleObjectHandleFunc

+ OnDeleting SingleObjectHandleFunc

+ OnUpdated CompareObjectHandleFunc

+ func (h *HandleFuncs) ResolveNil() *HandleFuncs

+ type Interface interface

+ CancelSchedule func(job queue.Job) bool

+ ReconcileUntil func(stop <-chan struct{})

+ Schedule func(job queue.Job, delay time.Duration) error

+ Start func() error

+ type KubeInformerReconciler struct

+ func NewKubeInformerReconciler(ctx context.Context, informer kubecache.SharedInformer, options Options) *KubeInformerReconciler

+ func (r *KubeInformerReconciler) GetKey(obj interface{}) string

+ type Options struct

+ BackoffStrategy *backoff.Strategy

+ Handlers HandleFuncs

+ Logger log.Interface

+ OnBackoffReset BackoffResetCallback

+ OnBackoffStart BackoffStartCallback

+ RequireCache bool

+ Workers int

+ func (o Options) ResolveNil() *Options

+ type Result struct

+ Err error

+ NextAction queue.JobAction

+ ScheduleAfter time.Duration

+ type SingleObjectHandleFunc func(obj interface{}) *Result