node

Documentation

Index

• Variables
• type DefaultNode
  • func (d *DefaultNode) NodeExpandVolume(ctx context.Context, request *csi.NodeExpandVolumeRequest) (*csi.NodeExpandVolumeResponse, error)
  • func (d *DefaultNode) NodeGetCapabilities(_ context.Context, _ *csi.NodeGetCapabilitiesRequest) (*csi.NodeGetCapabilitiesResponse, error)
  • func (d *DefaultNode) NodeGetInfo(_ context.Context, _ *csi.NodeGetInfoRequest) (*csi.NodeGetInfoResponse, error)
  • func (d *DefaultNode) NodeGetVolumeStats(_ context.Context, _ *csi.NodeGetVolumeStatsRequest) (*csi.NodeGetVolumeStatsResponse, error)
  • func (d *DefaultNode) NodePublishVolume(_ context.Context, request *csi.NodePublishVolumeRequest) (*csi.NodePublishVolumeResponse, error)
  • func (d *DefaultNode) NodeStageVolume(_ context.Context, _ *csi.NodeStageVolumeRequest) (*csi.NodeStageVolumeResponse, error)
  • func (d *DefaultNode) NodeUnpublishVolume(_ context.Context, request *csi.NodeUnpublishVolumeRequest) (*csi.NodeUnpublishVolumeResponse, error)
  • func (d *DefaultNode) NodeUnstageVolume(_ context.Context, _ *csi.NodeUnstageVolumeRequest) (*csi.NodeUnstageVolumeResponse, error)

Variables

var ErrFailedResize = errors.New("failed to resize disk")

Types

type DefaultNode

type DefaultNode struct {
	csi.UnimplementedNodeServer
	CrusoeClient  *crusoeapi.APIClient
	HostInstance  *crusoeapi.InstanceV1Alpha5
	Mounter       *mount.SafeFormatAndMount
	Resizer       *mount.ResizeFs
	DiskType      common.DiskType
	PluginName    string
	PluginVersion string
	Capabilities  []*csi.NodeServiceCapability
}

func (*DefaultNode) NodeExpandVolume

func (d *DefaultNode) NodeExpandVolume(ctx context.Context, request *csi.NodeExpandVolumeRequest) (
	*csi.NodeExpandVolumeResponse,
	error,
)

NodeExpandVolume This function is currently unused. common.DiskTypeFS disks do not require expansion on the node. common.DiskTypeSSD disks would require expansion on the node if they supported online expansion.

func (*DefaultNode) NodeGetCapabilities

func (d *DefaultNode) NodeGetCapabilities(_ context.Context, _ *csi.NodeGetCapabilitiesRequest) (
	*csi.NodeGetCapabilitiesResponse,
	error,
)

func (*DefaultNode) NodeGetInfo

func (d *DefaultNode) NodeGetInfo(_ context.Context, _ *csi.NodeGetInfoRequest) (*csi.NodeGetInfoResponse, error)

func (*DefaultNode) NodeGetVolumeStats

func (d *DefaultNode) NodeGetVolumeStats(_ context.Context, _ *csi.NodeGetVolumeStatsRequest) (
	*csi.NodeGetVolumeStatsResponse,
	error,
)

func (*DefaultNode) NodePublishVolume

func (d *DefaultNode) NodePublishVolume(_ context.Context, request *csi.NodePublishVolumeRequest) (
	*csi.NodePublishVolumeResponse,
	error,
)

func (*DefaultNode) NodeStageVolume

func (d *DefaultNode) NodeStageVolume(_ context.Context, _ *csi.NodeStageVolumeRequest) (
	*csi.NodeStageVolumeResponse,
	error,
)

func (*DefaultNode) NodeUnpublishVolume

func (d *DefaultNode) NodeUnpublishVolume(_ context.Context, request *csi.NodeUnpublishVolumeRequest) (
	*csi.NodeUnpublishVolumeResponse,
	error,
)

func (*DefaultNode) NodeUnstageVolume

func (d *DefaultNode) NodeUnstageVolume(_ context.Context, _ *csi.NodeUnstageVolumeRequest) (
	*csi.NodeUnstageVolumeResponse,
	error,
)