kubernetes

Documentation

Index

• Constants
• func CreateISCSIVolumeSource(volConfig *storage.VolumeConfig) *v1.ISCSIVolumeSource
• func CreateNFSVolumeSource(volConfig *storage.VolumeConfig) *v1.NFSVolumeSource
• func ValidateKubeVersion(versionInfo *k8s_version.Info) (kubeVersion *k8s_util_version.Version, err error)
• type KubernetesPlugin
  • func NewPlugin(o core.Orchestrator, apiServerIP, kubeConfigPath string) (*KubernetesPlugin, error)
  • func NewPluginInCluster(o core.Orchestrator) (*KubernetesPlugin, error)
  • func (p *KubernetesPlugin) Activate() error
  • func (p *KubernetesPlugin) Deactivate() error
  • func (p *KubernetesPlugin) GetName() string
  • func (p *KubernetesPlugin) Version() string

Constants

const (
	KubernetesSyncPeriod = 60 * time.Second

	// Kubernetes-defined annotations
	// (Based on kubernetes/pkg/controller/volume/persistentvolume/controller.go)
	AnnClass                  = "volume.beta.kubernetes.io/storage-class"
	AnnDynamicallyProvisioned = "pv.kubernetes.io/provisioned-by"
	AnnStorageProvisioner     = "volume.beta.kubernetes.io/storage-provisioner"
	AnnDefaultStorageClass    = "storageclass.kubernetes.io/is-default-class"

	// Orchestrator-defined annotations
	AnnOrchestrator    = "netapp.io/" + config.OrchestratorName
	AnnPrefix          = config.OrchestratorName + ".netapp.io"
	AnnReclaimPolicy   = AnnPrefix + "/reclaimPolicy"
	AnnProtocol        = AnnPrefix + "/protocol"
	AnnSpaceReserve    = AnnPrefix + "/spaceReserve"
	AnnSnapshotPolicy  = AnnPrefix + "/snapshotPolicy"
	AnnSnapshotDir     = AnnPrefix + "/snapshotDirectory"
	AnnUnixPermissions = AnnPrefix + "/unixPermissions"
	AnnVendor          = AnnPrefix + "/vendor"
	AnnBackendID       = AnnPrefix + "/backendID"
	AnnExportPolicy    = AnnPrefix + "/exportPolicy"
	AnnBlockSize       = AnnPrefix + "/blockSize"
	AnnFileSystem      = AnnPrefix + "/fileSystem"

	// Minimum and maximum supported Kubernetes versions
	KubernetesVersionMin = "v1.4.0"
	KubernetesVersionMax = "v1.6.0"
)

Functions

func CreateISCSIVolumeSource

func CreateISCSIVolumeSource(volConfig *storage.VolumeConfig) *v1.ISCSIVolumeSource

func CreateNFSVolumeSource

func CreateNFSVolumeSource(volConfig *storage.VolumeConfig) *v1.NFSVolumeSource

func ValidateKubeVersion

func ValidateKubeVersion(versionInfo *k8s_version.Info) (kubeVersion *k8s_util_version.Version, err error)

Types

type KubernetesPlugin

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

func NewPlugin

func NewPlugin(o core.Orchestrator, apiServerIP, kubeConfigPath string) (*KubernetesPlugin, error)

func NewPluginInCluster

func NewPluginInCluster(o core.Orchestrator) (*KubernetesPlugin, error)

func (*KubernetesPlugin) Activate

func (p *KubernetesPlugin) Activate() error

func (*KubernetesPlugin) Deactivate

func (p *KubernetesPlugin) Deactivate() error

func (*KubernetesPlugin) GetName

func (p *KubernetesPlugin) GetName() string

func (*KubernetesPlugin) Version

func (p *KubernetesPlugin) Version() string