Search Options

Results per page
Sort
Preferred Languages
Advance

Results 41 - 49 of 49 for fakeclient (0.18 sec)

  1. pkg/kube/client.go

    			return
    		}
    
    		if meta.GetName() == "" && meta.GetGenerateName() != "" {
    			meta.SetName(names.SimpleNameGenerator.GenerateName(meta.GetGenerateName()))
    		}
    
    		return
    	}
    	for _, fc := range []fakeClient{
    		c.kube.(*fake.Clientset),
    		c.istio.(*istiofake.Clientset),
    		c.gatewayapi.(*gatewayapifake.Clientset),
    		c.dynamic.(*dynamicfake.FakeDynamicClient),
    		c.metadata.(*metadatafake.FakeMetadataClient),
    	} {
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Thu Apr 25 14:44:17 UTC 2024
    - 39K bytes
    - Viewed (0)
  2. pkg/controller/daemon/daemon_controller_test.go

    			ds := newDaemonSet("foo")
    			fakeClient := &fake.Clientset{}
    			getCalled := 0
    			fakeClient.AddReactor("get", "daemonsets", func(action core.Action) (bool, runtime.Object, error) {
    				getCalled += 1
    				if getCalled <= tt.getErrorNum {
    					return true, nil, getError
    				}
    				return true, ds, nil
    			})
    			updateCalled := 0
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat May 04 18:33:12 UTC 2024
    - 111.4K bytes
    - Viewed (0)
  3. pkg/volume/csi/fake/fake_client.go

    Stephen Kitt <******@****.***> 1683039747 +0200
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Jun 20 14:49:03 UTC 2023
    - 16K bytes
    - Viewed (0)
  4. 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)
  5. pkg/controller/job/job_controller_test.go

    		t.Run(name, func(t *testing.T) {
    			t.Cleanup(setDurationDuringTest(&DefaultJobApiBackOff, fastJobApiBackoff))
    			fakeClient := clocktesting.NewFakeClock(time.Now())
    			manager, sharedInformerFactory := newControllerFromClientWithClock(ctx, t, clientset, controller.NoResyncPeriodFunc, fakeClient)
    			fakePodControl := controller.FakePodControl{}
    			manager.podControl = &fakePodControl
    			manager.podStoreSynced = alwaysReady
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Jun 11 15:36:36 UTC 2024
    - 229.2K bytes
    - Viewed (0)
  6. 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)
  7. staging/src/k8s.io/cli-runtime/pkg/resource/builder.go

    	Name     string
    }
    
    type FakeClientFunc func(version schema.GroupVersion) (RESTClient, error)
    
    func NewFakeBuilder(fakeClientFn FakeClientFunc, restMapper RESTMapperFunc, categoryExpander CategoryExpanderFunc) *Builder {
    	ret := newBuilder(nil, restMapper, categoryExpander)
    	ret.fakeClientFn = fakeClientFn
    	return ret
    }
    
    // NewBuilder creates a builder that operates on generic objects. At least one of
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Jul 03 10:17:56 UTC 2023
    - 37.2K bytes
    - Viewed (0)
  8. CHANGELOG/CHANGELOG-1.22.md

    - Fake clients now implement a `FakeClient` interface ([#100940](https://github.com/kubernetes/kubernetes/pull/100940), [@markusthoemmes](https://github.com/markusthoemmes)) [SIG API Machinery and Instrumentation]
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Dec 13 12:43:45 UTC 2022
    - 454.1K bytes
    - Viewed (0)
  9. security/pkg/nodeagent/cache/secretcache_test.go

    	})
    
    	if !bytes.Equal(sc.mergeConfigTrustBundle([]string{string(caClientRootCert), string(rootCert)}), expectedCerts) {
    		t.Fatalf("deduplicate test failed!")
    	}
    
    	// Update the proxyConfig with fakeCaClient certs
    	sc.UpdateConfigTrustBundle(caClientRootCert)
    	setupTestDir(t, sc)
    
    	rootCert, err = os.ReadFile(sc.existingCertificateFile.CaCertificatePath)
    	if err != nil {
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Thu May 16 22:12:28 UTC 2024
    - 23.9K bytes
    - Viewed (0)
Back to top