- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 61 for NewListFunc (0.13 sec)
-
staging/src/k8s.io/apiserver/pkg/registry/generic/storage_decorator.go
resourcePrefix string, keyFunc func(obj runtime.Object) (string, error), newFunc func() runtime.Object, newListFunc func() runtime.Object, getAttrsFunc storage.AttrFunc, trigger storage.IndexerFuncs, indexers *cache.Indexers) (storage.Interface, factory.DestroyFunc, error) { return NewRawStorage(config, newFunc, newListFunc, resourcePrefix) } // NewRawStorage creates the low level kv storage. This is a work-around for current
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Aug 24 09:23:05 UTC 2023 - 2.2K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/storage/cacher/lister_watcher.go
resourcePrefix: resourcePrefix, newListFunc: newListFunc, contextMetadata: contextMetadata, } } // Implements cache.ListerWatcher interface. func (lw *listerWatcher) List(options metav1.ListOptions) (runtime.Object, error) { list := lw.newListFunc() pred := storage.SelectionPredicate{ Label: labels.Everything(), Field: fields.Everything(), Limit: options.Limit, Continue: options.Continue, }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Mar 04 11:51:06 UTC 2024 - 2.7K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/registry/generic/registry/storage_factory.go
keyFunc func(obj runtime.Object) (string, error), newFunc func() runtime.Object, newListFunc func() runtime.Object, getAttrsFunc storage.AttrFunc, triggerFuncs storage.IndexerFuncs, indexers *cache.Indexers) (storage.Interface, factory.DestroyFunc, error) { s, d, err := generic.NewRawStorage(storageConfig, newFunc, newListFunc, resourcePrefix) if err != nil { return s, d, err }
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/storage/util.go
func GetCurrentResourceVersionFromStorage(ctx context.Context, storage Interface, newListFunc func() runtime.Object, resourcePrefix, objectType string) (uint64, error) { if storage == nil { return 0, fmt.Errorf("storage wasn't provided for %s", objectType) } if newListFunc == nil { return 0, fmt.Errorf("newListFunction wasn't provided for %s", objectType) } emptyList := newListFunc() pred := SelectionPredicate{ Label: labels.Everything(),
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Apr 18 08:05:06 UTC 2024 - 4.6K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/reconcilers/peer_endpoint_lease_test.go
newFunc := func() runtime.Object { return &corev1.Endpoints{} } newListFunc := func() runtime.Object { return &corev1.EndpointsList{} } sc.Codec = apitesting.TestStorageCodec(codecs, corev1.SchemeGroupVersion) s, dFunc, err := factory.Create(*sc.ForResource(schema.GroupResource{Resource: "endpoints"}), newFunc, newListFunc, "") if err != nil { t.Fatalf("Error creating storage: %v", err) } t.Cleanup(dFunc)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Apr 24 18:25:29 UTC 2024 - 8.7K bytes - Viewed (0) -
pkg/registry/rbac/role/storage/storage.go
func NewREST(optsGetter generic.RESTOptionsGetter) (*REST, error) { store := &genericregistry.Store{ NewFunc: func() runtime.Object { return &rbac.Role{} }, NewListFunc: func() runtime.Object { return &rbac.RoleList{} }, DefaultQualifiedResource: rbac.Resource("roles"), SingularQualifiedResource: rbac.Resource("role"), CreateStrategy: role.Strategy,
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Nov 18 09:21:13 UTC 2022 - 1.8K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/storage/storagebackend/factory/factory.go
func Create(c storagebackend.ConfigForResource, newFunc, newListFunc func() runtime.Object, resourcePrefix string) (storage.Interface, DestroyFunc, error) { switch c.Type { case storagebackend.StorageTypeETCD2: return nil, nil, fmt.Errorf("%s is no longer a supported storage backend", c.Type) case storagebackend.StorageTypeUnset, storagebackend.StorageTypeETCD3: return newETCD3Storage(c, newFunc, newListFunc, resourcePrefix) default:
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Aug 24 09:23:05 UTC 2023 - 3.3K bytes - Viewed (0) -
pkg/registry/core/secret/storage/storage.go
func NewREST(optsGetter generic.RESTOptionsGetter) (*REST, error) { store := &genericregistry.Store{ NewFunc: func() runtime.Object { return &api.Secret{} }, NewListFunc: func() runtime.Object { return &api.SecretList{} }, PredicateFunc: secret.Matcher, DefaultQualifiedResource: api.Resource("secrets"), SingularQualifiedResource: api.Resource("secret"),
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Feb 27 20:38:11 UTC 2023 - 2K bytes - Viewed (0) -
pkg/registry/networking/ingressclass/storage/storage.go
func NewREST(optsGetter generic.RESTOptionsGetter) (*REST, error) { store := &genericregistry.Store{ NewFunc: func() runtime.Object { return &networking.IngressClass{} }, NewListFunc: func() runtime.Object { return &networking.IngressClassList{} }, DefaultQualifiedResource: networking.Resource("ingressclasses"), SingularQualifiedResource: networking.Resource("ingressclass"),
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Nov 18 09:21:13 UTC 2022 - 2K bytes - Viewed (0) -
pkg/registry/rbac/rolebinding/storage/storage.go
func NewREST(optsGetter generic.RESTOptionsGetter) (*REST, error) { store := &genericregistry.Store{ NewFunc: func() runtime.Object { return &rbac.RoleBinding{} }, NewListFunc: func() runtime.Object { return &rbac.RoleBindingList{} }, DefaultQualifiedResource: rbac.Resource("rolebindings"), SingularQualifiedResource: rbac.Resource("rolebinding"),
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Nov 18 09:21:13 UTC 2022 - 1.9K bytes - Viewed (0)