cache

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

type Options struct {
	Namespace        string
	Resync           time.Duration
	TweakList        TweakListOptionsFunc
	WaitHealthy      func(ctx context.Context)
	DisableWatchList bool
}

type SharedCacheFactory interface {
	Start(ctx context.Context) error
	StartGVK(ctx context.Context, gvk schema.GroupVersionKind) error
	ForObject(obj runtime.Object) (cache.SharedIndexInformer, error)
	ForKind(gvk schema.GroupVersionKind) (cache.SharedIndexInformer, error)
	ForResource(gvr schema.GroupVersionResource, namespaced bool) (cache.SharedIndexInformer, error)
	ForResourceKind(gvr schema.GroupVersionResource, kind string, namespaced bool) (cache.SharedIndexInformer, error)
	WaitForCacheSync(ctx context.Context) map[schema.GroupVersionKind]bool
	SharedClientFactory() client.SharedClientFactory
}

type SharedCacheFactoryOptions struct {
	DefaultResync           time.Duration
	DefaultNamespace        string
	DefaultTweakList        TweakListOptionsFunc
	DefaultDisableWatchList bool

	KindResync           map[schema.GroupVersionKind]time.Duration
	KindNamespace        map[schema.GroupVersionKind]string
	KindTweakList        map[schema.GroupVersionKind]TweakListOptionsFunc
	KindDisableWatchList map[schema.GroupVersionKind]bool
	HealthCallback       func(healthy bool)

	// Determines how often metrics are gathered about how many resources are
	// cached by gvk across all caches in the sharedCacheFactory
	MetricsCollectionPeriod time.Duration
}

type TweakListOptionsFunc func(*v1.ListOptions)