- Sort Score
- Result 10 results
- Languages All
Results 21 - 30 of 150 for newFunc (0.18 sec)
-
pkg/registry/resource/resourceclass/storage/storage.go
*genericregistry.Store } // NewREST returns a RESTStorage object that will work against ResourceClass. func NewREST(optsGetter generic.RESTOptionsGetter) (*REST, error) { store := &genericregistry.Store{ NewFunc: func() runtime.Object { return &resource.ResourceClass{} }, NewListFunc: func() runtime.Object { return &resource.ResourceClassList{} },
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Nov 18 10:11:16 UTC 2022 - 2K bytes - Viewed (0) -
pkg/registry/node/runtimeclass/storage/storage.go
*genericregistry.Store } // NewREST returns a RESTStorage object that will work against runtime classes. func NewREST(optsGetter generic.RESTOptionsGetter) (*REST, error) { store := &genericregistry.Store{ NewFunc: func() runtime.Object { return &node.RuntimeClass{} }, NewListFunc: func() runtime.Object { return &node.RuntimeClassList{} }, ObjectNameFunc: func(obj runtime.Object) (string, error) {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Nov 18 09:21:13 UTC 2022 - 2K bytes - Viewed (0) -
staging/src/k8s.io/apiextensions-apiserver/examples/client-go/pkg/client/informers/externalversions/factory.go
} return res } // InformerFor returns the SharedIndexInformer for obj using an internal // client. func (f *sharedInformerFactory) InformerFor(obj runtime.Object, newFunc internalinterfaces.NewInformerFunc) cache.SharedIndexInformer { f.lock.Lock() defer f.lock.Unlock() informerType := reflect.TypeOf(obj) informer, exists := f.informers[informerType] if exists {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jul 18 18:31:26 UTC 2023 - 8.9K bytes - Viewed (0) -
staging/src/k8s.io/apiextensions-apiserver/pkg/client/informers/externalversions/factory.go
} return res } // InformerFor returns the SharedIndexInformer for obj using an internal // client. func (f *sharedInformerFactory) InformerFor(obj runtime.Object, newFunc internalinterfaces.NewInformerFunc) cache.SharedIndexInformer { f.lock.Lock() defer f.lock.Unlock() informerType := reflect.TypeOf(obj) informer, exists := f.informers[informerType] if exists {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jul 18 18:31:26 UTC 2023 - 9K bytes - Viewed (0) -
pkg/registry/certificates/clustertrustbundle/storage/storage.go
var _ genericregistry.GenericStore = &REST{} // NewREST returns a RESTStorage object for ClusterTrustBundle objects. func NewREST(optsGetter generic.RESTOptionsGetter) (*REST, error) { store := &genericregistry.Store{ NewFunc: func() runtime.Object { return &api.ClusterTrustBundle{} }, NewListFunc: func() runtime.Object { return &api.ClusterTrustBundleList{} }, DefaultQualifiedResource: api.Resource("clustertrustbundles"),
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Mar 16 03:10:18 UTC 2023 - 2.6K bytes - Viewed (0) -
pkg/registry/core/event/storage/storage.go
*genericregistry.Store } // NewREST returns a RESTStorage object that will work against events. func NewREST(optsGetter generic.RESTOptionsGetter, ttl uint64) (*REST, error) { store := &genericregistry.Store{ NewFunc: func() runtime.Object { return &api.Event{} }, NewListFunc: func() runtime.Object { return &api.EventList{} }, PredicateFunc: event.Matcher, TTLFunc: func(runtime.Object, uint64, bool) (uint64, error) {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Nov 18 09:21:13 UTC 2022 - 2.3K bytes - Viewed (0) -
pkg/controlplane/reconcilers/lease_test.go
t.Cleanup(func() { server.Terminate(t) }) 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 {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Aug 24 09:23:05 UTC 2023 - 28.7K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/storage/etcd3/watcher_test.go
enableWatchList bool expectedErr error }{ { name: "no newFunc provided", setupFn: func(opts *setupOptions) { opts.newFunc = nil }, requestOpts: storage.ListOptions{ProgressNotify: true}, expectedErr: apierrors.NewInternalError(errors.New("progressNotify for watch is unsupported by the etcd storage because no newFunc was provided")), }, } for _, scenario := range scenarios {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Apr 24 18:25:29 UTC 2024 - 12.3K bytes - Viewed (0) -
pkg/registry/storage/csinode/storage/storage.go
*genericregistry.Store } // NewStorage returns a RESTStorage object that will work against CSINodes func NewStorage(optsGetter generic.RESTOptionsGetter) (*CSINodeStorage, error) { store := &genericregistry.Store{ NewFunc: func() runtime.Object { return &storageapi.CSINode{} }, NewListFunc: func() runtime.Object { return &storageapi.CSINodeList{} }, DefaultQualifiedResource: storageapi.Resource("csinodes"),
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Nov 18 09:21:13 UTC 2022 - 2.1K bytes - Viewed (0) -
pkg/registry/storage/storageclass/storage/storage.go
*genericregistry.Store } // NewREST returns a RESTStorage object that will work against storage classes. func NewREST(optsGetter generic.RESTOptionsGetter) (*REST, error) { store := &genericregistry.Store{ NewFunc: func() runtime.Object { return &storageapi.StorageClass{} }, NewListFunc: func() runtime.Object { return &storageapi.StorageClassList{} },
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Nov 18 09:21:13 UTC 2022 - 2.3K bytes - Viewed (0)