- Sort Score
- Result 10 results
- Languages All
Results 1 - 6 of 6 for NewUnsecuredEtcd3TestClientServer (0.45 sec)
-
pkg/controlplane/reconcilers/lease_test.go
for _, ip := range keys { if err := f.UpdateLease(ip); err != nil { return err } } return nil } func TestLeaseEndpointReconciler(t *testing.T) { 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: Thu Aug 24 09:23:05 UTC 2023 - 28.7K 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) -
staging/src/k8s.io/apiserver/pkg/registry/generic/registry/dryrun_test.go
"k8s.io/apiserver/pkg/storage/storagebackend/factory" ) func NewDryRunnableTestStorage(t *testing.T) (DryRunnableStorage, func()) { server, sc := etcd3testing.NewUnsecuredEtcd3TestClientServer(t) sc.Codec = apitesting.TestStorageCodec(codecs, examplev1.SchemeGroupVersion) s, destroy, err := factory.Create(*sc.ForResource(schema.GroupResource{Resource: "pods"}), nil, nil, "") if err != nil {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Aug 24 09:23:05 UTC 2023 - 9.9K 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/apiextensions-apiserver/pkg/apiserver/customresource_handler_test.go
informers := informers.NewSharedInformerFactory(fake.NewSimpleClientset(), 0) crdInformer := informers.Apiextensions().V1().CustomResourceDefinitions() server, storageConfig := etcd3testing.NewUnsecuredEtcd3TestClientServer(t) defer server.Terminate(t) crd := multiVersionFixture.DeepCopy() // Create a context with metav1.NamespaceNone as the namespace since multiVersionFixture // is a cluster scoped CRD.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Apr 13 15:27:39 UTC 2023 - 34.6K bytes - Viewed (0)