internal

Documentation

Index

• func RegisterControllerMode(f ControllerInitFunc)
• type Controller
• type ControllerConfig
  • func GetControllerConfig(meta *metadata.Metadata) (*ControllerConfig, error)
• type ControllerFactory
  • func NewControllerFactory(config *ControllerConfig, defaultVolumeAs string) (*ControllerFactory, error)
  • func (fac *ControllerFactory) VolumeAs(what string) (Controller, error)
• type ControllerInitFunc
• type NodeConfig
  • func GetNodeConfig() (*NodeConfig, error)

Functions

func RegisterControllerMode

func RegisterControllerMode(f ControllerInitFunc)

Types

type Controller

type Controller interface {
	VolumeAs() string
	CreateVolume(context.Context, *csi.CreateVolumeRequest) (*csi.CreateVolumeResponse, error)
	DeleteVolume(context.Context, *csi.DeleteVolumeRequest, *corev1.PersistentVolume) (*csi.DeleteVolumeResponse, error)
	ControllerExpandVolume(context.Context, *csi.ControllerExpandVolumeRequest, *corev1.PersistentVolume) (*csi.ControllerExpandVolumeResponse, error)
}

type ControllerConfig

type ControllerConfig struct {
	// cluster info
	Region    string
	ClusterID string

	// subpath configs
	SkipSubpathCreation    bool
	EnableSubpathFinalizer bool

	// clients for kubernetes
	KubeClient kubernetes.Interface
	CNFSGetter cnfsv1beta1.CNFSGetter

	// clients for alibaba cloud
	NasClientFactory *cloud.NasClientFactory
}

func GetControllerConfig

func GetControllerConfig(meta *metadata.Metadata) (*ControllerConfig, error)

type ControllerFactory

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

func NewControllerFactory

func NewControllerFactory(config *ControllerConfig, defaultVolumeAs string) (*ControllerFactory, error)

func (*ControllerFactory) VolumeAs

func (fac *ControllerFactory) VolumeAs(what string) (Controller, error)

type ControllerInitFunc

type ControllerInitFunc func(*ControllerConfig) (Controller, error)

type NodeConfig

type NodeConfig struct {
	NodeName          string
	NodeIP            string
	EnableEFCCache    bool
	EnableMixRuntime  bool
	EnablePortCheck   bool
	EnableLosetup     bool
	EnableVolumeStats bool

	// clients for kubernetes
	KubeClient kubernetes.Interface
	CNFSGetter cnfsv1beta1.CNFSGetter
}

func GetNodeConfig

func GetNodeConfig() (*NodeConfig, error)