- Sort Score
- Result 10 results
- Languages All
Results 1 - 7 of 7 for GetNodeLabels (0.14 sec)
-
pkg/controller/volume/persistentvolume/volume_host.go
} } func (adc *PersistentVolumeController) GetExec(pluginName string) utilexec.Interface { return utilexec.New() } func (ctrl *PersistentVolumeController) GetNodeLabels() (map[string]string, error) { return nil, fmt.Errorf("GetNodeLabels() unsupported in PersistentVolumeController") } func (ctrl *PersistentVolumeController) GetNodeName() types.NodeName { return "" }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Apr 18 11:00:37 UTC 2024 - 4.5K bytes - Viewed (0) -
pkg/controller/volume/expand/expand_controller.go
return func(types.UID) { //nolint:logcheck klog.ErrorS(nil, "DeleteServiceAccountToken unsupported in expandController") } } func (expc *expandController) GetNodeLabels() (map[string]string, error) { return nil, fmt.Errorf("GetNodeLabels unsupported in expandController") } func (expc *expandController) GetNodeName() types.NodeName { return "" }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 16.2K bytes - Viewed (0) -
pkg/kubelet/volume_host.go
return kvh.clusterTrustBundleManager.GetTrustAnchorsBySigner(signerName, labelSelector, allowMissing) } func (kvh *kubeletVolumeHost) GetNodeLabels() (map[string]string, error) { node, err := kvh.kubelet.GetNode() if err != nil { return nil, fmt.Errorf("error retrieving node: %v", err) } return node.Labels, nil }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Apr 18 11:00:37 UTC 2024 - 10K bytes - Viewed (0) -
pkg/controller/volume/attachdetach/attach_detach_controller.go
// detach controller. Add it to desired state of world. adc.desiredStateOfWorld.AddNode(nodeName) } } func (adc *attachDetachController) GetNodeLabels() (map[string]string, error) { return nil, fmt.Errorf("GetNodeLabels() unsupported in Attach/Detach controller") } func (adc *attachDetachController) GetNodeName() types.NodeName { return "" }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 32.6K bytes - Viewed (0) -
pkg/volume/testing/volume_host.go
} } func (f *fakeVolumeHost) DeleteServiceAccountTokenFunc() func(types.UID) { return func(types.UID) {} } func (f *fakeVolumeHost) GetNodeLabels() (map[string]string, error) { if f.nodeLabels == nil { f.nodeLabels = map[string]string{"test-label": "test-value"} } return f.nodeLabels, nil } func (f *fakeVolumeHost) GetNodeName() types.NodeName {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 11 09:02:45 UTC 2024 - 16.5K bytes - Viewed (0) -
pkg/volume/plugins.go
// Returns an interface that should be used to execute any utilities in volume plugins GetExec(pluginName string) exec.Interface // Returns the labels on the node GetNodeLabels() (map[string]string, error) // Returns the name of the node GetNodeName() types.NodeName GetAttachedVolumesFromNodeStatus() (map[v1.UniqueVolumeName]string, error)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Jun 06 16:13:15 UTC 2024 - 38.2K bytes - Viewed (0) -
pkg/volume/util/operationexecutor/operation_generator.go
func checkNodeAffinity(og *operationGenerator, volumeToMount VolumeToMount) error { pv := volumeToMount.VolumeSpec.PersistentVolume if pv != nil { nodeLabels, err := og.volumePluginMgr.Host.GetNodeLabels() if err != nil { return err } err = storagehelpers.CheckNodeAffinity(pv, nodeLabels) if err != nil { return err } } return nil }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue May 14 06:17:25 UTC 2024 - 101.4K bytes - Viewed (0)