storageutil

Nov 11, 2020

Changes in this version

+ type DriverConfig struct

+ Config interface{}

+ Driver string

+ func (c *DriverConfig) UnmarshalJSON(data []byte) error

+ func (c *DriverConfig) UnmarshalYAML(value *yaml.Node) error

Nov 11, 2020

Changes in this version

+ const StorageArgEnvMountpoint

+ const StorageArgEnvRemotePath

+ var ErrMountpointInProcess = errors.New("already in process")

+ var ErrMountpointInUse = errors.New("already in use")

+ func CleanupPodData(podDir, remoteVolumeDir, tmpfsVolumeDir string, ...) error

+ func FlagsForClient(prefix string, config *ClientConfig) *pflag.FlagSet

+ func GenerateUnmountCmd(binPath string, mountPoint string) []string

+ func IsLikelyNotMountPoint(file string) (bool, error)

+ func LookupUnmountUtil(extraLookupPaths []string, fuse bool) (string, error)

+ func NewConfig(name string) (interface{}, error)

+ func Register(name string, f FactoryFunc, cf ConfigFactoryFunc)

+ func RemoveAllOneFilesystem(path string) error

+ func ResolveHostPathMountSource(path, podUID, volName string, remote bool, ...) (string, error)

+ func ResolveStorageCommand(bin string, args []string, remotePath, localPath string) []string

+ type Client struct

+ func NewClient(ctx context.Context, impl Interface, successTimeWait time.Duration, ...) (_ *Client, err error)

+ func (c *Client) Close()

+ func (c *Client) Mount(ctx context.Context, remotePath, mountPoint string, onExited ExitHandleFunc) error

+ func (c *Client) Unmount(ctx context.Context, mountPoint string) error

+ type ClientConfig struct

+ Driver string

+ DriverConfig interface{}

+ ExtraLookupPaths []string

+ StderrFile string

+ StdoutFile string

+ SuccessTimeWait time.Duration

+ func (c *ClientConfig) CreateClient(ctx context.Context) (*Client, error)

+ func (c *ClientConfig) UnmarshalJSON(data []byte) error

+ func (c *ClientConfig) UnmarshalYAML(value *yaml.Node) error

+ type ConfigFactoryFunc func() interface

+ type ExitHandleFunc func(remotePath, mountPoint string, err error)

+ type FactoryFunc func(config interface{}) (Interface, error)

+ type Interface interface

+ GetMountCmd func(remotePath, mountPoint string) []string

+ GetUnmountCmd func(mountPoint string) []string

+ func NewDriver(name string, config interface{}) (Interface, error)

+ type NopConfig struct

+ type NopDriver struct

+ func (d *NopDriver) GetMountCmd(remotePath, mountPoint string) []string

+ func (d *NopDriver) GetUnmountCmd(mountPoint string) []string