Documentation
¶
Index ¶
- type Node
- func (d *Node) NodeExpandVolume(_ context.Context, _ *csi.NodeExpandVolumeRequest) (*csi.NodeExpandVolumeResponse, error)
- func (d *Node) NodeGetCapabilities(_ context.Context, _ *csi.NodeGetCapabilitiesRequest) (*csi.NodeGetCapabilitiesResponse, error)
- func (d *Node) NodeGetInfo(_ context.Context, _ *csi.NodeGetInfoRequest) (*csi.NodeGetInfoResponse, error)
- func (d *Node) NodeGetVolumeStats(_ context.Context, _ *csi.NodeGetVolumeStatsRequest) (*csi.NodeGetVolumeStatsResponse, error)
- func (d *Node) NodePublishVolume(ctx context.Context, request *csi.NodePublishVolumeRequest) (*csi.NodePublishVolumeResponse, error)
- func (d *Node) NodeStageVolume(_ context.Context, _ *csi.NodeStageVolumeRequest) (*csi.NodeStageVolumeResponse, error)
- func (d *Node) NodeUnpublishVolume(_ context.Context, request *csi.NodeUnpublishVolumeRequest) (*csi.NodeUnpublishVolumeResponse, error)
- func (d *Node) NodeUnstageVolume(_ context.Context, _ *csi.NodeUnstageVolumeRequest) (*csi.NodeUnstageVolumeResponse, error)
- type PublishFilesystem
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Node ¶
type Node struct {
csi.UnimplementedNodeServer
CrusoeClient *crusoeapi.APIClient
CrusoeHTTPClient *http.Client
HostInstance *crusoeapi.InstanceV1Alpha5
Mounter *mount.SafeFormatAndMount
Resizer *mount.ResizeFs
CrusoeAPIEndpoint string
NFSRemotePorts string
NFSHost string
DiskType common.DiskType
PluginName string
PluginVersion string
Capabilities []*csi.NodeServiceCapability
MaxVolumesPerNode int64
}
func (*Node) NodeExpandVolume ¶
func (d *Node) NodeExpandVolume(_ context.Context, _ *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 (*Node) NodeGetCapabilities ¶
func (d *Node) NodeGetCapabilities(_ context.Context, _ *csi.NodeGetCapabilitiesRequest) ( *csi.NodeGetCapabilitiesResponse, error, )
func (*Node) NodeGetInfo ¶
func (d *Node) NodeGetInfo(_ context.Context, _ *csi.NodeGetInfoRequest) (*csi.NodeGetInfoResponse, error)
func (*Node) NodeGetVolumeStats ¶
func (d *Node) NodeGetVolumeStats(_ context.Context, _ *csi.NodeGetVolumeStatsRequest) ( *csi.NodeGetVolumeStatsResponse, error, )
func (*Node) NodePublishVolume ¶
func (d *Node) NodePublishVolume(ctx context.Context, request *csi.NodePublishVolumeRequest) ( *csi.NodePublishVolumeResponse, error, )
func (*Node) NodeStageVolume ¶
func (d *Node) NodeStageVolume(_ context.Context, _ *csi.NodeStageVolumeRequest) ( *csi.NodeStageVolumeResponse, error, )
func (*Node) NodeUnpublishVolume ¶
func (d *Node) NodeUnpublishVolume(_ context.Context, request *csi.NodeUnpublishVolumeRequest) ( *csi.NodeUnpublishVolumeResponse, error, )
func (*Node) NodeUnstageVolume ¶
func (d *Node) NodeUnstageVolume(_ context.Context, _ *csi.NodeUnstageVolumeRequest) ( *csi.NodeUnstageVolumeResponse, error, )
type PublishFilesystem ¶
type PublishFilesystem struct {
Mounter *mount.SafeFormatAndMount
Resizer *mount.ResizeFs
Request *csi.NodePublishVolumeRequest
DevicePath string
NFSRemotePorts string
NFSHost string
MountOpts []string
NFSEnabled bool
}
func (*PublishFilesystem) Publish ¶
func (p *PublishFilesystem) Publish() error
Source Files
Click to show internal directories.
Click to hide internal directories.