node

package

v1.0.0-rc-3 Latest Latest Go to latest Published: Dec 23, 2020 License: AGPL-3.0 Imports: 27 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 FindDrives(ctx context.Context, nodeID string, procfs string) ([]direct_csi.DirectCSIDrive, error)
func FormatDevice(ctx context.Context, source, fsType string, force bool) error
func GetDiskFS(devicePath string) (string, error)
func GetLatestStatus(statusXs []metav1.Condition) metav1.Condition
func MountDevice(devicePath, mountPoint, fsType string, options []string) error
func PublishVolume(ctx context.Context, stagingPath, containerPath string, readOnly bool) error
func RemoveDriveFinalizerWithConflictRetry(ctx context.Context, csiDriveName string, finalizer string) error
func StageVolume(ctx context.Context, directCSIDrive *direct_csi.DirectCSIDrive, ...) (string, error)
func UnmountAllMountRefs(mountPoint string) error
func UnpublishVolume(ctx context.Context, containerPath string) error
func UnstageVolume(ctx context.Context, stagingPath string) error
func UpdateDriveStatusOnDiff(newObj direct_csi.DirectCSIDrive, existingObj *direct_csi.DirectCSIDrive) bool
type DirectCSIDriveListener
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) error

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

func FindDrives ¶

func FindDrives(ctx context.Context, nodeID string, procfs string) ([]direct_csi.DirectCSIDrive, error)

func FormatDevice ¶

func FormatDevice(ctx context.Context, source, fsType string, force bool) error

FormatDevice - Formats the given device

func GetDiskFS ¶ added in v1.0.0

func GetDiskFS(devicePath string) (string, error)

GetDiskFS - To get the filesystem of a block device

func GetLatestStatus ¶ added in v1.0.0

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

GetLatestStatus gets the latest condition by time

func MountDevice ¶

func MountDevice(devicePath, mountPoint, fsType string, options []string) error

MountDevice - Utility to mount a device in the given mountpoint

func PublishVolume ¶

func PublishVolume(ctx context.Context, stagingPath, containerPath string, readOnly bool) error

func RemoveDriveFinalizerWithConflictRetry ¶ added in v1.0.0

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

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

func StageVolume ¶

func StageVolume(ctx context.Context, directCSIDrive *direct_csi.DirectCSIDrive, stagingPath string, volumeID string) (string, error)

func UnmountAllMountRefs ¶

func UnmountAllMountRefs(mountPoint string) error

UnmountAllMountRefs - Unmount all mount refs. To avoid later mounts to overlap earlier mounts.

func UnpublishVolume ¶

func UnpublishVolume(ctx context.Context, containerPath string) error

func UnstageVolume ¶

func UnstageVolume(ctx context.Context, stagingPath string) error

func UpdateDriveStatusOnDiff ¶ added in v1.0.0

func UpdateDriveStatusOnDiff(newObj direct_csi.DirectCSIDrive, existingObj *direct_csi.DirectCSIDrive) bool

UpdateDriveStatusOnDiff Updates the drive status fields on diff.

Types ¶

type DirectCSIDriveListener ¶

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

func (*DirectCSIDriveListener) Add ¶

func (b *DirectCSIDriveListener) Add(ctx context.Context, obj *direct_csi.DirectCSIDrive) error

func (*DirectCSIDriveListener) Delete ¶

func (b *DirectCSIDriveListener) Delete(ctx context.Context, obj *direct_csi.DirectCSIDrive) error

func (*DirectCSIDriveListener) InitializeDirectCSIClient ¶

func (b *DirectCSIDriveListener) InitializeDirectCSIClient(bc clientset.Interface)

func (*DirectCSIDriveListener) InitializeKubeClient ¶

func (b *DirectCSIDriveListener) InitializeKubeClient(k kubeclientset.Interface)

func (*DirectCSIDriveListener) Update ¶

func (b *DirectCSIDriveListener) Update(ctx context.Context, old, new *direct_csi.DirectCSIDrive) error

type NodeServer ¶

type NodeServer struct {
	NodeID    string
	Identity  string
	Rack      string
	Zone      string
	Region    string
	BasePaths []string
}

func NewNodeServer ¶

func NewNodeServer(ctx context.Context, identity, nodeID, rack, zone, region string, basePaths []string, procfs 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

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