- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 28 for makeClient (0.54 sec)
-
okhttp/src/test/java/okhttp3/CallHandshakeTest.kt
// We are avoiding making guarantees on ordering of secondary Platforms. platform.assumeNotConscrypt() platform.assumeNotBouncyCastle() val client = makeClient(ConnectionSpec.RESTRICTED_TLS, TlsVersion.TLS_1_2) val handshake = makeRequest(client) assertThat(handshake.cipherSuite).isIn(*expectedModernTls12CipherSuites.toTypedArray()) // Probably something like
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Sat Jan 20 10:30:28 UTC 2024 - 11.2K bytes - Viewed (0) -
pilot/pkg/config/kube/crdclient/client_test.go
"istio.io/istio/pkg/kube/kubetypes" "istio.io/istio/pkg/slices" "istio.io/istio/pkg/test" "istio.io/istio/pkg/test/util/assert" "istio.io/istio/pkg/test/util/retry" ) func makeClient(t *testing.T, schemas collection.Schemas, f kubetypes.DynamicObjectFilter) (model.ConfigStoreController, kube.CLIClient) { fake := kube.NewFakeClient() if f != nil { kube.SetObjectFilter(fake, f) }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri May 10 02:58:52 UTC 2024 - 14.1K bytes - Viewed (0) -
pkg/controller/statefulset/stateful_pod_control_test.go
set := newStatefulSet(3) pod := newStatefulSetPod(set, 0) fakeClient := &fake.Clientset{} claimIndexer := cache.NewIndexer(cache.MetaNamespaceKeyFunc, cache.Indexers{cache.NamespaceIndex: cache.MetaNamespaceIndexFunc}) claimLister := corelisters.NewPersistentVolumeClaimLister(claimIndexer) control := NewStatefulPodControl(fakeClient, nil, claimLister, recorder)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jun 05 19:06:41 UTC 2024 - 35.5K bytes - Viewed (0) -
pilot/pkg/leaderelection/k8sleaderelection/leaderelection_test.go
{ verb: "get", reaction: func(action fakeclient.Action) (handled bool, ret runtime.Object, err error) { return true, nil, errors.NewNotFound(action.(fakeclient.GetAction).GetResource().GroupResource(), action.(fakeclient.GetAction).GetName()) }, }, { verb: "create", reaction: func(action fakeclient.Action) (handled bool, ret runtime.Object, err error) {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon Jan 23 16:39:43 UTC 2023 - 42.5K bytes - Viewed (0) -
pkg/kubelet/util/manager/watch_based_manager_test.go
"github.com/stretchr/testify/assert" ) func listSecret(fakeClient clientset.Interface) listObjectFunc { return func(namespace string, opts metav1.ListOptions) (runtime.Object, error) { return fakeClient.CoreV1().Secrets(namespace).List(context.TODO(), opts) } } func watchSecret(fakeClient clientset.Interface) watchObjectFunc {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue May 09 10:05:43 UTC 2023 - 17.2K bytes - Viewed (0) -
pkg/controlplane/reconcilers/instancecount_test.go
}, } for _, test := range reconcileTests { t.Run(test.testName, func(t *testing.T) { fakeClient := fake.NewSimpleClientset(test.initialState...) epAdapter := NewEndpointsAdapter(fakeClient.CoreV1(), fakeClient.DiscoveryV1()) reconciler := NewMasterCountEndpointReconciler(test.additionalMasters+1, epAdapter)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri May 27 12:46:24 UTC 2022 - 14K bytes - Viewed (0) -
pkg/kubelet/util/manager/cache_based_manager_test.go
store.Get("ns1", "s20") store.Get("ns1", "s3") actions = fakeClient.Actions() assert.Equal(t, 3, len(actions), "unexpected actions: %#v", actions) fakeClient.ClearActions() } func TestRegisterIdempotence(t *testing.T) { fakeClient := &fake.Clientset{} fakeClock := testingclock.NewFakeClock(time.Now()) store := newSecretStore(fakeClient, fakeClock, noObjectTTL, time.Minute)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 04 06:25:43 UTC 2024 - 19.6K bytes - Viewed (0) -
pkg/registry/core/service/ipallocator/controller/repair_test.go
r.updated = alloc return r.updateErr } func TestRepair(t *testing.T) { fakeClient := fake.NewSimpleClientset() ipregistry := &mockRangeRegistry{ item: &api.RangeAllocation{Range: "192.168.1.0/24"}, } _, cidr, _ := netutils.ParseCIDRSloppy(ipregistry.item.Range) r := NewRepair(0, fakeClient.CoreV1(), fakeClient.EventsV1(), cidr, ipregistry, nil, nil) if err := r.runOnce(); err != nil { t.Fatal(err) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat Sep 30 15:46:06 UTC 2023 - 21.1K bytes - Viewed (0) -
cni/pkg/repair/repair_test.go
false, }, } for _, tt := range cases { t.Run(tt.name, func(t *testing.T) { c := &Controller{cfg: tt.config} assert.Equal(t, c.matchesFilter(tt.pod), tt.want) }) } } func fakeClient(pods ...*corev1.Pod) kube.Client { var csPods []runtime.Object for _, pod := range pods { csPods = append(csPods, pod.DeepCopy()) } return kube.NewFakeClient(csPods...) }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue Oct 24 03:31:28 UTC 2023 - 10.6K bytes - Viewed (0) -
pkg/registry/core/service/portallocator/controller/repair_test.go
r.updated = alloc return r.updateErr } func TestRepair(t *testing.T) { clearMetrics() fakeClient := fake.NewSimpleClientset() registry := &mockRangeRegistry{ item: &api.RangeAllocation{Range: "100-200"}, } pr, _ := net.ParsePortRange(registry.item.Range) r := NewRepair(0, fakeClient.CoreV1(), fakeClient.EventsV1(), *pr, registry) if err := r.runOnce(); err != nil { t.Fatal(err) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat Sep 30 15:46:06 UTC 2023 - 10.6K bytes - Viewed (0)