Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 2 of 2 for scheduleOperation (0.16 sec)

  1. pkg/controller/volume/persistentvolume/pv_controller.go

    	return "pvc-" + string(claim.UID)
    }
    
    // scheduleOperation starts given asynchronous operation on given volume. It
    // makes sure the operation is already not running.
    func (ctrl *PersistentVolumeController) scheduleOperation(logger klog.Logger, operationName string, operation func() error) {
    	logger.V(4).Info("scheduleOperation", "operationName", operationName)
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri May 10 08:42:31 UTC 2024
    - 89.2K bytes
    - Viewed (0)
  2. pkg/controller/volume/persistentvolume/framework_test.go

    		return toWrap(ctrl, reactor, test)
    	}
    }
    
    // wrapTestWithInjectedOperation returns a testCall that:
    //   - starts the controller and lets it run original testCall until
    //     scheduleOperation() call. It blocks the controller there and calls the
    //     injected function to simulate that something is happening when the
    //     controller waits for the operation lock. Controller is then resumed and we
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Nov 01 09:54:00 UTC 2023
    - 38.3K bytes
    - Viewed (0)
Back to top