- Sort Score
- Result 10 results
- Languages All
Results 1 - 6 of 6 for NewRawStorage (0.21 sec)
-
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) -
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) -
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) -
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) -
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) -
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)