- Sort Score
- Result 10 results
- Languages All
Results 1 - 6 of 6 for NewUnsecuredEtcd3TestClientServer (0.35 sec)
-
staging/src/k8s.io/apiserver/pkg/reconcilers/peer_endpoint_lease_test.go
featuregatetesting.SetFeatureGateDuringTest(t, utilfeature.DefaultFeatureGate, features.StorageVersionAPI, true) server, sc := etcd3testing.NewUnsecuredEtcd3TestClientServer(t) t.Cleanup(func() { server.Terminate(t) }) newFunc := func() runtime.Object { return &corev1.Endpoints{} } newListFunc := func() runtime.Object { return &corev1.EndpointsList{} }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Apr 24 18:25:29 UTC 2024 - 8.7K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/storage/util_test.go
func TestGetCurrentResourceVersionFromStorage(t *testing.T) { // test data newEtcdTestStorage := func(t *testing.T, prefix string) (*etcd3testing.EtcdTestServer, storage.Interface) { server, _ := etcd3testing.NewUnsecuredEtcd3TestClientServer(t)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Mar 11 12:07:39 UTC 2024 - 6.3K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/util/peerproxy/peerproxy_handler_test.go
t.Fatal(err) } } }) } } func newFakePeerEndpointReconciler(t *testing.T) reconcilers.PeerEndpointLeaseReconciler { server, sc := etcd3testing.NewUnsecuredEtcd3TestClientServer(t) t.Cleanup(func() { server.Terminate(t) }) scheme := runtime.NewScheme() metav1.AddToGroupVersion(scheme, metav1.SchemeGroupVersion) //utilruntime.Must(core.AddToScheme(scheme))
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Apr 24 18:25:29 UTC 2024 - 10.8K bytes - Viewed (0) -
pkg/controlplane/instance_test.go
) // setUp is a convenience function for setting up for (most) tests. func setUp(t *testing.T) (*etcd3testing.EtcdTestServer, Config, *assert.Assertions) { server, storageConfig := etcd3testing.NewUnsecuredEtcd3TestClientServer(t) config := &Config{ ControlPlane: controlplaneapiserver.Config{ Generic: genericapiserver.NewConfig(legacyscheme.Codecs), Extra: controlplaneapiserver.Extra{
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Jun 03 11:50:04 UTC 2024 - 21.5K bytes - Viewed (0) -
staging/src/k8s.io/apiextensions-apiserver/pkg/registry/customresource/etcd_test.go
) func newStorage(t *testing.T) (customresource.CustomResourceStorage, *etcd3testing.EtcdTestServer) { server, etcdStorage := etcd3testing.NewUnsecuredEtcd3TestClientServer(t) etcdStorage.Codec = unstructured.UnstructuredJSONScheme groupResource := schema.GroupResource{Group: "mygroup.example.com", Resource: "noxus"}
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/registry/generic/registry/store_test.go
} }) } } func newTestGenericStoreRegistry(t *testing.T, scheme *runtime.Scheme, hasCacheEnabled bool) (factory.DestroyFunc, *Store) { podPrefix := "/pods" server, sc := etcd3testing.NewUnsecuredEtcd3TestClientServer(t) strategy := &testRESTStrategy{scheme, names.SimpleNameGenerator, true, false, true} newFunc := func() runtime.Object { return &example.Pod{} }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jun 12 10:12:02 UTC 2024 - 101.8K bytes - Viewed (0)