- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 19 for NewListFunc (0.32 sec)
-
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/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/storage/volumeattributesclass/storage/storage.go
func NewREST(optsGetter generic.RESTOptionsGetter) (*REST, error) { store := &genericregistry.Store{ NewFunc: func() runtime.Object { return &storageapi.VolumeAttributesClass{} }, NewListFunc: func() runtime.Object { return &storageapi.VolumeAttributesClassList{} }, DefaultQualifiedResource: storageapi.Resource("volumeattributesclasses"),
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Oct 31 03:18:56 UTC 2023 - 2.4K bytes - Viewed (0) -
pkg/registry/resource/resourceclaimparameters/storage/storage.go
func NewREST(optsGetter generic.RESTOptionsGetter) (*REST, error) { store := &genericregistry.Store{ NewFunc: func() runtime.Object { return &resource.ResourceClaimParameters{} }, NewListFunc: func() runtime.Object { return &resource.ResourceClaimParametersList{} }, PredicateFunc: resourceclaimparameters.Match, DefaultQualifiedResource: resource.Resource("resourceclaimparameters"),
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Mar 07 15:15:31 UTC 2024 - 2.2K bytes - Viewed (0) -
pkg/registry/resource/resourceslice/storage/storage.go
func NewREST(optsGetter generic.RESTOptionsGetter) (*REST, error) { store := &genericregistry.Store{ NewFunc: func() runtime.Object { return &resource.ResourceSlice{} }, NewListFunc: func() runtime.Object { return &resource.ResourceSliceList{} }, PredicateFunc: resourceslice.Match, DefaultQualifiedResource: resource.Resource("resourceslices"),
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Mar 07 21:22:55 UTC 2024 - 2.2K bytes - Viewed (0) -
pkg/registry/core/serviceaccount/storage/storage.go
store := &genericregistry.Store{ NewFunc: func() runtime.Object { return &api.ServiceAccount{} }, NewListFunc: func() runtime.Object { return &api.ServiceAccountList{} }, DefaultQualifiedResource: api.Resource("serviceaccounts"), SingularQualifiedResource: api.Resource("serviceaccount"),
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Oct 30 21:15:10 UTC 2023 - 3K bytes - Viewed (0) -
pkg/registry/resource/resourceclassparameters/storage/storage.go
func NewREST(optsGetter generic.RESTOptionsGetter) (*REST, error) { store := &genericregistry.Store{ NewFunc: func() runtime.Object { return &resource.ResourceClassParameters{} }, NewListFunc: func() runtime.Object { return &resource.ResourceClassParametersList{} }, PredicateFunc: resourceclassparameters.Match, DefaultQualifiedResource: resource.Resource("resourceclassparameters"),
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Mar 07 15:15:31 UTC 2024 - 2.2K bytes - Viewed (0) -
pkg/registry/networking/servicecidr/storage/storage.go
func NewREST(optsGetter generic.RESTOptionsGetter) (*REST, *StatusREST, error) { store := &genericregistry.Store{ NewFunc: func() runtime.Object { return &networking.ServiceCIDR{} }, NewListFunc: func() runtime.Object { return &networking.ServiceCIDRList{} }, DefaultQualifiedResource: networking.Resource("servicecidrs"), SingularQualifiedResource: networking.Resource("servicecidr"),
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Oct 31 21:05:04 UTC 2023 - 3.9K bytes - Viewed (0) -
pkg/registry/storagemigration/storagemigration/storage/storage.go
func NewREST(optsGetter generic.RESTOptionsGetter) (*REST, *StatusREST, error) { store := &genericregistry.Store{ NewFunc: func() runtime.Object { return &svmapi.StorageVersionMigration{} }, NewListFunc: func() runtime.Object { return &svmapi.StorageVersionMigrationList{} }, ObjectNameFunc: func(obj runtime.Object) (string, error) { return obj.(*svmapi.StorageVersionMigration).Name, nil },
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Mar 08 04:18:56 UTC 2024 - 4.2K bytes - Viewed (0)