hotplug_volume

Documentation

Overview

* This file is part of the KubeVirt project * * 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. * * Copyright 2021 Red Hat, Inc. *

Index

• type FileSystems
• type FindmntInfo
  • func LookupFindmntInfoByDevice(deviceName string) ([]FindmntInfo, error)
  • func LookupFindmntInfoByVolume(volumeName string, pid int) ([]FindmntInfo, error)
  • func (f *FindmntInfo) GetOptions() []string
  • func (f *FindmntInfo) GetSourceDevice() string
  • func (f *FindmntInfo) GetSourcePath() string
• type MockVolumeMounter
  • func NewMockVolumeMounter(ctrl *gomock.Controller) *MockVolumeMounter
  • func (_m *MockVolumeMounter) EXPECT() *_MockVolumeMounterRecorder
  • func (_m *MockVolumeMounter) IsMounted(vmi *v1.VirtualMachineInstance, volume string, sourceUID types.UID) (bool, error)
  • func (_m *MockVolumeMounter) Mount(vmi *v1.VirtualMachineInstance, cgroupManager cgroup.Manager) error
  • func (_m *MockVolumeMounter) MountFromPod(vmi *v1.VirtualMachineInstance, sourceUID types.UID, ...) error
  • func (_m *MockVolumeMounter) Unmount(vmi *v1.VirtualMachineInstance, cgroupManager cgroup.Manager) error
  • func (_m *MockVolumeMounter) UnmountAll(vmi *v1.VirtualMachineInstance, cgroupManager cgroup.Manager) error
• type VolumeMounter
  • func NewVolumeMounter(mountStateDir string, kubeletPodsDir string) VolumeMounter

Types

type FileSystems

type FileSystems struct {
	Filesystems []FindmntInfo `json:"filesystems"`
}

type FindmntInfo

type FindmntInfo struct {
	Target  string `json:"target"`
	Source  string `json:"source"`
	Fstype  string `json:"fstype"`
	Options string `json:"options"`
}

func LookupFindmntInfoByDevice

func LookupFindmntInfoByDevice(deviceName string) ([]FindmntInfo, error)

func LookupFindmntInfoByVolume

func LookupFindmntInfoByVolume(volumeName string, pid int) ([]FindmntInfo, error)

func (*FindmntInfo) GetOptions

func (f *FindmntInfo) GetOptions() []string

func (*FindmntInfo) GetSourceDevice

func (f *FindmntInfo) GetSourceDevice() string

func (*FindmntInfo) GetSourcePath

func (f *FindmntInfo) GetSourcePath() string

type MockVolumeMounter

type MockVolumeMounter struct {
	// contains filtered or unexported fields
}

Mock of VolumeMounter interface

func NewMockVolumeMounter

func NewMockVolumeMounter(ctrl *gomock.Controller) *MockVolumeMounter

func (*MockVolumeMounter) EXPECT

func (_m *MockVolumeMounter) EXPECT() *_MockVolumeMounterRecorder

func (*MockVolumeMounter) IsMounted

func (_m *MockVolumeMounter) IsMounted(vmi *v1.VirtualMachineInstance, volume string, sourceUID types.UID) (bool, error)

func (*MockVolumeMounter) Mount

func (_m *MockVolumeMounter) Mount(vmi *v1.VirtualMachineInstance, cgroupManager cgroup.Manager) error

func (*MockVolumeMounter) MountFromPod

func (_m *MockVolumeMounter) MountFromPod(vmi *v1.VirtualMachineInstance, sourceUID types.UID, cgroupManager cgroup.Manager) error

func (*MockVolumeMounter) Unmount

func (_m *MockVolumeMounter) Unmount(vmi *v1.VirtualMachineInstance, cgroupManager cgroup.Manager) error

func (*MockVolumeMounter) UnmountAll

func (_m *MockVolumeMounter) UnmountAll(vmi *v1.VirtualMachineInstance, cgroupManager cgroup.Manager) error

type VolumeMounter

type VolumeMounter interface {
	// Mount any new volumes defined in the VMI
	Mount(vmi *v1.VirtualMachineInstance, cgroupManager cgroup.Manager) error
	MountFromPod(vmi *v1.VirtualMachineInstance, sourceUID types.UID, cgroupManager cgroup.Manager) error
	// Unmount any volumes no longer defined in the VMI
	Unmount(vmi *v1.VirtualMachineInstance, cgroupManager cgroup.Manager) error
	//UnmountAll cleans up all hotplug volumes
	UnmountAll(vmi *v1.VirtualMachineInstance, cgroupManager cgroup.Manager) error
	//IsMounted returns if the volume is mounted or not.
	IsMounted(vmi *v1.VirtualMachineInstance, volume string, sourceUID types.UID) (bool, error)
}

VolumeMounter is the interface used to mount and unmount volumes to/from a running virtlauncher pod.

func NewVolumeMounter

func NewVolumeMounter(mountStateDir string, kubeletPodsDir string) VolumeMounter

NewVolumeMounter creates a new VolumeMounter