nas

Documentation

Index

• Variables
• func DeleteUsageFullServers(serverList []string, thresholdFloat64 float64) ([]string, error)
• type ControllerServer
  • func NewControllerServer(d *NasDriver) *ControllerServer
  • func (c ControllerServer) ControllerExpandVolume(context.Context, *csi.ControllerExpandVolumeRequest) (*csi.ControllerExpandVolumeResponse, error)
  • func (c *ControllerServer) CreateVolume(ctx context.Context, req *csi.CreateVolumeRequest) (*csi.CreateVolumeResponse, error)
  • func (c *ControllerServer) DeleteVolume(ctx context.Context, req *csi.DeleteVolumeRequest) (*csi.DeleteVolumeResponse, error)
  • func (c ControllerServer) ValidateVolumeCapabilities(ctx context.Context, req *csi.ValidateVolumeCapabilitiesRequest) (*csi.ValidateVolumeCapabilitiesResponse, error)
• type DeleteVolumeSubpathOptions
• type IdentityServer
  • func NewIdentityServer(d *NasDriver) *IdentityServer
• type NasDriver
  • func NewDriver(driverName, nodeId, endpoint string) *NasDriver
  • func (d *NasDriver) Run()
• type NfsFilesystemOpts
• type NfsOpts
• type NfsServer
  • func ParseServerList(serverList []string, thresholdFloat64 float64) ([]*NfsServer, error)
  • func SelectServer(servers []*NfsServer, uniqueSelectString string, strategy string) *NfsServer
  • func SelectServerRandom(servers []*NfsServer) *NfsServer
  • func SelectServerRoundRobin(servers []*NfsServer, uniqueSelectString string) *NfsServer
• type NodeServer
  • func NewNodeServer(d *NasDriver) *NodeServer
  • func (n *NodeServer) NodeExpandVolume(context.Context, *csi.NodeExpandVolumeRequest) (*csi.NodeExpandVolumeResponse, error)
  • func (n *NodeServer) NodePublishVolume(ctx context.Context, req *csi.NodePublishVolumeRequest) (*csi.NodePublishVolumeResponse, error)
  • func (n *NodeServer) NodeStageVolume(context.Context, *csi.NodeStageVolumeRequest) (*csi.NodeStageVolumeResponse, error)
  • func (n *NodeServer) NodeUnpublishVolume(ctx context.Context, req *csi.NodeUnpublishVolumeRequest) (*csi.NodeUnpublishVolumeResponse, error)
  • func (n *NodeServer) NodeUnstageVolume(context.Context, *csi.NodeUnstageVolumeRequest) (*csi.NodeUnstageVolumeResponse, error)
• type PublishOptions
• type VolumeCreateFilesystemOptions
• type VolumeCreateSubpathOptions

Variables

var (
	RR     = make(map[string]uint, 0)
	RRLock = sync.Mutex{}
)

Functions

func DeleteUsageFullServers

func DeleteUsageFullServers(serverList []string, thresholdFloat64 float64) ([]string, error)

Types

type ControllerServer

type ControllerServer struct {
	*csicommon.DefaultControllerServer
	Client *kubernetes.Clientset
}

func NewControllerServer

func NewControllerServer(d *NasDriver) *ControllerServer

func (ControllerServer) ControllerExpandVolume

func (c ControllerServer) ControllerExpandVolume(context.Context, *csi.ControllerExpandVolumeRequest) (*csi.ControllerExpandVolumeResponse, error)

func (*ControllerServer) CreateVolume

func (c *ControllerServer) CreateVolume(ctx context.Context, req *csi.CreateVolumeRequest) (*csi.CreateVolumeResponse, error)

func (*ControllerServer) DeleteVolume

func (c *ControllerServer) DeleteVolume(ctx context.Context, req *csi.DeleteVolumeRequest) (*csi.DeleteVolumeResponse, error)

func (ControllerServer) ValidateVolumeCapabilities

func (c ControllerServer) ValidateVolumeCapabilities(ctx context.Context, req *csi.ValidateVolumeCapabilitiesRequest) (*csi.ValidateVolumeCapabilitiesResponse, error)

type DeleteVolumeSubpathOptions

type DeleteVolumeSubpathOptions struct {
	Server          string
	Path            string
	Vers            string
	ArchiveOnDelete bool
}

type IdentityServer

type IdentityServer struct {
	*csicommon.DefaultIdentityServer
}

func NewIdentityServer

func NewIdentityServer(d *NasDriver) *IdentityServer

type NasDriver

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

func NewDriver

func NewDriver(driverName, nodeId, endpoint string) *NasDriver

func (*NasDriver) Run

func (d *NasDriver) Run()

type NfsFilesystemOpts

type NfsFilesystemOpts struct {
	ProtocolType string
	StorageType  string
	SiteID       string
	ClusterID    string
	DeleteNas    bool
}

type NfsOpts

type NfsOpts struct {
	Servers   string
	Server    string
	Path      string
	Vers      string
	Mode      string
	ModeType  string
	Options   string
	Strategy  string
	VolumeAs  string
	Threshold string
}

type NfsServer

type NfsServer struct {
	Address string
	Path    string
}

func ParseServerList

func ParseServerList(serverList []string, thresholdFloat64 float64) ([]*NfsServer, error)

parse ServerList that support multi servers in one SC

func SelectServer

func SelectServer(servers []*NfsServer, uniqueSelectString string, strategy string) *NfsServer

func SelectServerRandom

func SelectServerRandom(servers []*NfsServer) *NfsServer

func SelectServerRoundRobin

func SelectServerRoundRobin(servers []*NfsServer, uniqueSelectString string) *NfsServer

type NodeServer

type NodeServer struct {
	*csicommon.DefaultNodeServer
}

func NewNodeServer

func NewNodeServer(d *NasDriver) *NodeServer

func (*NodeServer) NodeExpandVolume

func (n *NodeServer) NodeExpandVolume(context.Context, *csi.NodeExpandVolumeRequest) (*csi.NodeExpandVolumeResponse, error)

func (*NodeServer) NodePublishVolume

func (n *NodeServer) NodePublishVolume(ctx context.Context, req *csi.NodePublishVolumeRequest) (*csi.NodePublishVolumeResponse, error)

func (*NodeServer) NodeStageVolume

func (n *NodeServer) NodeStageVolume(context.Context, *csi.NodeStageVolumeRequest) (
	*csi.NodeStageVolumeResponse, error)

func (*NodeServer) NodeUnpublishVolume

func (n *NodeServer) NodeUnpublishVolume(ctx context.Context, req *csi.NodeUnpublishVolumeRequest) (*csi.NodeUnpublishVolumeResponse, error)

func (*NodeServer) NodeUnstageVolume

func (n *NodeServer) NodeUnstageVolume(context.Context, *csi.NodeUnstageVolumeRequest) (
	*csi.NodeUnstageVolumeResponse, error)

type PublishOptions

type PublishOptions struct {
	NfsOpts
	NodePublishPath string
	AllowSharePath  bool
}

type VolumeCreateFilesystemOptions

type VolumeCreateFilesystemOptions struct {
	NfsFilesystemOpts
	VolumeAs string
}

type VolumeCreateSubpathOptions

type VolumeCreateSubpathOptions struct {
	NfsOpts
	VolumeAs string
}