Search Options

Results per page
Sort
Preferred Languages
Advance

Results 31 - 34 of 34 for AddReactor (0.53 sec)

  1. pkg/volume/projected/projected_test.go

    				ObjectMeta: metav1.ObjectMeta{Namespace: testNamespace, UID: testPodUID},
    				Spec:       v1.PodSpec{ServiceAccountName: "foo"},
    			}
    			scheme.Default(pod)
    
    			client := &fake.Clientset{}
    			client.AddReactor("create", "serviceaccounts", clitesting.ReactionFunc(func(action clitesting.Action) (bool, runtime.Object, error) {
    				tr := action.(clitesting.CreateAction).GetObject().(*authenticationv1.TokenRequest)
    				scheme.Default(tr)
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Nov 03 18:40:48 UTC 2023
    - 40.5K bytes
    - Viewed (0)
  2. pkg/controller/daemon/daemon_controller_test.go

    			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
    			fakeClient.AddReactor("update", "daemonsets", func(action core.Action) (bool, runtime.Object, error) {
    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/kubelet/kubelet_pods_test.go

    			}
    
    			testKubelet.fakeKubeClient.AddReactor("get", "configmaps", func(action core.Action) (bool, runtime.Object, error) {
    				var err error
    				if tc.configMap == nil {
    					err = apierrors.NewNotFound(action.GetResource().GroupResource(), "configmap-name")
    				}
    				return true, tc.configMap, err
    			})
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Jun 07 00:05:23 UTC 2024
    - 198.8K bytes
    - Viewed (0)
  4. pkg/scheduler/schedule_one_test.go

    		},
    	}
    	for _, test := range tests {
    		t.Run(test.name, func(t *testing.T) {
    			actualPatchRequests := 0
    			var actualPatchData string
    			cs := &clientsetfake.Clientset{}
    			cs.AddReactor("patch", "pods", func(action clienttesting.Action) (bool, runtime.Object, error) {
    				actualPatchRequests++
    				patch := action.(clienttesting.PatchAction)
    				actualPatchData = string(patch.GetPatch())
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Jun 04 06:20:55 UTC 2024
    - 128.1K bytes
    - Viewed (0)
Back to top