node

Documentation

Index

• func GetNodeId(l *log.Entry) (string, error)
• func GetStageStatus(stp string) bool
• func NodeGetServiceCapability(cap csi.NodeServiceCapability_RPC_Type) *csi.NodeServiceCapability
• type NodePlugin
  • func GetNodePlugin(l *log.Entry) (*NodePlugin, error)
  • func (np *NodePlugin) NodeExpandVolume(ctx context.Context, in *csi.NodeExpandVolumeRequest) (*csi.NodeExpandVolumeResponse, error)
  • func (ns *NodePlugin) NodeGetCapabilities(ctx context.Context, req *csi.NodeGetCapabilitiesRequest) (*csi.NodeGetCapabilitiesResponse, error)
  • func (np *NodePlugin) NodeGetInfo(ctx context.Context, req *csi.NodeGetInfoRequest) (*csi.NodeGetInfoResponse, error)
  • func (np *NodePlugin) NodeGetVolumeStats(ctx context.Context, in *csi.NodeGetVolumeStatsRequest) (*csi.NodeGetVolumeStatsResponse, error)
  • func (np *NodePlugin) NodePublishVolume(ctx context.Context, req *csi.NodePublishVolumeRequest) (*csi.NodePublishVolumeResponse, error)
  • func (np *NodePlugin) NodeStageVolume(ctx context.Context, req *csi.NodeStageVolumeRequest) (*csi.NodeStageVolumeResponse, error)
  • func (np *NodePlugin) NodeUnpublishVolume(ctx context.Context, req *csi.NodeUnpublishVolumeRequest) (*csi.NodeUnpublishVolumeResponse, error)
  • func (np *NodePlugin) NodeUnstageVolume(ctx context.Context, req *csi.NodeUnstageVolumeRequest) (*csi.NodeUnstageVolumeResponse, error)
• type Target
  • func GetTarget(l *log.Entry, tp string) (t *Target, err error)
  • func GetTargetFromPath(l *log.Entry, path string) (t *Target, err error)
  • func GetTargetFromReq(ctx context.Context, r interface{}) (t *Target, err error)
  • func (t *Target) DeSerializeTarget(stp string) error
  • func (t *Target) DeleteSerialization() (err error)
  • func (t *Target) FormatMountVolume(req *csi.NodePublishVolumeRequest) error
  • func (t *Target) SerializeTarget() error
  • func (t *Target) StageVolume(ctx context.Context) error
  • func (t *Target) UnMountVolume(ctx context.Context) error
  • func (t *Target) UnStageVolume(ctx context.Context) error

Functions

func GetNodeId

func GetNodeId(l *log.Entry) (string, error)

func GetStageStatus

func GetStageStatus(stp string) bool

GetStageStatus check if specified dir exists

func NodeGetServiceCapability

func NodeGetServiceCapability(cap csi.NodeServiceCapability_RPC_Type) *csi.NodeServiceCapability

NodeGetServiceCapability provides service capabilities

Types

type NodePlugin

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

NodePlugin responsible for attaching and detaching volumes to host

func GetNodePlugin

func GetNodePlugin(l *log.Entry) (*NodePlugin, error)

GetNodePlugin inits NodePlugin

func (*NodePlugin) NodeExpandVolume

func (np *NodePlugin) NodeExpandVolume(ctx context.Context, in *csi.NodeExpandVolumeRequest) (*csi.NodeExpandVolumeResponse, error)

NodeExpandVolume responsible for update of file system on volume

func (*NodePlugin) NodeGetCapabilities

func (ns *NodePlugin) NodeGetCapabilities(
	ctx context.Context,
	req *csi.NodeGetCapabilitiesRequest,
) (*csi.NodeGetCapabilitiesResponse, error)

NodeGetCapabilities provides node capabilities

func (*NodePlugin) NodeGetInfo

func (np *NodePlugin) NodeGetInfo(
	ctx context.Context,
	req *csi.NodeGetInfoRequest) (*csi.NodeGetInfoResponse, error)

NodeGetInfo returns node info

func (*NodePlugin) NodeGetVolumeStats

func (np *NodePlugin) NodeGetVolumeStats(ctx context.Context, in *csi.NodeGetVolumeStatsRequest) (*csi.NodeGetVolumeStatsResponse, error)

NodeGetVolumeStats volume total and available space

func (*NodePlugin) NodePublishVolume

func (np *NodePlugin) NodePublishVolume(
	ctx context.Context,
	req *csi.NodePublishVolumeRequest,
) (*csi.NodePublishVolumeResponse, error)

NodePublishVolume mount volume to target

func (*NodePlugin) NodeStageVolume

func (np *NodePlugin) NodeStageVolume(
	ctx context.Context,
	req *csi.NodeStageVolumeRequest,
) (*csi.NodeStageVolumeResponse, error)

NodeStageVolume introduce volume to host

func (*NodePlugin) NodeUnpublishVolume

func (np *NodePlugin) NodeUnpublishVolume(
	ctx context.Context,
	req *csi.NodeUnpublishVolumeRequest,
) (*csi.NodeUnpublishVolumeResponse, error)

NodeUnpublishVolume unmount volume

func (*NodePlugin) NodeUnstageVolume

func (np *NodePlugin) NodeUnstageVolume(
	ctx context.Context,
	req *csi.NodeUnstageVolumeRequest,
) (*csi.NodeUnstageVolumeResponse, error)

NodeUnstageVolume remove volume from host

type Target

type Target struct {
	STPath     string // Where target is staged
	TPath      string // Where target should be mounted
	DPath      string // Device representation in system
	Portal     string // ip of JovianDSS
	PortalPort string // port of JovianDSS
	Iqn        string // prefix part of iqn
	Lun        string // expected to be 0
	Tname      string // target name = volumeID
	// CoUser     string // Chap outgoing password
	// CoPass     string // Chap outgoing Password
	TProtocol string // tcp, others are not supported

	FsType     string   // Type of file system
	MountFlags []string // mount tool arguments
	// contains filtered or unexported fields
}

Target stores info about iscsi target

func GetTarget

func GetTarget(l *log.Entry, tp string) (t *Target, err error)

GetTarget constructs basic Target structure

func GetTargetFromPath

func GetTargetFromPath(l *log.Entry, path string) (t *Target, err error)

GetTargetFromPath recoinstruct Target on the basis of the path

func GetTargetFromReq

func GetTargetFromReq(ctx context.Context, r interface{}) (t *Target, err error)

GetTargetFromReq constructs Target structure from request data

func (*Target) DeSerializeTarget

func (t *Target) DeSerializeTarget(stp string) error

DeSerializeTarget restores Target form data file

func (*Target) DeleteSerialization

func (t *Target) DeleteSerialization() (err error)

DeleteSerialization deletes record file about target

func (*Target) FormatMountVolume

func (t *Target) FormatMountVolume(req *csi.NodePublishVolumeRequest) error

FormatMountVolume tries to check fs on volume and formats if not sutable been found

func (*Target) SerializeTarget

func (t *Target) SerializeTarget() error

SerializeTarget stores Target data to file

func (*Target) StageVolume

func (t *Target) StageVolume(ctx context.Context) error

StageVolume discovers iscsi target and attach it

func (*Target) UnMountVolume

func (t *Target) UnMountVolume(ctx context.Context) error

UnMountVolume unmounts volume

func (*Target) UnStageVolume

func (t *Target) UnStageVolume(ctx context.Context) error

UnStageVolume detachs iscsi target from host