Documentation ¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type BackoffResetCallbackFunc ¶ added in v0.12.0
type BackoffResetCallbackFunc[K comparable] func(key K)
type BackoffStartCallbackFunc ¶ added in v0.12.0
type BackoffStartCallbackFunc[K comparable] func(key K, reason error)
type Cache ¶
type Cache[K comparable, V any] struct { // contains filtered or unexported fields }
func NewCache ¶
func NewCache[K comparable, V any]() *Cache[K, V]
type CompareObjectHandleFunc ¶
type Core ¶
type Core[K comparable, V any] struct { *Cache[K, V] // contains filtered or unexported fields }
func (*Core[K, V]) Reconcile ¶ added in v0.5.5
func (c *Core[K, V]) Reconcile(stop <-chan struct{})
Reconcile jobs until stop released
type HandleFuncs ¶
type HandleFuncs[T any] struct { OnAdded SingleObjectHandleFunc[T] OnUpdated CompareObjectHandleFunc[T] OnDeleting SingleObjectHandleFunc[T] OnDeleted SingleObjectHandleFunc[T] }
func (*HandleFuncs[T]) ResolveNil ¶
func (h *HandleFuncs[T]) ResolveNil() (result HandleFuncs[T])
type Options ¶
type Options[K comparable, T any] struct { Logger log.Interface BackoffStrategy *backoff.Strategy[K] Workers int RequireCache bool Handlers HandleFuncs[T] OnBackoffStart BackoffStartCallbackFunc[K] OnBackoffReset BackoffResetCallbackFunc[K] }
func (Options[K, T]) ResolveNil ¶
Click to show internal directories.
Click to hide internal directories.