- Sort Score
- Result 10 results
- Languages All
Results 1 - 2 of 2 for newUIDTrackingExpectations (0.2 sec)
-
pkg/controller/job/tracking_utils.go
} } } // NewUIDTrackingControllerExpectations returns a wrapper around // ControllerExpectations that is aware of deleteKeys. func newUIDTrackingExpectations() *uidTrackingExpectations { return &uidTrackingExpectations{store: cache.NewStore(uidSetKeyFunc)} } func hasJobTrackingFinalizer(pod *v1.Pod) bool { for _, fin := range pod.Finalizers {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jun 14 05:40:02 UTC 2023 - 4.3K bytes - Viewed (0) -
pkg/controller/job/tracking_utils_test.go
firstRound: []string{"x", "y", "z"}, secondRound: []string{"u", "v", "w"}, }, { job: "baz", firstRound: []string{"w"}, secondRound: []string{"a"}, }, } expectations := newUIDTrackingExpectations() // Insert first round of keys in parallel. var wg sync.WaitGroup wg.Add(len(tracks)) errs := make([]error, len(tracks)) for i := range tracks { track := tracks[i] go func(errID int) {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jun 14 05:40:02 UTC 2023 - 5.9K bytes - Viewed (0)