pkg/volume/image/image.go - master - githubmirror/kubernetes

pkg/volume/image/image.go
98 строк3 KB
Kubernetes Prow Robot
Merge pull request #126777 from carlory/fix-image-plugin
20 янв 2025, 19:46
20 янв 2025, 19:463305fcc
/*
Copyright 2024 The Kubernetes Authors.

Licensed under the Apache License, Version 2.0 (the "License");
you may not use this file except in compliance with the License.
You may obtain a copy of the License at

    http://www.apache.org/licenses/LICENSE-2.0

Unless required by applicable law or agreed to in writing, software
distributed under the License is distributed on an "AS IS" BASIS,
WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
See the License for the specific language governing permissions and
limitations under the License.
*/

package image

import (
	"fmt"

	v1 "k8s.io/api/core/v1"
	"k8s.io/apimachinery/pkg/types"
	"k8s.io/kubernetes/pkg/volume"
)

// imagePlugin is the image volume plugin which acts as a stub to provide the
// functionality the volume manager expects. The real volume source
// implementation is part of the kubelet code and gated by the Kubernetes
// feature "ImageVolume"
// See: https://kep.k8s.io/4639
type imagePlugin struct {
	volume.MetricsNil
}

var _ volume.VolumePlugin = &imagePlugin{}
var _ volume.Mounter = &imagePlugin{}
var _ volume.Unmounter = &imagePlugin{}
var _ volume.Volume = &imagePlugin{}

const pluginName = "kubernetes.io/image"

func ProbeVolumePlugins() []volume.VolumePlugin {
	p := &imagePlugin{}
	return []volume.VolumePlugin{p}
}

func (o *imagePlugin) Init(volume.VolumeHost) error { return nil }
func (o *imagePlugin) GetPluginName() string        { return pluginName }
func (o *imagePlugin) GetVolumeName(spec *volume.Spec) (string, error) {
	volumeSource := getVolumeSource(spec)
	if volumeSource == nil {
		return "", fmt.Errorf("the volumeSpec does not reference an Image volume type")
	}

	return volumeSource.Reference, nil
}

func (o *imagePlugin) CanSupport(spec *volume.Spec) bool {
	return spec != nil && spec.Volume != nil && spec.Volume.Image != nil
}

func (o *imagePlugin) NewMounter(spec *volume.Spec, podRef *v1.Pod) (volume.Mounter, error) {
	return o, nil
}

func (o *imagePlugin) NewUnmounter(name string, podUID types.UID) (volume.Unmounter, error) {
	return o, nil
}

func (o *imagePlugin) ConstructVolumeSpec(volumeName, mountPath string) (volume.ReconstructedVolume, error) {
	return volume.ReconstructedVolume{}, nil
}

func (o *imagePlugin) GetAttributes() volume.Attributes {
	return volume.Attributes{
		ReadOnly:       true,
		Managed:        false,
		SELinuxRelabel: false,
	}
}

func (o *imagePlugin) GetPath() string                                             { return "" }
func (o *imagePlugin) RequiresFSResize() bool                                      { return false }
func (o *imagePlugin) RequiresRemount(spec *volume.Spec) bool                      { return false }
func (o *imagePlugin) SetUp(mounterArgs volume.MounterArgs) error                  { return nil }
func (o *imagePlugin) SetUpAt(dir string, mounterArgs volume.MounterArgs) error    { return nil }
func (o *imagePlugin) SupportsMountOption() bool                                   { return false }
func (o *imagePlugin) SupportsSELinuxContextMount(spec *volume.Spec) (bool, error) { return false, nil }
func (o *imagePlugin) TearDown() error                                             { return nil }
func (o *imagePlugin) TearDownAt(string) error                                     { return nil }

func getVolumeSource(spec *volume.Spec) *v1.ImageVolumeSource {
	if spec == nil || spec.Volume == nil {
		return nil
	}
	return spec.Volume.Image
}