node

package
v1.4.6 Latest Latest
Warning

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

 Go to latest Published: Nov 20, 2021 License: AGPL-3.0 Imports: 26 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func AddDriveFinalizersWithConflictRetry added in v1.0.0 

func AddDriveFinalizersWithConflictRetry(ctx context.Context, csiDriveName string, finalizers []string, crdVersion string) error

AddDriveFinalizersWithConflictRetry - appends a finalizer to the csidrive's finalizers list

func CheckStatusEquality added in v1.2.1 

func CheckStatusEquality(existingConditions, newConditions []metav1.Condition) bool

func GetDiskFS added in v1.0.0 

func GetDiskFS(devicePath string) (string, error)

GetDiskFS - To get the filesystem of a block sys.ce

func GetLatestStatus added in v1.0.0 

func GetLatestStatus(statusXs []metav1.Condition) metav1.Condition

GetLatestStatus gets the latest condition by time

func RemoveDriveFinalizerWithConflictRetry added in v1.0.0 

func RemoveDriveFinalizerWithConflictRetry(ctx context.Context, csiDriveName string, finalizer, crdVersion string) error

RemoveDriveFinalizerWithConflictRetry - removes a finalizer from the csidrive's finalizers list

Types

type NodeServer 

type NodeServer struct {
	NodeID   string
	Identity string
	Rack     string
	Zone     string
	Region   string
	// contains filtered or unexported fields
}

func NewNodeServer 

func NewNodeServer(ctx context.Context, identity, nodeID, rack, zone, region string) (*NodeServer, error)

func (*NodeServer) NodeExpandVolume 

func (ns *NodeServer) NodeExpandVolume(ctx context.Context, in *csi.NodeExpandVolumeRequest) (*csi.NodeExpandVolumeResponse, error)

func (*NodeServer) NodeGetCapabilities 

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

func (*NodeServer) NodeGetInfo 

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

func (*NodeServer) NodeGetVolumeStats 

func (ns *NodeServer) NodeGetVolumeStats(ctx context.Context, req *csi.NodeGetVolumeStatsRequest) (*csi.NodeGetVolumeStatsResponse, error)

func (*NodeServer) NodePublishVolume 

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

func (*NodeServer) NodeStageVolume 

func (n *NodeServer) NodeStageVolume(ctx context.Context, req *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(ctx context.Context, req *csi.NodeUnstageVolumeRequest) (*csi.NodeUnstageVolumeResponse, error)

Source Files

View all Source files

Directories

Path Synopsis

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.