Search Options

Results per page
Sort
Preferred Languages
Advance

Results 21 - 30 of 150 for newFunc (0.12 sec)

  1. 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)
  2. 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)
  3. 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)
  4. 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)
  5. 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)
  6. 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)
  7. 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)
  8. 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)
  9. 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)
  10. 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)
Back to top