reconcile

type BackoffResetCallback func(key interface{})

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

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

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

type Core struct {
	*Cache
	// contains filtered or unexported fields
}

type HandleFuncs struct {
	OnAdded    SingleObjectHandleFunc
	OnUpdated  CompareObjectHandleFunc
	OnDeleting SingleObjectHandleFunc
	OnDeleted  SingleObjectHandleFunc
}

type Interface interface {
	Start() error
	ReconcileUntil(stop <-chan struct{})
	Schedule(job queue.Job, delay time.Duration) error
	CancelSchedule(job queue.Job) bool
}

type Options struct {
	Logger          log.Interface
	BackoffStrategy *backoff.Strategy
	Workers         int
	RequireCache    bool
	Handlers        HandleFuncs
	OnBackoffStart  BackoffStartCallback
	OnBackoffReset  BackoffResetCallback
}

type Result struct {
	NextAction    queue.JobAction
	ScheduleAfter time.Duration
	Err           error
}

type SingleObjectHandleFunc func(obj interface{}) *Result