- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 24 for clientLeft (0.2 sec)
-
src/crypto/tls/handshake_client_test.go
config.Certificates = []Certificate{cert} test := &clientTest{ name: "ClientCert-RSA-RSA", args: []string{"-cipher", "AES128", "-Verify", "1"}, config: config, } runClientTestTLS10(t, test) runClientTestTLS12(t, test) test = &clientTest{ name: "ClientCert-RSA-ECDSA", args: []string{"-cipher", "ECDHE-ECDSA-AES128-SHA", "-Verify", "1"},
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu May 23 03:10:12 UTC 2024 - 88.7K bytes - Viewed (0) -
pkg/kubelet/status/status_manager_test.go
} } func verifyActions(t *testing.T, manager *manager, expectedActions []core.Action) { t.Helper() manager.consumeUpdates() actions := manager.kubeClient.(*fake.Clientset).Actions() defer manager.kubeClient.(*fake.Clientset).ClearActions() if len(actions) != len(expectedActions) { t.Fatalf("unexpected actions: %s", cmp.Diff(expectedActions, actions)) } for i := 0; i < len(actions); i++ {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu May 02 16:27:19 UTC 2024 - 68.1K bytes - Viewed (0) -
pkg/scheduler/framework/runtime/framework.go
return func(o *frameworkOptions) { o.componentConfigVersion = componentConfigVersion } } // WithClientSet sets clientSet for the scheduling frameworkImpl. func WithClientSet(clientSet clientset.Interface) Option { return func(o *frameworkOptions) { o.clientSet = clientSet } } // WithKubeConfig sets kubeConfig for the scheduling frameworkImpl. func WithKubeConfig(kubeConfig *restclient.Config) Option {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri May 17 09:07:27 UTC 2024 - 60.9K bytes - Viewed (0) -
pilot/pkg/serviceregistry/kube/controller/ambient/ambientindex_test.go
fx *xdsfake.Updater pc clienttest.TestClient[*corev1.Pod] sc clienttest.TestClient[*corev1.Service] ns clienttest.TestWriter[*corev1.Namespace] grc clienttest.TestWriter[*k8sbeta.Gateway] gwcls clienttest.TestWriter[*k8sbeta.GatewayClass] se clienttest.TestWriter[*apiv1alpha3.ServiceEntry] we clienttest.TestWriter[*apiv1alpha3.WorkloadEntry]
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed May 08 01:04:50 UTC 2024 - 70.2K bytes - Viewed (0) -
pkg/controller/replicaset/replica_set_test.go
"k8s.io/apimachinery/pkg/types" "k8s.io/apimachinery/pkg/util/sets" "k8s.io/apimachinery/pkg/util/uuid" "k8s.io/apimachinery/pkg/util/wait" "k8s.io/apimachinery/pkg/watch" "k8s.io/client-go/informers" clientset "k8s.io/client-go/kubernetes" "k8s.io/client-go/kubernetes/fake" restclient "k8s.io/client-go/rest" core "k8s.io/client-go/testing" "k8s.io/client-go/tools/cache" utiltesting "k8s.io/client-go/util/testing"
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 69.2K bytes - Viewed (0) -
pkg/scheduler/framework/plugins/dynamicresources/dynamicresources.go
return &dynamicResources{}, nil } logger := klog.FromContext(ctx) pl := &dynamicResources{ enabled: true, fh: fh, clientset: fh.ClientSet(), claimLister: fh.SharedInformerFactory().Resource().V1alpha2().ResourceClaims().Lister(), classLister: fh.SharedInformerFactory().Resource().V1alpha2().ResourceClasses().Lister(),
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu May 30 15:22:37 UTC 2024 - 75.9K bytes - Viewed (0) -
pilot/pkg/serviceregistry/kube/controller/controller_test.go
"istio.io/istio/pkg/config/labels" "istio.io/istio/pkg/config/mesh" "istio.io/istio/pkg/config/protocol" "istio.io/istio/pkg/config/visibility" kubelib "istio.io/istio/pkg/kube" "istio.io/istio/pkg/kube/kclient/clienttest" "istio.io/istio/pkg/network" "istio.io/istio/pkg/test" "istio.io/istio/pkg/test/util/assert" "istio.io/istio/pkg/test/util/retry" "istio.io/istio/pkg/util/sets" ) const ( testService = "test" )
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu May 23 21:07:03 UTC 2024 - 85K bytes - Viewed (0) -
pilot/pkg/networking/core/cluster_tls_test.go
tlsContext *tls.UpstreamTlsContext err error } // TestBuildUpstreamClusterTLSContext tests the buildUpstreamClusterTLSContext function func TestBuildUpstreamClusterTLSContext(t *testing.T) { clientCert := "/path/to/cert" rootCert := "path/to/cacert" clientKey := "/path/to/key" credentialName := "some-fake-credential" testCases := []struct { name string
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon May 06 03:53:05 UTC 2024 - 60.9K bytes - Viewed (0) -
cmd/kubelet/app/server.go
"k8s.io/apimachinery/pkg/util/validation/field" "k8s.io/apimachinery/pkg/util/wait" genericapiserver "k8s.io/apiserver/pkg/server" "k8s.io/apiserver/pkg/server/healthz" utilfeature "k8s.io/apiserver/pkg/util/feature" clientset "k8s.io/client-go/kubernetes" v1core "k8s.io/client-go/kubernetes/typed/core/v1" restclient "k8s.io/client-go/rest" "k8s.io/client-go/tools/clientcmd" "k8s.io/client-go/tools/record"
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Jun 07 00:05:34 UTC 2024 - 53.9K bytes - Viewed (0) -
pkg/kubelet/volumemanager/reconciler/reconciler_test.go
Factor: 3, Jitter: 0, Steps: 6, } return wait.ExponentialBackoff(backoff, fn) } func createTestClient(attachedVolumes ...v1.AttachedVolume) *fake.Clientset { fakeClient := &fake.Clientset{} if len(attachedVolumes) == 0 { attachedVolumes = append(attachedVolumes, v1.AttachedVolume{ Name: "fake-plugin/fake-device1", DevicePath: "fake/path", }) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Apr 09 07:34:33 UTC 2024 - 75.4K bytes - Viewed (0)