- Sort Score
- Result 10 results
- Languages All
Results 1 - 2 of 2 for checkBindings (0.2 sec)
-
pkg/scheduler/framework/plugins/volumebinding/binder.go
if err != nil { return err } err = wait.PollUntilContextTimeout(ctx, time.Second, b.bindTimeout, false, func(ctx context.Context) (bool, error) { b, err := b.checkBindings(logger, assumedPod, bindings, claimsToProvision) return b, err }) if err != nil { return fmt.Errorf("binding volumes: %w", err) } return nil } func getPodName(pod *v1.Pod) string {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu May 09 14:55:34 UTC 2024 - 42.6K bytes - Viewed (0) -
pkg/scheduler/framework/plugins/volumebinding/binder_test.go
} else { if err := testEnv.updateClaims(ctx, scenario.apiPVCs); err != nil { t.Errorf("Failed to update PVCs: %v", err) } } // Execute allBound, err := testEnv.internalBinder.checkBindings(logger, pod, scenario.bindings, scenario.provisionedPVCs) // Validate if !scenario.shouldFail && err != nil { t.Errorf("returned error: %v", err) } if scenario.shouldFail && err == nil {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Apr 25 09:46:58 UTC 2024 - 82.8K bytes - Viewed (0)