controller

Documentation

Index

• Constants
• func InArray(target string, array []string) bool
• type Controller
  • func NewController(kubeclientset kubernetes.Interface, dockerClient *dockerclient.Client, ...) *Controller
  • func (c *Controller) AddNFSItem(nfsItem string)
  • func (c *Controller) DelNFSItem(nfsItem string) error
  • func (c *Controller) ExportFs()
  • func (c *Controller) HasMount(mountPath string) bool
  • func (c *Controller) HasNFSItem(nfsItem string) bool
  • func (c *Controller) Mkdir(MountPath string) error
  • func (c *Controller) MountBind(source string, target string) error
  • func (c *Controller) Run(threadiness int, stopCh <-chan struct{}) error
  • func (c *Controller) Umount(mountPath string) error

Constants

const (
	SuccessSynced         = "Synced"
	MessageResourceSynced = "Add nfs share path success."
	NFSShareLabel         = "NFSShare"
)

Functions

func InArray

func InArray(target string, array []string) bool

Types

type Controller

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

func NewController

func NewController(kubeclientset kubernetes.Interface, dockerClient *dockerclient.Client,
	podInformer corev1.PodInformer, containerId string) *Controller

func (*Controller) AddNFSItem

func (c *Controller) AddNFSItem(nfsItem string)

func (*Controller) DelNFSItem

func (c *Controller) DelNFSItem(nfsItem string) error

func (*Controller) ExportFs

func (c *Controller) ExportFs()

func (*Controller) HasMount

func (c *Controller) HasMount(mountPath string) bool

func (*Controller) HasNFSItem

func (c *Controller) HasNFSItem(nfsItem string) bool

func (*Controller) Mkdir

func (c *Controller) Mkdir(MountPath string) error

func (*Controller) MountBind

func (c *Controller) MountBind(source string, target string) error

func (*Controller) Run

func (c *Controller) Run(threadiness int, stopCh <-chan struct{}) error

func (*Controller) Umount

func (c *Controller) Umount(mountPath string) error