Versions in this module Expand all Collapse all v0 v0.7.1 Mar 9, 2018 v0.7.0 Feb 21, 2018 Changes in this version + const FlexvolumeDriver + const FlexvolumeVendor + const ImageKey + const PoolKey + const ReadOnly + const ReadWrite + const StorageClassKey + const UnixSocketName + type AttachOptions struct + ClusterName string + FsName string + FsType string + Image string + MountDir string + Path string + Pod string + PodID string + PodNamespace string + Pool string + RW string + StorageClass string + VolumeName string + type Controller struct + func NewController(context *clusterd.Context, volumeAttachment attachment.Attachment, ...) *Controller + func (c *Controller) Attach(attachOpts AttachOptions, devicePath *string) error + func (c *Controller) Detach(detachOpts AttachOptions, _ *struct{}) error + func (c *Controller) DetachForce(detachOpts AttachOptions, _ *struct{}) error + func (c *Controller) GetAttachInfoFromMountDir(mountDir string, attachOptions *AttachOptions) error + func (c *Controller) GetClientAccessInfo(clusterName string, clientAccessInfo *model.ClientAccessInfo) error + func (c *Controller) GetGlobalMountPath(volumeName string, globalMountPath *string) error + func (c *Controller) GetKernelVersion(_ *struct{}, kernelVersion *string) error + func (c *Controller) Log(message LogMessage, _ *struct{}) error + func (c *Controller) RemoveAttachmentObject(detachOpts AttachOptions, safeToDetach *bool) error + type FlexvolumeServer struct + func NewFlexvolumeServer(context *clusterd.Context, controller *Controller, manager VolumeManager) *FlexvolumeServer + func (s *FlexvolumeServer) Start() error + func (s *FlexvolumeServer) Stop() + type LogMessage struct + IsError bool + Message string + type MockFlexvolumeController struct + MockAttach func(attachOpts AttachOptions, devicePath *string) error + MockDetach func(detachOpts AttachOptions, _ *struct{}) error + MockDetachForce func(detachOpts AttachOptions, _ *struct{}) error + MockGetAttachInfoFromMountDir func(mountDir string, attachOptions *AttachOptions) error + MockLog func(message LogMessage, _ *struct{}) error + MockRemoveAttachmentObject func(detachOpts AttachOptions, safeToDetach *bool) error + func (m *MockFlexvolumeController) Attach(attachOpts AttachOptions, devicePath *string) error + func (m *MockFlexvolumeController) Detach(detachOpts AttachOptions, _ *struct{}) error + func (m *MockFlexvolumeController) DetachForce(detachOpts AttachOptions, _ *struct{}) error + func (m *MockFlexvolumeController) GetAttachInfoFromMountDir(mountDir string, attachOptions *AttachOptions) error + func (m *MockFlexvolumeController) Log(message LogMessage, _ *struct{}) error + func (m *MockFlexvolumeController) RemoveAttachmentObject(detachOpts AttachOptions, safeToDetach *bool) error + type VolumeController interface + Attach func(attachOpts AttachOptions, devicePath *string) error + Detach func(detachOpts AttachOptions, _ *struct{}) error + DetachForce func(detachOpts AttachOptions, _ *struct{}) error + GetAttachInfoFromMountDir func(mountDir string, attachOptions *AttachOptions) error + Log func(message LogMessage, _ *struct{}) error + RemoveAttachmentObject func(detachOpts AttachOptions, safeToDetach *bool) error + type VolumeManager interface + Attach func(image, pool, clusterName string) (string, error) + Detach func(image, pool, clusterName string, force bool) error + Init func() error