Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 3 of 3 for setResourceVersion (0.2 sec)

  1. pkg/controller/statefulset/stateful_set_control_test.go

    	obj, isObj := object.(metav1.Object)
    	if !isObj {
    		return
    	}
    	if version := obj.GetResourceVersion(); version == "" {
    		obj.SetResourceVersion("1")
    	} else if intValue, err := strconv.ParseInt(version, 10, 32); err == nil {
    		obj.SetResourceVersion(strconv.FormatInt(intValue+1, 10))
    	}
    }
    func TestParallelScale(t *testing.T) {
    	for _, tc := range []struct {
    		desc                        string
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue May 07 19:01:47 UTC 2024
    - 108.7K bytes
    - Viewed (0)
  2. pkg/controller/daemon/daemon_controller_test.go

    			t.Fatalf("queue.Len() = %v, want %v", got, want)
    		}
    	}
    }
    
    func bumpResourceVersion(obj metav1.Object) {
    	ver, _ := strconv.ParseInt(obj.GetResourceVersion(), 10, 32)
    	obj.SetResourceVersion(strconv.FormatInt(ver+1, 10))
    }
    
    // getQueuedKeys returns a sorted list of keys in the queue.
    // It can be used to quickly check that multiple keys are in there.
    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/controller/job/job_controller_test.go

    				}
    			}
    		})
    	}
    }
    
    func bumpResourceVersion(obj metav1.Object) {
    	ver, _ := strconv.ParseInt(obj.GetResourceVersion(), 10, 32)
    	obj.SetResourceVersion(strconv.FormatInt(ver+1, 10))
    }
    
    func TestJobApiBackoffReset(t *testing.T) {
    	t.Cleanup(setDurationDuringTest(&DefaultJobApiBackOff, fastJobApiBackoff))
    	_, ctx := ktesting.NewTestContext(t)
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Jun 11 15:36:36 UTC 2024
    - 229.2K bytes
    - Viewed (0)
Back to top