- Sort Score
- Result 10 results
- Languages All
Results 51 - 60 of 61 for destroyFunc (0.32 sec)
-
staging/src/k8s.io/apiextensions-apiserver/pkg/registry/customresource/etcd_test.go
defer server.Terminate(t) defer storage.CustomResource.Store.DestroyFunc() test := registrytest.New(t, storage.CustomResource.Store) cr := validNewCustomResource() cr.SetNamespace("") test.TestCreate( cr, ) } func TestGet(t *testing.T) { storage, server := newStorage(t) defer server.Terminate(t) defer storage.CustomResource.Store.DestroyFunc() test := registrytest.New(t, storage.CustomResource.Store)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Feb 28 19:06:46 UTC 2024 - 25.2K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/storage/storagebackend/factory/factory.go
"k8s.io/apiserver/pkg/storage/storagebackend" ) // DestroyFunc is to destroy any resources used by the storage returned in Create() together. type DestroyFunc func() // Create creates a storage backend based on given config. func Create(c storagebackend.ConfigForResource, newFunc, newListFunc func() runtime.Object, resourcePrefix string) (storage.Interface, DestroyFunc, error) { switch c.Type { case storagebackend.StorageTypeETCD2:
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Aug 24 09:23:05 UTC 2023 - 3.3K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/storage/storagebackend/factory/tls_test.go
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) -
staging/src/k8s.io/apiserver/pkg/storage/storagebackend/factory/etcd3.go
compactor.client.Close() delete(compactors, key) } }, nil } func newETCD3Storage(c storagebackend.ConfigForResource, newFunc, newListFunc func() runtime.Object, resourcePrefix string) (storage.Interface, DestroyFunc, error) { stopCompactor, err := startCompactorOnce(c.Transport, c.CompactionInterval) if err != nil { return nil, nil, err } client, err := newETCD3Client(c.Transport) if err != nil {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Apr 24 07:56:39 UTC 2024 - 15.1K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/registry/generic/registry/store.go
// storageVersionHash as empty in the discovery document. StorageVersioner runtime.GroupVersioner // DestroyFunc cleans up clients used by the underlying Storage; optional. // If set, DestroyFunc has to be implemented in thread-safe way and // be prepared for being called more than once. DestroyFunc func() } // Note: the rest.StandardStorage interface aggregates the common REST verbs
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Jan 19 23:22:44 UTC 2024 - 60.8K bytes - Viewed (0) -
pkg/registry/core/pod/storage/eviction_test.go
testContext := genericapirequest.WithNamespace(genericapirequest.NewContext(), metav1.NamespaceDefault) storage, _, statusStorage, server := newStorage(t) defer server.Terminate(t) defer storage.Store.DestroyFunc() pod := validNewPod() pod.Name = tc.podName pod.Labels = map[string]string{"a": "true"} pod.Spec.NodeName = "foo"
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jun 12 09:26:37 UTC 2024 - 40K bytes - Viewed (0) -
pkg/registry/core/service/storage/storage_test.go
defer server.Terminate(t) defer storage.Store.DestroyFunc() test := genericregistrytest.New(t, storage.Store).AllowCreateOnUpdate().ReturnDeletedObject() test.TestDelete(validService()) } func TestGenericGet(t *testing.T) { storage, _, server := newStorage(t, []api.IPFamily{api.IPv4Protocol}) defer server.Terminate(t) defer storage.Store.DestroyFunc()
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Apr 24 18:25:29 UTC 2024 - 440.2K bytes - Viewed (0) -
staging/src/k8s.io/apiextensions-apiserver/pkg/apiserver/customresource_handler.go
for _, crdInfo := range storageMap { for _, storage := range crdInfo.storages { // DestroyFunc have to be implemented in idempotent way, // so the potential race with r.tearDown() (being called // from a goroutine) is safe. storage.CustomResource.DestroyFunc() } } } // GetCustomResourceListerCollectionDeleter returns the ListerCollectionDeleter of // the given crd.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Feb 28 19:06:46 UTC 2024 - 52.9K bytes - Viewed (0) -
tensorflow/c/experimental/grappler/grappler_internal.h
} Status Optimize(Cluster* cluster, const GrapplerItem& item, GraphDef* optimized_graph_def) override; ~CGraphOptimizer() override { if (optimizer_.destroy_func != nullptr) { (*optimizer_.destroy_func)(c_optimizer_); } } private: TP_Optimizer optimizer_; std::string device_type_; void* c_optimizer_; };
Registered: Sun Jun 16 05:45:23 UTC 2024 - Last Modified: Wed Jun 08 08:58:23 UTC 2022 - 3.5K bytes - Viewed (0) -
tensorflow/c/experimental/grappler/grappler.h
// [Optional] // Destroy function for optimizer. If Create function is provided, destroy // function is must. void (*destroy_func)(void*); } TP_Optimizer; #define TP_OPTIMIZER_STRUCT_SIZE TF_OFFSET_OF_END(TP_Optimizer, destroy_func) typedef struct TP_OptimizerRegistrationParams { size_t struct_size; void* ext; // reserved for future use // Graph C API version.
Registered: Sun Jun 16 05:45:23 UTC 2024 - Last Modified: Wed Aug 03 18:08:43 UTC 2022 - 12.5K bytes - Viewed (0)