kubernetes

Documentation

Index

• Constants
• func GetHomeKubernetesConfigPath() (string, error)
• type DatasetMount
• type ParcelVolumeManager
  • func NewVolumeManager(configPath string, namespace string) (*ParcelVolumeManager, error)
  • func (manager *ParcelVolumeManager) CreateStorageClass() error
  • func (manager *ParcelVolumeManager) CreateVolume(ds *dataset.Dataset) (*DatasetMount, error)
  • func (manager *ParcelVolumeManager) DeleteVolume(volumeName string) error
  • func (manager *ParcelVolumeManager) GetVolume(volumeName string) (*DatasetMount, error)
  • func (manager *ParcelVolumeManager) ListVolumes() ([]*DatasetMount, error)

Constants

const (

	// VolumeNamespace is a default namespace
	VolumeNamespace = "default"
)

Functions

func GetHomeKubernetesConfigPath

func GetHomeKubernetesConfigPath() (string, error)

GetHomeKubernetesConfigPath returns a kubernetes configuration path under home

Types

type DatasetMount

type DatasetMount struct {
	Dataset               *dataset.Dataset
	PersistentVolume      *apiv1.PersistentVolume
	PersistentVolumeClaim *apiv1.PersistentVolumeClaim
}

DatasetMount holds a volume mapping

type ParcelVolumeManager

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

ParcelVolumeManager manages parcel volume

func NewVolumeManager

func NewVolumeManager(configPath string, namespace string) (*ParcelVolumeManager, error)

NewVolumeManager returns a new volume manager instance

func (*ParcelVolumeManager) CreateStorageClass

func (manager *ParcelVolumeManager) CreateStorageClass() error

CreateStorageClass creates a new storage class

func (*ParcelVolumeManager) CreateVolume

func (manager *ParcelVolumeManager) CreateVolume(ds *dataset.Dataset) (*DatasetMount, error)

CreateVolume creates a Persistent Volume for Kubernetes

func (*ParcelVolumeManager) DeleteVolume

func (manager *ParcelVolumeManager) DeleteVolume(volumeName string) error

DeleteVolume deletes a Persistent Volume for Kubernetes

func (*ParcelVolumeManager) GetVolume

func (manager *ParcelVolumeManager) GetVolume(volumeName string) (*DatasetMount, error)

GetVolume returns a Persistent Volume for Kubernetes

func (*ParcelVolumeManager) ListVolumes

func (manager *ParcelVolumeManager) ListVolumes() ([]*DatasetMount, error)

ListVolumes lists Persistent Volumes for Kubernetes