Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 4 of 4 for ForResource (0.15 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/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)
  3. 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)
  4. pkg/registry/core/service/portallocator/storage/storage_test.go

    	etcdStorage, server := registrytest.NewEtcdStorage(t, "")
    
    	serviceNodePortRange := utilnet.PortRange{Base: basePortRange, Size: sizePortRange}
    	configForAllocations := etcdStorage.ForResource(api.Resource("servicenodeportallocations"))
    	var backing allocator.Interface
    	storage, err := portallocator.New(serviceNodePortRange, func(max int, rangeSpec string, offset int) (allocator.Interface, error) {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed May 08 07:15:02 UTC 2024
    - 8.1K bytes
    - Viewed (0)
Back to top