storage

Documentation

Index

• type Manager
  • func NewManager(ctx context.Context, kubeClient kubeclient.Interface, ...) *Manager
  • func (m *Manager) Cleanup(pod *corev1.Pod) error
  • func (m *Manager) Close() error
  • func (m *Manager) GetPersistentVolumeMountPath(podUID types.UID, volumeName string) string
  • func (m *Manager) Prepare(pod *corev1.Pod, volToMount []corev1.UniqueVolumeName) error
  • func (m *Manager) Start() error
• type Options
• type PodStateProvider

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
}