Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 6 of 6 for NewRawStorage (0.21 sec)

  1. staging/src/k8s.io/apiserver/pkg/registry/generic/storage_decorator.go

    	return NewRawStorage(config, newFunc, newListFunc, resourcePrefix)
    }
    
    // NewRawStorage creates the low level kv storage. This is a work-around for current
    // two layer of same storage interface.
    // TODO: Once cacher is enabled on all registries (event registry is special), we will remove this method.
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Aug 24 09:23:05 UTC 2023
    - 2.2K bytes
    - Viewed (0)
  2. pkg/registry/core/pod/rest/log_test.go

    	"k8s.io/kubernetes/pkg/registry/registrytest"
    )
    
    func TestPodLogValidates(t *testing.T) {
    	config, server := registrytest.NewEtcdStorage(t, "")
    	defer server.Terminate(t)
    	s, destroyFunc, err := generic.NewRawStorage(config, nil, nil, "")
    	if err != nil {
    		t.Fatalf("Unexpected error: %v", err)
    	}
    	defer destroyFunc()
    	store := &genericregistry.Store{
    		Storage: genericregistry.DryRunnableStorage{Storage: s},
    	}
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Aug 24 09:23:05 UTC 2023
    - 1.6K bytes
    - Viewed (0)
  3. staging/src/k8s.io/apiserver/pkg/registry/generic/registry/storage_factory.go

    		newListFunc func() runtime.Object,
    		getAttrsFunc storage.AttrFunc,
    		triggerFuncs storage.IndexerFuncs,
    		indexers *cache.Indexers) (storage.Interface, factory.DestroyFunc, error) {
    
    		s, d, err := generic.NewRawStorage(storageConfig, newFunc, newListFunc, resourcePrefix)
    		if err != nil {
    			return s, d, err
    		}
    		if klogV := klog.V(5); klogV.Enabled() {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Aug 24 09:23:05 UTC 2023
    - 2.9K bytes
    - Viewed (0)
  4. pkg/registry/core/service/ipallocator/storage/storage_test.go

    		if err != nil {
    			return nil, err
    		}
    		return etcd, nil
    	})
    	if err != nil {
    		t.Fatalf("unexpected error creating etcd: %v", err)
    	}
    	s, d, err := generic.NewRawStorage(configForAllocations, nil, nil, "")
    	if err != nil {
    		t.Fatalf("Couldn't create storage: %v", err)
    	}
    	destroyFunc := func() {
    		d()
    		server.Terminate(t)
    	}
    	return server, storage, backing, s, destroyFunc
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Aug 24 09:23:05 UTC 2023
    - 5.9K bytes
    - Viewed (0)
  5. pkg/registry/core/service/allocator/storage/storage.go

    	// note that newFunc, newListFunc and resourcePrefix
    	// can be left blank unless the storage.Watch method is used
    	storage, d, err := generic.NewRawStorage(config, nil, nil, "")
    	if err != nil {
    		return nil, err
    	}
    
    	var once sync.Once
    	return &Etcd{
    		alloc:     alloc,
    		storage:   storage,
    		baseKey:   baseKey,
    		resource:  config.GroupResource,
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Aug 24 09:23:05 UTC 2023
    - 6.5K bytes
    - Viewed (0)
  6. pkg/registry/core/service/portallocator/storage/storage_test.go

    		if err != nil {
    			return nil, err
    		}
    		return etcd, nil
    	})
    	if err != nil {
    		t.Fatalf("unexpected error creating etcd: %v", err)
    	}
    	s, d, err := generic.NewRawStorage(configForAllocations, nil, nil, "")
    	if err != nil {
    		t.Fatalf("Couldn't create storage: %v", err)
    	}
    	destroyFunc := func() {
    		d()
    		server.Terminate(t)
    	}
    	return server, storage, backing, s, destroyFunc
    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