storage

package
Version: v0.0.0-...-4cca708 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Jul 26, 2022 License: Apache-2.0 Imports: 50 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type Manager

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

func NewManager

func NewManager(
	ctx context.Context,
	kubeClient kubeclient.Interface,
	nodeName, hostname, hostIP string,
	runtime kubecontainer.Runtime,
	podManager kubeletpod.Manager,
	podStatusProvider PodStateProvider,
	options *Options,
) *Manager

func (*Manager) Cleanup

func (m *Manager) Cleanup(pod *corev1.Pod) error

Cleanup pod volumes

func (*Manager) Close

func (m *Manager) Close() error

func (*Manager) GetPersistentVolumeMountPath

func (m *Manager) GetPersistentVolumeMountPath(podUID types.UID, volumeName string) string

func (*Manager) Prepare

func (m *Manager) Prepare(pod *corev1.Pod, volToMount []corev1.UniqueVolumeName) error

func (*Manager) Start

func (m *Manager) Start() error

type Options

type Options struct {
	SSHPrivateKey []byte

	StorageRootDir         string
	KubeletRegistrationDir string
	KubeletPluginsDir      string
	CSIDriverLister        *kubehelper.CSIDriverLister
	EventRecorder          record.EventRecorder
}

type PodStateProvider

type PodStateProvider interface {
	ShouldPodContainersBeTerminating(types.UID) bool
	ShouldPodRuntimeBeRemoved(types.UID) bool
}

Directories

Path Synopsis

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL