block

package

v1.0.0 Latest Latest Go to latest Published: Jun 28, 2020 License: Apache-2.0 Imports: 16 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/asifdxtreme/nbp

Links

Open Source Insights

Documentation ¶

Index ¶

Constants
Variables
func CreateSymlink(device, mountpoint string) error
func ExtractFCInitiatorFromNodeInfo(nodeInfo string) ([]string, error)
func ExtractISCSIInitiatorFromNodeInfo(nodeInfo string) (string, error)
func ExtractNvmeofInitiatorFromNodeInfo(nodeInfo string) (string, error)
func NewServer(client *client.Client) (common.Service, error)
type Plugin
type Volume
- func NewVolume(c *client.Client) *Volume

Constants ¶

View Source

const (
	VolumeName          = "name"
	VolumeStatus        = "status"
	VolumeAZ            = "availabilityZone"
	VolumePoolId        = "poolId"
	VolumeProfileId     = "profileId"
	VolumeLvPath        = "lvPath"
	VolumeReplicationId = "replicationId"
)

CSI volume attribute keywords

View Source

const (
	AttachedVolumeId = "attachedVolumeId"
	AttachedId       = "attachedId"
)

Opensds replication metadata keywords

View Source

const (
	TargetPath        = "targetPath"
	StagingTargetPath = "stagingTargetPath"
)

Opensds Attachment metadata keywords

View Source

const (
	// parameters
	CSIVolumeMode = "CSIVolumeMode"

	// CSIVolumeMode = Filesystem
	CSIFilesystem = "Filesystem"

	// CSIVolumeMode = Block
	CSIBlock = "Block"
)

Csi configuration parameters and values

View Source

const (
	PluginName = "csi-opensdsplugin-block"
)

PluginName setting

View Source

const SecondaryPrefix = "secondary-"

volume prefix

Variables ¶

View Source

var TopologyZoneKey = "topology." + PluginName + "/zone"

Functions ¶

func CreateSymlink ¶

func CreateSymlink(device, mountpoint string) error

CreateSymlink Symlink implementation

func ExtractFCInitiatorFromNodeInfo ¶

func ExtractFCInitiatorFromNodeInfo(nodeInfo string) ([]string, error)

ExtractFCInitiatorFromNodeInfo implementation

func ExtractISCSIInitiatorFromNodeInfo ¶

func ExtractISCSIInitiatorFromNodeInfo(nodeInfo string) (string, error)

ExtractISCSIInitiatorFromNodeInfo implementation

func ExtractNvmeofInitiatorFromNodeInfo ¶

func ExtractNvmeofInitiatorFromNodeInfo(nodeInfo string) (string, error)

ExtractNvmeofInitiatorFromNodeInfo implementation

func NewServer ¶

func NewServer(client *client.Client) (common.Service, error)

NewServer Initialises and return plugin server

Types ¶

type Plugin ¶

type Plugin struct {
	VolumeClient *Volume
}

Plugin define

func (*Plugin) ControllerGetCapabilities ¶

func (p *Plugin) ControllerGetCapabilities(
	ctx context.Context,
	req *csi.ControllerGetCapabilitiesRequest) (
	*csi.ControllerGetCapabilitiesResponse, error)

ControllerGetCapabilities implementation

func (*Plugin) ControllerPublishVolume ¶

func (p *Plugin) ControllerPublishVolume(ctx context.Context,
	req *csi.ControllerPublishVolumeRequest) (
	*csi.ControllerPublishVolumeResponse, error)

ControllerPublishVolume implementation

func (*Plugin) ControllerUnpublishVolume ¶

func (p *Plugin) ControllerUnpublishVolume(
	ctx context.Context,
	req *csi.ControllerUnpublishVolumeRequest) (
	*csi.ControllerUnpublishVolumeResponse, error)

ControllerUnpublishVolume implementation

func (*Plugin) CreateSnapshot ¶

func (p *Plugin) CreateSnapshot(
	ctx context.Context,
	req *csi.CreateSnapshotRequest) (
	*csi.CreateSnapshotResponse, error)

CreateSnapshot implementation

func (*Plugin) CreateVolume ¶

func (p *Plugin) CreateVolume(
	ctx context.Context,
	req *csi.CreateVolumeRequest) (
	*csi.CreateVolumeResponse, error)

CreateVolume implementation

func (*Plugin) DeleteSnapshot ¶

func (p *Plugin) DeleteSnapshot(
	ctx context.Context,
	req *csi.DeleteSnapshotRequest) (
	*csi.DeleteSnapshotResponse, error)

DeleteSnapshot implementation

func (*Plugin) DeleteVolume ¶

func (p *Plugin) DeleteVolume(
	ctx context.Context,
	req *csi.DeleteVolumeRequest) (
	*csi.DeleteVolumeResponse, error)

DeleteVolume implementation

func (*Plugin) GetCapacity ¶

func (p *Plugin) GetCapacity(
	ctx context.Context,
	req *csi.GetCapacityRequest) (
	*csi.GetCapacityResponse, error)

GetCapacity implementation

func (*Plugin) GetPluginCapabilities ¶

func (p *Plugin) GetPluginCapabilities(
	ctx context.Context,
	req *csi.GetPluginCapabilitiesRequest) (
	*csi.GetPluginCapabilitiesResponse, error)

GetPluginCapabilities implementation

func (*Plugin) GetPluginInfo ¶

