edge_pv

Documentation

Index

• Constants
• func EdgePVHandler(path string, provisioner volume.ProvisionableVolumePlugin, ...) *restful.WebService
• func Fake(edgePV EdgePV) volume.VolumePlugin
• func ProbeVolumePlugins(volumeConfig volume.VolumeConfig) []volume.VolumePlugin
• type EdgePV
• type EdgePVClient
  • func (edgePVClient *EdgePVClient) Delete(gatewayId string, pvName string) error
  • func (edgePVClient *EdgePVClient) GetVolumeSource(spec *volume.Spec) (*v1.HostPathVolumeSource, bool, error)
  • func (edgePVClient *EdgePVClient) Init(host volume.VolumeHost)
  • func (edgePVClient *EdgePVClient) Provision(gatewayId string, pvName string) error
  • func (edgePVClient *EdgePVClient) Recycle(gatewayId string, pvName string) error
• type EdgePVManager
  • func (edgePVManager *EdgePVManager) Delete(gatewayId string, pvName string) error
  • func (edgePVManager *EdgePVManager) GetVolumeSource(spec *volume.Spec) (*v1.HostPathVolumeSource, bool, error)
  • func (edgePVManager *EdgePVManager) Init(host volume.VolumeHost)
  • func (edgePVManager *EdgePVManager) Provision(gatewayId string, pvName string) error
  • func (edgePVManager *EdgePVManager) Recycle(gatewayId string, pvName string) error

Constants

const (
	EdgePVPluginName         = "kubernetes.io/edge-pv"
	AnnGateway               = "volume.kubernetes.io/gateway"
	EdgePVFogProxyAddress    = "edge-pv-fog-proxy-address"
	EdgePVProvisionerAddress = "edge-pv-provisioner-address"
)

Functions

func EdgePVHandler

func EdgePVHandler(path string, provisioner volume.ProvisionableVolumePlugin, deleter volume.DeletableVolumePlugin, recycler volume.RecyclableVolumePlugin) *restful.WebService

func Fake

func Fake(edgePV EdgePV) volume.VolumePlugin

func ProbeVolumePlugins

func ProbeVolumePlugins(volumeConfig volume.VolumeConfig) []volume.VolumePlugin

This is the primary entrypoint for volume plugins. The volumeConfig arg provides the ability to configure volume behavior. It is implemented as a pointer to allow nils. The hostPathPlugin is used to store the volumeConfig and give it, when needed, to the func that Recycles. Tests that exercise recycling should not use this func but instead use ProbeRecyclablePlugins() to override default behavior.

Types

type EdgePV

type EdgePV interface {
	Init(volume.VolumeHost)
	Provision(gatewayId string, pvName string) error
	Delete(gatewayId string, pvName string) error
	Recycle(gatewayId string, pvName string) error
	GetVolumeSource(spec *volume.Spec) (*v1.HostPathVolumeSource, bool, error)
}

type EdgePVClient

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

Uses fog-proxy

func (*EdgePVClient) Delete

func (edgePVClient *EdgePVClient) Delete(gatewayId string, pvName string) error

func (*EdgePVClient) GetVolumeSource

func (edgePVClient *EdgePVClient) GetVolumeSource(spec *volume.Spec) (*v1.HostPathVolumeSource, bool, error)

func (*EdgePVClient) Init

func (edgePVClient *EdgePVClient) Init(host volume.VolumeHost)

func (*EdgePVClient) Provision

func (edgePVClient *EdgePVClient) Provision(gatewayId string, pvName string) error

func (*EdgePVClient) Recycle

func (edgePVClient *EdgePVClient) Recycle(gatewayId string, pvName string) error

type EdgePVManager

type EdgePVManager struct {
	EdgePVDirectory string
	// contains filtered or unexported fields
}

func (*EdgePVManager) Delete

func (edgePVManager *EdgePVManager) Delete(gatewayId string, pvName string) error

Delete directory and free up resources

func (*EdgePVManager) GetVolumeSource

func (edgePVManager *EdgePVManager) GetVolumeSource(spec *volume.Spec) (*v1.HostPathVolumeSource, bool, error)

Get the directory host path for this volume

func (*EdgePVManager) Init

func (edgePVManager *EdgePVManager) Init(host volume.VolumeHost)

func (*EdgePVManager) Provision

func (edgePVManager *EdgePVManager) Provision(gatewayId string, pvName string) error

Creates directory

func (*EdgePVManager) Recycle

func (edgePVManager *EdgePVManager) Recycle(gatewayId string, pvName string) error

Recycle should delete contents of the directory to return it to a blank state