csi

package
v0.2.1 Latest Latest
Warning

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

 Go to latest Published: Sep 10, 2022 License: MIT Imports: 19 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func StartGrpcServer 

func StartGrpcServer(endpoint string, vdaEndpoint string,
	enableCs bool, enableNs bool, nodeId string)

Types

type CnListenerConf 

type CnListenerConf struct {
	TrType  string `json:trtype`
	TrAddr  string `json:traddr`
	AdrFam  string `json:adrfam`
	TrSvcId string `json:trsvcid`
}

type ControllerServer 

type ControllerServer struct {
	csi.UnimplementedControllerServer
	// contains filtered or unexported fields
}

func (*ControllerServer) ControllerGetCapabilities 

func (cs *ControllerServer) ControllerGetCapabilities(
	ctx context.Context,
	req *csi.ControllerGetCapabilitiesRequest) (
	*csi.ControllerGetCapabilitiesResponse, error)

func (*ControllerServer) CreateVolume 

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

func (*ControllerServer) DeleteVolume 

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

type IdentityServer 

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

func (*IdentityServer) GetPluginCapabilities 

func (ids *IdentityServer) GetPluginCapabilities(ctx context.Context, req *csi.GetPluginCapabilitiesRequest) (*csi.GetPluginCapabilitiesResponse, error)

func (*IdentityServer) GetPluginInfo 

func (ids *IdentityServer) GetPluginInfo(ctx context.Context, req *csi.GetPluginInfoRequest) (*csi.GetPluginInfoResponse, error)

func (*IdentityServer) Probe 

func (ids *IdentityServer) Probe(ctx context.Context, req *csi.ProbeRequest) (*csi.ProbeResponse, error)

type NodeOperatorInterface 

type NodeOperatorInterface interface {
	ExecWithTimeout(cmdLine []string, timeout int, ctx context.Context) error
	CheckDeviceReady(devPath string) (bool, error)
	WaitForDeviceReady(devPath string, seconds int) error
	WaitForDeviceGone(devPath string, seconds int) error
	MountAndFormat(devPath, stagingPath, fsType string, mntFlags []string) error
	Mount(stagingPath, targetPath, fsType string, mntFlags []string) error
	DeleteMountPoint(path string) error
}

type NodeServer 

type NodeServer struct {
	csi.UnimplementedNodeServer
	// contains filtered or unexported fields
}

func (*NodeServer) NodeGetCapabilities 

func (ns *NodeServer) NodeGetCapabilities(
	ctx context.Context,
	req *csi.NodeGetCapabilitiesRequest) (
	*csi.NodeGetCapabilitiesResponse, error)

func (*NodeServer) NodeGetInfo 

func (ns *NodeServer) NodeGetInfo(
	ctx context.Context,
	req *csi.NodeGetInfoRequest) (
	*csi.NodeGetInfoResponse, error)

func (*NodeServer) NodePublishVolume 

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

func (*NodeServer) NodeStageVolume 

func (ns *NodeServer) NodeStageVolume(
	ctx context.Context,
	req *csi.NodeStageVolumeRequest) (
	*csi.NodeStageVolumeResponse, error)

func (*NodeServer) NodeUnpublishVolume 

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

func (*NodeServer) NodeUnstageVolume 

func (ns *NodeServer) NodeUnstageVolume(
	ctx context.Context,
	req *csi.NodeUnstageVolumeRequest) (
	*csi.NodeUnstageVolumeResponse, error)

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.
JackTT - Gopher 🇻🇳