Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 36 for makeClient (0.15 sec)

  1. 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)
  2. 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)
  3. 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)
  4. pkg/volume/csi/csi_attacher_test.go

    			shouldFail:           true,
    		},
    	}
    
    	for i, tc := range testCases {
    		t.Run(tc.name, func(t *testing.T) {
    			fakeClient := fakeclient.NewSimpleClientset()
    			plug, tmpDir := newTestPlugin(t, fakeClient)
    			defer os.RemoveAll(tmpDir)
    
    			fakeWatcher := watch.NewRaceFreeFake()
    			fakeClient.Fake.PrependWatchReactor("volumeattachments", core.DefaultWatchReactor(fakeWatcher, nil))
    
    			attacher, err := plug.NewAttacher()
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Apr 18 12:23:16 UTC 2024
    - 58.1K bytes
    - Viewed (0)
  5. 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)
  6. pkg/controller/ttl/ttl_controller_test.go

    		},
    	}
    
    	for i, testCase := range testCases {
    		fakeClient := &fake.Clientset{}
    		ttlController := &Controller{
    			kubeClient: fakeClient,
    		}
    		err := ttlController.patchNodeWithAnnotation(context.TODO(), testCase.node, v1.ObjectTTLAnnotationKey, testCase.ttlSeconds)
    		if err != nil {
    			t.Errorf("%d: unexpected error: %v", i, err)
    			continue
    		}
    		actions := fakeClient.Actions()
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat May 04 18:33:12 UTC 2024
    - 7.1K bytes
    - Viewed (0)
  7. 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)
  8. 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)
  9. 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)
  10. pkg/controlplane/controller/kubernetesservice/controller_test.go

    		},
    	}
    	for _, test := range nonReconcileTests {
    		t.Run(test.testName, func(t *testing.T) {
    			master := Controller{}
    			fakeClient := fake.NewSimpleClientset(test.service)
    			master.client = fakeClient
    			serviceInformer := v1informers.NewServiceInformer(fakeClient, metav1.NamespaceDefault, 12*time.Hour, cache.Indexers{})
    			serviceStore := serviceInformer.GetIndexer()
    			err := serviceStore.Add(test.service)
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Jul 13 10:41:06 UTC 2023
    - 15.3K bytes
    - Viewed (0)
Back to top