Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 2 of 2 for AddIfNotExist (0.13 sec)

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

    		cache: sync.Map{}, // [string]operationTimestamp {}
    	}
    }
    
    // AddIfNotExist returns directly if there exists an entry with the key. Otherwise, it
    // creates a new operation timestamp using operationName, pluginName, and current timestamp
    // and stores the operation timestamp with the key
    func (c *OperationStartTimeCache) AddIfNotExist(key, pluginName, operationName string) {
    	ts := newOperationTimestamp(pluginName, operationName)
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Oct 25 13:09:16 UTC 2022
    - 10.5K bytes
    - Viewed (0)
  2. pkg/controller/volume/persistentvolume/pv_controller.go

    		// create a start timestamp entry in cache for deletion operation if no one exists with
    		// key = volume.Name, pluginName = provisionerName, operation = "delete"
    		ctrl.operationTimestamps.AddIfNotExist(volume.Name, ctrl.getProvisionerNameFromVolume(volume), "delete")
    		ctrl.scheduleOperation(logger, opName, func() error {
    			_, err := ctrl.deleteVolumeOperation(ctx, volume)
    			if err != nil {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri May 10 08:42:31 UTC 2024
    - 89.2K bytes
    - Viewed (0)
Back to top