- Sort Score
- Result 10 results
- Languages All
Results 1 - 3 of 3 for StorageWithCacher (0.19 sec)
-
staging/src/k8s.io/apiserver/pkg/registry/generic/registry/storage_factory.go
"k8s.io/apiserver/pkg/storage/storagebackend" "k8s.io/apiserver/pkg/storage/storagebackend/factory" "k8s.io/client-go/tools/cache" ) // Creates a cacher based given storageConfig. func StorageWithCacher() generic.StorageDecorator { return func( storageConfig *storagebackend.ConfigForResource, resourcePrefix string, keyFunc func(obj runtime.Object) (string, error), newFunc func() runtime.Object,
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Aug 24 09:23:05 UTC 2023 - 2.9K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/server/options/etcd.go
klog.V(3).InfoS("Not using watch cache", "resource", resource) ret.Decorator = generic.UndecoratedStorage } else { klog.V(3).InfoS("Using watch cache", "resource", resource) ret.Decorator = genericregistry.StorageWithCacher() } } return ret, nil } // ParseWatchCacheSizes turns a list of cache size values into a map of group resources // to requested sizes.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Apr 18 15:02:16 UTC 2024 - 20K bytes - Viewed (0) -
staging/src/k8s.io/apiextensions-apiserver/pkg/apiserver/customresource_handler_test.go
ResourcePrefix: crd.Spec.Group + "/" + crd.Spec.Names.Plural, CountMetricPollPeriod: time.Minute, } if enableWatchCache { restOptionsGetter.Decorator = genericregistry.StorageWithCacher() } handler, err := NewCustomResourceDefinitionHandler( &versionDiscoveryHandler{}, &groupDiscoveryHandler{}, crdInformer, http.HandlerFunc(func(http.ResponseWriter, *http.Request) {}),
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Apr 13 15:27:39 UTC 2023 - 34.6K bytes - Viewed (0)