Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 2 of 2 for checkBindings (0.2 sec)

  1. 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)
  2. 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)
Back to top