Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 6 of 6 for NewUnsecuredEtcd3TestClientServer (0.35 sec)

  1. 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)
  2. 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)
  3. 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)
  4. 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)
  5. 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)
  6. 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)
Back to top