- Sort Score
- Result 10 results
- Languages All
Results 41 - 50 of 482 for clientLeft (0.12 sec)
-
pkg/controller/nodeipam/ipam/range_allocator_test.go
fakeNodeHandler: &testutil.FakeNodeHandler{ Existing: []*v1.Node{ { ObjectMeta: metav1.ObjectMeta{ Name: "node0", }, }, }, Clientset: fake.NewSimpleClientset(), }, allocatorParams: CIDRAllocatorParams{ ClusterCIDRs: func() []*net.IPNet { _, clusterCIDRv4, _ := netutils.ParseCIDRSloppy("10.10.0.0/16") return []*net.IPNet{clusterCIDRv4}
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Apr 24 10:06:15 UTC 2024 - 25.2K bytes - Viewed (0) -
pkg/adsc/util.go
if err != nil { return nil, err } clientCert, err := tls.X509KeyPair(key.CertificateChain, key.PrivateKey) if err != nil { return nil, err } return &clientCert, nil } } if config.CertDir != "" { return func(requestInfo *tls.CertificateRequestInfo) (*tls.Certificate, error) { certName := config.CertDir + "/cert-chain.pem" clientCert, err := tls.LoadX509KeyPair(certName, config.CertDir+"/key.pem")
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Sep 21 15:51:28 UTC 2022 - 2K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/util/webhook/webhook_test.go
}, { test: "client does not trust server", clientCert: clientCert, clientKey: clientKey, serverCert: serverCert, serverKey: serverKey, errRegex: errSignedByUnknownCA, }, { test: "server does not trust client", clientCert: clientCert, clientKey: clientKey, clientCA: badCACert, serverCert: serverCert, serverKey: serverKey, serverCA: caCert,
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Jun 29 15:48:39 UTC 2023 - 25.8K bytes - Viewed (0) -
pkg/volume/util/resize_util.go
pvc *v1.PersistentVolumeClaim, newSize resource.Quantity, kubeClient clientset.Interface) (*v1.PersistentVolumeClaim, error) { return MarkFSResizeFinished(pvc, newSize, kubeClient) } // MarkFSResizeFinished marks file system resizing as done func MarkFSResizeFinished( pvc *v1.PersistentVolumeClaim, newSize resource.Quantity, kubeClient clientset.Interface) (*v1.PersistentVolumeClaim, error) { newPVC := pvc.DeepCopy()
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Jul 17 19:30:35 UTC 2023 - 14.8K bytes - Viewed (0) -
pilot/pkg/serviceregistry/kube/controller/network_test.go
IP: "2.3.4.6", Ports: []corev1.PortStatus{{Port: 15443, Protocol: corev1.ProtocolTCP}}, }}}}, } clienttest.Wrap(t, c.services).CreateOrUpdate(svc) } func removeLabeledServiceGateway(t *testing.T, c *FakeController) { clienttest.Wrap(t, c.services).Delete("istio-labeled-gw", "arbitrary-ns") } // creates a gateway that exposes 2 ports that are valid auto-passthrough ports
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Apr 18 19:09:43 UTC 2024 - 10.7K bytes - Viewed (0) -
pilot/pkg/config/kube/ingress/status_test.go
return res } } func TestStatusController(t *testing.T) { statusLog.SetOutputLevel(istiolog.DebugLevel) c := makeStatusSyncer(t, "istio-ingress") ing := clienttest.Wrap(t, c.ingresses) svc := clienttest.Wrap(t, c.services) ingc := clienttest.Wrap(t, c.ingressClasses) ing.Create(&knetworking.Ingress{ ObjectMeta: metav1.ObjectMeta{ Name: "ingress", Namespace: "default",
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Feb 28 16:41:38 UTC 2024 - 5.8K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/server/egressselector/config_test.go
url: "https://127.0.0.1:8131" tlsConfig: caBundle: "/etc/srv/kubernetes/pki/konnectivity-server/ca.crt" clientKey: "/etc/srv/kubernetes/pki/konnectivity-server/client.key" clientCert: "/etc/srv/kubernetes/pki/konnectivity-server/client.crt" - name: "controlplane" connection: proxyProtocol: "HTTPConnect" transport: tcp: url: "https://127.0.0.1:8132" tlsConfig:
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Sep 05 02:24:38 UTC 2023 - 15.1K bytes - Viewed (0) -
pkg/controlplane/controller/systemnamespaces/system_namespaces_controller_test.go
&v1.Namespace{ ObjectMeta: metav1.ObjectMeta{ Name: ns, Namespace: "", }, }, ) } clientset := fake.NewSimpleClientset(objs...) informerFactory := informers.NewSharedInformerFactory(clientset, 0) namespaceInformer := informerFactory.Core().V1().Namespaces() for _, obj := range objs { namespaceInformer.Informer().GetIndexer().Add(obj) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat Apr 27 12:19:56 UTC 2024 - 4.3K bytes - Viewed (0) -
cmd/kubeadm/app/util/apiclient/clientbacked_dryrun.go
if err != nil { fmt.Printf("error after decode: %v %v\n", unstructuredList, err) return true, nil, err } return true, newObj, err } // Client gets the backing clientset.Interface func (clg *ClientBackedDryRunGetter) Client() clientset.Interface { return clg.client } // decodeUnstructuredIntoAPIObject converts the *unversioned.Unversioned object returned from the dynamic client
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sun Apr 16 10:29:45 UTC 2023 - 4.8K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/internal/tls/ClientAuthTest.kt
.build() clientCert = HeldCertificate.Builder() .signedBy(clientIntermediateCa) .serialNumber(4L) .commonName("Jethro Willis") .addSubjectAlternativeName("jethrowillis.com") .build() } @Test fun clientAuthForWants() { val client = buildClient(clientCert, clientIntermediateCa.certificate)
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Sun Jan 14 10:20:09 UTC 2024 - 12.5K bytes - Viewed (0)