driver

func (*Driver) ControllerExpandVolume ¶

func (d *Driver) ControllerExpandVolume(
	ctx context.Context, req *csi.ControllerExpandVolumeRequest,
) (*csi.ControllerExpandVolumeResponse, error)

func (*Driver) ControllerGetCapabilities ¶

func (d *Driver) ControllerGetCapabilities(
	_ context.Context, _ *csi.ControllerGetCapabilitiesRequest,
) (*csi.ControllerGetCapabilitiesResponse, error)

func (*Driver) ControllerGetVolume ¶

func (d *Driver) ControllerGetVolume(
	_ context.Context, _ *csi.ControllerGetVolumeRequest,
) (*csi.ControllerGetVolumeResponse, error)

func (*Driver) ControllerPublishVolume ¶

func (d *Driver) ControllerPublishVolume(
	ctx context.Context, req *csi.ControllerPublishVolumeRequest,
) (*csi.ControllerPublishVolumeResponse, error)

func (*Driver) ControllerUnpublishVolume ¶

func (d *Driver) ControllerUnpublishVolume(
	ctx context.Context, req *csi.ControllerUnpublishVolumeRequest,
) (*csi.ControllerUnpublishVolumeResponse, error)

func (*Driver) CreateSnapshot ¶

func (d *Driver) CreateSnapshot(
	ctx context.Context, req *csi.CreateSnapshotRequest,
) (*csi.CreateSnapshotResponse, error)

func (*Driver) CreateVolume ¶

func (d *Driver) CreateVolume(
	ctx context.Context, req *csi.CreateVolumeRequest,
) (*csi.CreateVolumeResponse, error)

CreateVolume uses info extracted from request `parameters` field to connect to LB and attempt to create the volume specified by `name` field (or return info on an existing volume if one matches, for idempotency). see `lbCreateVolumeParams` for more details on the format.

TODO: on volume "clone" ops, the CSI spec seems to require that the plugin detect "incompatibility between `parameters` from the source and the ones requested for the new volume". unfortunately, the CSI spec does NOT supply the `parameters` of the source as part of the params to this call. it is unspecified how the plugin is supposed to pull this off.

TODO: it's also unclear what's the expected behaviour if a "clone" op is requested for a FS volume with a block mode vol or snap specified as a source. since the capabilities of the source volume are not passed in to this call either, how are plugins expected to detect such cases?

func (*Driver) DeleteSnapshot ¶

func (d *Driver) DeleteSnapshot(
	ctx context.Context, req *csi.DeleteSnapshotRequest,
) (*csi.DeleteSnapshotResponse, error)

func (*Driver) DeleteVolume ¶

func (d *Driver) DeleteVolume(
	ctx context.Context, req *csi.DeleteVolumeRequest,
) (*csi.DeleteVolumeResponse, error)

func (*Driver) GetCapacity ¶

func (d *Driver) GetCapacity(
	ctx context.Context, req *csi.GetCapacityRequest,
) (*csi.GetCapacityResponse, error)

func (*Driver) GetLBClient ¶

func (d *Driver) GetLBClient(
	ctx context.Context, mgmtEPs endpoint.Slice, mgmtScheme string,
) (lb.Client, error)

GetLBClient conjures up a functional LB mgmt API client by whatever means necessary. the errors it returns are gRPC-grade and can be returned directly to the remote CSI API clients.

func (*Driver) GetPluginCapabilities ¶

func (d *Driver) GetPluginCapabilities(
	_ context.Context, _ *csi.GetPluginCapabilitiesRequest,
) (*csi.GetPluginCapabilitiesResponse, error)

func (*Driver) GetPluginInfo ¶

func (d *Driver) GetPluginInfo(
	_ context.Context, _ *csi.GetPluginInfoRequest,
) (*csi.GetPluginInfoResponse, error)

func (*Driver) ListSnapshots ¶

func (d *Driver) ListSnapshots(
	_ context.Context, _ *csi.ListSnapshotsRequest,
) (*csi.ListSnapshotsResponse, error)

func (*Driver) ListVolumes ¶

func (d *Driver) ListVolumes(
	_ context.Context, _ *csi.ListVolumesRequest,
) (*csi.ListVolumesResponse, error)

func (*Driver) NodeExpandVolume ¶

func (d *Driver) NodeExpandVolume(
	_ context.Context, req *csi.NodeExpandVolumeRequest,
) (*csi.NodeExpandVolumeResponse, error)

func (*Driver) NodeGetCapabilities ¶

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

func (*Driver) NodeGetInfo ¶

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

func (*Driver) NodeGetVolumeStats ¶

func (d *Driver) NodeGetVolumeStats(
	ctx context.Context, req *csi.NodeGetVolumeStatsRequest,
) (*csi.NodeGetVolumeStatsResponse, error)

func (*Driver) NodePublishVolume ¶

func (d *Driver) NodePublishVolume(
	ctx context.Context, req *csi.NodePublishVolumeRequest,
) (*csi.NodePublishVolumeResponse, error)

TODO: see the wonderful mandated error codes table covering NodePublishVolume return value semantics... (NOT currently implemented that way!)

func (*Driver) NodeStageVolume ¶

func (d *Driver) NodeStageVolume(
	ctx context.Context, req *csi.NodeStageVolumeRequest,
) (*csi.NodeStageVolumeResponse, error)

NodeStageVolume obtains the necessary NVMe-oF target(s) endpoints from the LB mgmt API server(s) specified in `NodeStageVolumeRequest.volume_id`, then establishes data plane connections to them to attach the volume to the node. it will also format the volume with a specified FS, if necessary, or try to recover the FS (q.v. fsck) if an existing one is detected.

func (*Driver) NodeUnpublishVolume ¶

func (d *Driver) NodeUnpublishVolume(
	_ context.Context, req *csi.NodeUnpublishVolumeRequest,
) (*csi.NodeUnpublishVolumeResponse, error)

func (*Driver) NodeUnstageVolume ¶

func (d *Driver) NodeUnstageVolume(
	ctx context.Context, req *csi.NodeUnstageVolumeRequest,
) (*csi.NodeUnstageVolumeResponse, error)

func (*Driver) Probe ¶

func (d *Driver) Probe(
	_ context.Context, _ *csi.ProbeRequest,
) (*csi.ProbeResponse, error)

func (*Driver) PutLBClient ¶

func (d *Driver) PutLBClient(clnt lb.Client)

PutLBClient returns a client that necessarily must have been previously obtained using GetLBClient, with the understanding that the Driver will dispose of it as necessary at its discretion.

func (*Driver) Run ¶

func (d *Driver) Run() error

func (*Driver) ValidateVolumeCapabilities ¶

func (d *Driver) ValidateVolumeCapabilities(
	ctx context.Context, req *csi.ValidateVolumeCapabilitiesRequest,
) (*csi.ValidateVolumeCapabilitiesResponse, error)