helper

Documentation

Index

• type DriverHelper
  • func NewDriverHelper() DriverHelper
• type Validator
  • func NewValidator() Validator

Types

type DriverHelper

type DriverHelper interface {
	GetValidator() Validator

	GetClientSet() (kubernetes.Interface, dynamic.Interface, error)
	GetMountCommand() string

	ParseJWTclaims(token string) (jwt.MapClaims, error)
	GetClaimValue(claims jwt.MapClaims, key string) (string, error)

	MarshaljSON(v interface{}) ([]byte, error)
	UnMarshaljSON(data []byte, v interface{}) error

	GetDatasetDirectoryNames(targetPath string) []string
	CheckMount(targetPath string) (bool, error)
	CleanMountPoint(targetPath string) error
	WaitForMount(path string, timeout time.Duration) error
	MkdirAll(path string, perm os.FileMode) error
	WriteFile(name, content string, flag int, perm os.FileMode) error
	FileStat(path string) (os.FileInfo, error)
	ReadDir(path string) ([]os.FileInfo, error)
	RemoveFile(path string) error
}

func NewDriverHelper

func NewDriverHelper() DriverHelper

type Validator

type Validator interface {
	CheckCreateVolumeAllowed(req *csi.CreateVolumeRequest) error
	CheckDeleteVolumeAllowed(req *csi.DeleteVolumeRequest) error
	CheckValidateVolumeCapabilitiesAllowed(req *csi.ValidateVolumeCapabilitiesRequest) error
}

func NewValidator

func NewValidator() Validator