nas

package
v1.4.0 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Aug 12, 2020 License: Apache-2.0 Imports: 23 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

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

Functions

func DeleteUsageFullServers added in v1.3.0

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) CreateVolume

func (*ControllerServer) DeleteVolume

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 added in v1.2.0

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 added in v0.1.2

type NfsServer struct {
	Address string
	Path    string
}

func ParseServerList added in v0.1.2

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

parse ServerList that support multi servers in one SC

func SelectServer added in v0.1.2

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

func SelectServerRandom added in v0.1.2

func SelectServerRandom(servers []*NfsServer) *NfsServer

func SelectServerRoundRobin added in v0.1.2

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

type NodeServer

type NodeServer struct {
	*csicommon.DefaultNodeServer
}

func NewNodeServer

func NewNodeServer(d *NasDriver) *NodeServer

func (*NodeServer) NodePublishVolume

func (*NodeServer) NodeUnpublishVolume

type PublishOptions

type PublishOptions struct {
	NfsOpts
	NodePublishPath string
	AllowSharePath  bool
}

type VolumeCreateFilesystemOptions added in v1.2.0

type VolumeCreateFilesystemOptions struct {
	NfsFilesystemOpts
	VolumeAs string
}

type VolumeCreateSubpathOptions

type VolumeCreateSubpathOptions struct {
	NfsOpts
	VolumeAs string
}

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL