Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 28 for ForResource (0.33 sec)

  1. staging/src/k8s.io/apiserver/pkg/storage/storagebackend/config.go

    type ConfigForResource struct {
    	// Config is the resource-independent configuration
    	Config
    
    	// GroupResource is the relevant one
    	GroupResource schema.GroupResource
    }
    
    // ForResource specializes to the given resource
    func (config *Config) ForResource(resource schema.GroupResource) *ConfigForResource {
    	return &ConfigForResource{
    		Config:        *config,
    		GroupResource: resource,
    	}
    }
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Jun 07 17:57:37 UTC 2024
    - 4.3K bytes
    - Viewed (0)
  2. staging/src/k8s.io/apiextensions-apiserver/examples/client-go/pkg/client/informers/externalversions/factory.go

    	// WaitForCacheSync blocks until all started informers' caches were synced
    	// or the stop channel gets closed.
    	WaitForCacheSync(stopCh <-chan struct{}) map[reflect.Type]bool
    
    	// ForResource gives generic access to a shared informer of the matching type.
    	ForResource(resource schema.GroupVersionResource) (GenericInformer, error)
    
    	// InformerFor returns the SharedIndexInformer for obj using an internal
    	// client.
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Jul 18 18:31:26 UTC 2023
    - 8.9K bytes
    - Viewed (0)
  3. staging/src/k8s.io/apiextensions-apiserver/pkg/client/informers/externalversions/factory.go

    	// WaitForCacheSync blocks until all started informers' caches were synced
    	// or the stop channel gets closed.
    	WaitForCacheSync(stopCh <-chan struct{}) map[reflect.Type]bool
    
    	// ForResource gives generic access to a shared informer of the matching type.
    	ForResource(resource schema.GroupVersionResource) (GenericInformer, error)
    
    	// InformerFor returns the SharedIndexInformer for obj using an internal
    	// client.
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Jul 18 18:31:26 UTC 2023
    - 9K bytes
    - Viewed (0)
  4. pkg/registry/core/service/allocator/storage/storage_test.go

    	etcdStorage, server := registrytest.NewEtcdStorage(t, "")
    	mem := allocator.NewAllocationMap(100, "rangeSpecValue")
    	etcd, err := NewEtcd(mem, "/ranges/serviceips", etcdStorage.ForResource(api.Resource("serviceipallocations")))
    	if err != nil {
    		t.Fatalf("unexpected error creating etcd: %v", err)
    	}
    	return etcd, server, mem, &etcdStorage.Config
    }
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Sep 01 20:54:26 UTC 2021
    - 4.8K bytes
    - Viewed (0)
  5. staging/src/k8s.io/apiserver/pkg/storage/storagebackend/factory/tls_test.go

    			CertFile:       certFile,
    			KeyFile:        keyFile,
    			TrustedCAFile:  caFile,
    			TracerProvider: noopoteltrace.NewTracerProvider(),
    		},
    		Codec: codec,
    	}
    	storage, destroyFunc, err := newETCD3Storage(*cfg.ForResource(schema.GroupResource{Resource: "pods"}), nil, nil, "")
    	defer destroyFunc()
    	if err != nil {
    		t.Fatal(err)
    	}
    	err = storage.Create(context.TODO(), "/abc", &example.Pod{}, nil, 0)
    	if err != nil {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Jun 07 17:57:37 UTC 2024
    - 3.4K bytes
    - Viewed (0)
  6. staging/src/k8s.io/apiserver/pkg/reconcilers/peer_endpoint_lease_test.go

    	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)
    
    	tests := []struct {
    		testName     string
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Apr 24 18:25:29 UTC 2024
    - 8.7K bytes
    - Viewed (0)
  7. pkg/registry/core/rest/storage_core.go

    			// TODO etcdallocator package to return a storage interface via the storageFactory
    			etcd, err := serviceallocator.NewEtcd(mem, "/ranges/serviceips", serviceStorageConfig.ForResource(api.Resource("serviceipallocations")))
    			if err != nil {
    				return nil, err
    			}
    			registries.clusterIP = etcd
    			return etcd, nil
    		})
    		if err != nil {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Oct 31 21:05:05 UTC 2023
    - 19.1K bytes
    - Viewed (0)
  8. pkg/controlplane/reconcilers/lease_test.go

    	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)
    
    	reconcileTests := []struct {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Aug 24 09:23:05 UTC 2023
    - 28.7K bytes
    - Viewed (0)
  9. pkg/controller/resourcequota/resource_quota_monitor.go

    			}
    			event := &event{
    				eventType: deleteEvent,
    				obj:       obj,
    				gvr:       resource,
    			}
    			qm.resourceChanges.Add(event)
    		},
    	}
    	shared, err := qm.informerFactory.ForResource(resource)
    	if err == nil {
    		logger.V(4).Info("QuotaMonitor using a shared informer", "resource", resource.String())
    		shared.Informer().AddEventHandlerWithResyncPeriod(handlers, qm.resyncPeriod())
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat May 04 18:33:12 UTC 2024
    - 11.6K bytes
    - Viewed (0)
  10. pkg/registry/core/service/ipallocator/storage/storage_test.go

    	_, cidr, err := netutils.ParseCIDRSloppy("192.168.1.0/24")
    	if err != nil {
    		t.Fatal(err)
    	}
    
    	var backing allocator.Interface
    	configForAllocations := etcdStorage.ForResource(api.Resource("serviceipallocations"))
    	storage, err := ipallocator.New(cidr, func(max int, rangeSpec string, offset int) (allocator.Interface, error) {
    		mem := allocator.NewAllocationMapWithOffset(max, rangeSpec, offset)
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Aug 24 09:23:05 UTC 2023
    - 5.9K bytes
    - Viewed (0)
Back to top