AlwaysRetry is an error handler that always retries the error.

EventStreamFromFiles returns an observable stream of events created from decoding the given slice of files and emitted as Upserts.

New creates a new Resource[T].

RetryUpTo is an error handler that retries a key up to specified number of times before stopping.

WithErrorHandler specifies the error handling strategy for failed events.

WithIndexers sets additional custom indexers on the resource store.

WithLazyTransform sets the function to transform the object before storing it.

WithMetric enables metrics collection for the resource using the provided scope.

WithName sets the name of the resource.

WithRateLimiter sets the rate limiting algorithm to be used when requeueing failed events.

WithStoppableInformer marks the resource as releasable.

WithTransform sets the function to transform the object before storing it.

ErrorActionIgnore instructs to ignore the error.

ErrorActionRetry instructs to retry the processing.

ErrorActionStop instructs to stop the processing for this subscriber.

Event emitted from resource.

Key of an K8s object, e.g.

Resource provides access to a Kubernetes resource through either a stream of events or a read-only store.

Store is a read-only typed wrapper for cache.Store.

ErrorHandler is a function that takes the key of the failing object (zero key if event was sync), the number of times the key has been retried and the error that occurred.