Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 7 of 7 for GetEventRecorder (0.19 sec)

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

    }
    
    func (ctrl *PersistentVolumeController) GetNodeName() types.NodeName {
    	return ""
    }
    
    func (ctrl *PersistentVolumeController) GetEventRecorder() record.EventRecorder {
    	return ctrl.eventRecorder
    }
    
    func (ctrl *PersistentVolumeController) GetSubpather() subpath.Interface {
    	// No volume plugin needs Subpaths in PV controller.
    	return nil
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Apr 18 11:00:37 UTC 2024
    - 4.5K bytes
    - Viewed (0)
  2. pkg/kubelet/volume_host.go

    	}
    	return result, nil
    }
    
    func (kvh *kubeletVolumeHost) GetNodeName() types.NodeName {
    	return kvh.kubelet.nodeName
    }
    
    func (kvh *kubeletVolumeHost) GetEventRecorder() record.EventRecorder {
    	return kvh.kubelet.recorder
    }
    
    func (kvh *kubeletVolumeHost) GetExec(pluginName string) utilexec.Interface {
    	return kvh.exec
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Apr 18 11:00:37 UTC 2024
    - 10K bytes
    - Viewed (0)
  3. pkg/controller/volume/expand/expand_controller.go

    	return nil, fmt.Errorf("GetNodeLabels unsupported in expandController")
    }
    
    func (expc *expandController) GetNodeName() types.NodeName {
    	return ""
    }
    
    func (expc *expandController) GetEventRecorder() record.EventRecorder {
    	return expc.recorder
    }
    
    func (expc *expandController) GetSubpather() subpath.Interface {
    	// not needed for expand controller
    	return nil
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat May 04 18:33:12 UTC 2024
    - 16.2K bytes
    - Viewed (0)
  4. pkg/volume/testing/volume_host.go

    	}
    	return f.nodeLabels, nil
    }
    
    func (f *fakeVolumeHost) GetNodeName() types.NodeName {
    	return types.NodeName(f.nodeName)
    }
    
    func (f *fakeVolumeHost) GetEventRecorder() record.EventRecorder {
    	return nil
    }
    
    func (f *fakeVolumeHost) ScriptCommands(scripts []CommandScript) {
    	ScriptCommands(f.exec, scripts)
    }
    
    func (f *fakeVolumeHost) WaitForKubeletErrNil() error {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat May 11 09:02:45 UTC 2024
    - 16.5K bytes
    - Viewed (0)
  5. pkg/volume/local/local.go

    	localVolumePluginName = "kubernetes.io/local-volume"
    )
    
    func (plugin *localVolumePlugin) Init(host volume.VolumeHost) error {
    	plugin.host = host
    	plugin.volumeLocks = keymutex.NewHashed(0)
    	plugin.recorder = host.GetEventRecorder()
    	return nil
    }
    
    func (plugin *localVolumePlugin) GetPluginName() string {
    	return localVolumePluginName
    }
    
    func (plugin *localVolumePlugin) GetVolumeName(spec *volume.Spec) (string, error) {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue May 14 06:17:25 UTC 2024
    - 22.2K bytes
    - Viewed (0)
  6. pkg/controller/volume/attachdetach/attach_detach_controller.go

    	return nil, fmt.Errorf("GetNodeLabels() unsupported in Attach/Detach controller")
    }
    
    func (adc *attachDetachController) GetNodeName() types.NodeName {
    	return ""
    }
    
    func (adc *attachDetachController) GetEventRecorder() record.EventRecorder {
    	return nil
    }
    
    func (adc *attachDetachController) GetSubpather() subpath.Interface {
    	// Subpaths not needed in attachdetach controller
    	return nil
    }
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat May 04 18:33:12 UTC 2024
    - 32.6K bytes
    - Viewed (0)
  7. pkg/volume/plugins.go

    	// Returns the name of the node
    	GetNodeName() types.NodeName
    
    	GetAttachedVolumesFromNodeStatus() (map[v1.UniqueVolumeName]string, error)
    
    	// Returns the event recorder of kubelet.
    	GetEventRecorder() record.EventRecorder
    
    	// Returns an interface that should be used to execute subpath operations
    	GetSubpather() subpath.Interface
    }
    
    // VolumePluginMgr tracks registered plugins.
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Jun 06 16:13:15 UTC 2024
    - 38.2K bytes
    - Viewed (0)
Back to top