node

package

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

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/minio/direct-csi

Links

Open Source Insights

Documentation ¶

Index ¶

func AddDriveFinalizersWithConflictRetry(ctx context.Context, csiDriveName string, finalizers []string, ...) error
func CheckStatusEquality(existingConditions, newConditions []metav1.Condition) bool
func GetDiskFS(devicePath string) (string, error)
func GetLatestStatus(statusXs []metav1.Condition) metav1.Condition
func RemoveDriveFinalizerWithConflictRetry(ctx context.Context, csiDriveName string, finalizer, crdVersion string) error
type NodeServer
- func NewNodeServer(ctx context.Context, identity, nodeID, rack, zone, region string) (*NodeServer, error)

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
discovery

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