func (p *Plugin) GetPluginInfo(
	ctx context.Context,
	req *csi.GetPluginInfoRequest) (
	*csi.GetPluginInfoResponse, error)

GetPluginInfo implementation

func (*Plugin) ListSnapshots ¶

func (p *Plugin) ListSnapshots(
	ctx context.Context,
	req *csi.ListSnapshotsRequest) (
	*csi.ListSnapshotsResponse, error)

ListSnapshots implementation

func (*Plugin) ListVolumes ¶

func (p *Plugin) ListVolumes(
	ctx context.Context,
	req *csi.ListVolumesRequest) (
	*csi.ListVolumesResponse, error)

ListVolumes implementation

func (*Plugin) NodeGetCapabilities ¶

func (p *Plugin) NodeGetCapabilities(
	ctx context.Context,
	req *csi.NodeGetCapabilitiesRequest) (
	*csi.NodeGetCapabilitiesResponse, error)

NodeGetCapabilities implementation

func (*Plugin) NodeGetInfo ¶

func (p *Plugin) NodeGetInfo(
	ctx context.Context,
	req *csi.NodeGetInfoRequest) (
	*csi.NodeGetInfoResponse, error)

NodeGetInfo gets information on a node

func (*Plugin) NodeGetVolumeStats ¶

func (p *Plugin) NodeGetVolumeStats(
	ctx context.Context,
	req *csi.NodeGetVolumeStatsRequest) (
	*csi.NodeGetVolumeStatsResponse, error)

NodeGetVolumeStats implementation

func (*Plugin) NodePublishVolume ¶

func (p *Plugin) NodePublishVolume(
	ctx context.Context,
	req *csi.NodePublishVolumeRequest) (
	*csi.NodePublishVolumeResponse, error)

NodePublishVolume implementation

func (*Plugin) NodeStageVolume ¶

func (p *Plugin) NodeStageVolume(
	ctx context.Context,
	req *csi.NodeStageVolumeRequest) (
	*csi.NodeStageVolumeResponse, error)

NodeStageVolume implementation

func (*Plugin) NodeUnpublishVolume ¶

func (p *Plugin) NodeUnpublishVolume(
	ctx context.Context,
	req *csi.NodeUnpublishVolumeRequest) (
	*csi.NodeUnpublishVolumeResponse, error)

NodeUnpublishVolume implementation

func (*Plugin) NodeUnstageVolume ¶

func (p *Plugin) NodeUnstageVolume(
	ctx context.Context,
	req *csi.NodeUnstageVolumeRequest) (
	*csi.NodeUnstageVolumeResponse, error)

NodeUnstageVolume implementation

func (*Plugin) Probe ¶

func (p *Plugin) Probe(
	ctx context.Context,
	req *csi.ProbeRequest) (
	*csi.ProbeResponse, error)

Probe implementation

func (*Plugin) ValidateVolumeCapabilities ¶

func (p *Plugin) ValidateVolumeCapabilities(
	ctx context.Context,
	req *csi.ValidateVolumeCapabilitiesRequest) (
	*csi.ValidateVolumeCapabilitiesResponse, error)

ValidateVolumeCapabilities implementation

type Volume ¶

type Volume struct {
	Client *client.Client
}

func NewVolume ¶

func NewVolume(c *client.Client) *Volume

func (*Volume) ControllerPublishVolume ¶

func (v *Volume) ControllerPublishVolume(req *csi.ControllerPublishVolumeRequest) (*csi.ControllerPublishVolumeResponse, error)

ControllerPublishVolume implementation

func (*Volume) ControllerUnpublishVolume ¶

func (v *Volume) ControllerUnpublishVolume(req *csi.ControllerUnpublishVolumeRequest) (*csi.ControllerUnpublishVolumeResponse, error)

ControllerUnpublishVolume implementation

func (*Volume) CreateVolume ¶

func (v *Volume) CreateVolume(req *csi.CreateVolumeRequest) (*csi.CreateVolumeResponse, error)

CreateVolume implementation

func (*Volume) DeleteVolume ¶

func (v *Volume) DeleteVolume(volId string) (*csi.DeleteVolumeResponse, error)

DeleteVolume implementation

func (*Volume) FindVolume ¶

func (v *Volume) FindVolume(volName string) (*model.VolumeSpec, error)

FindVolume implementation

func (*Volume) ListVolumes ¶

func (v *Volume) ListVolumes(req *csi.ListVolumesRequest) (*csi.ListVolumesResponse, error)

ListVolumes implementation

func (*Volume) NodePublishVolume ¶

func (v *Volume) NodePublishVolume(req *csi.NodePublishVolumeRequest) (*csi.NodePublishVolumeResponse, error)

NodePublishVolume implementation

func (*Volume) NodeStageVolume ¶

func (v *Volume) NodeStageVolume(req *csi.NodeStageVolumeRequest) (*csi.NodeStageVolumeResponse, error)

NodeStageVolume implementation

func (*Volume) NodeUnpublishVolume ¶

func (v *Volume) NodeUnpublishVolume(req *csi.NodeUnpublishVolumeRequest) (*csi.NodeUnpublishVolumeResponse, error)

NodeUnpublishVolume implementation

func (*Volume) NodeUnstageVolume ¶

func (v *Volume) NodeUnstageVolume(req *csi.NodeUnstageVolumeRequest) (*csi.NodeUnstageVolumeResponse, error)

NodeUnstageVolume implementation

Source Files ¶

View all Source files

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