node

Documentation

Index

• Variables
• func Readonly(vc *csi.VolumeCapability) bool
• type Block
• type Expand
• type Interface
• type Mount
• type MountResponse
• type Populate
• type Server
  • func New(nodeID string, maxVolumesPerNode int64, manager Interface) (*Server, error)
  • func (ns *Server) NodeExpandVolume(ctx context.Context, request *csi.NodeExpandVolumeRequest) (*csi.NodeExpandVolumeResponse, error)
  • func (ns *Server) NodeGetCapabilities(ctx context.Context, request *csi.NodeGetCapabilitiesRequest) (*csi.NodeGetCapabilitiesResponse, error)
  • func (ns *Server) NodeGetInfo(ctx context.Context, request *csi.NodeGetInfoRequest) (*csi.NodeGetInfoResponse, error)
  • func (ns *Server) NodeGetVolumeStats(ctx context.Context, request *csi.NodeGetVolumeStatsRequest) (*csi.NodeGetVolumeStatsResponse, error)
  • func (ns *Server) NodePublishVolume(ctx context.Context, req *csi.NodePublishVolumeRequest) (*csi.NodePublishVolumeResponse, error)
  • func (ns *Server) NodeStageVolume(ctx context.Context, req *csi.NodeStageVolumeRequest) (*csi.NodeStageVolumeResponse, error)
  • func (ns *Server) NodeUnpublishVolume(ctx context.Context, req *csi.NodeUnpublishVolumeRequest) (*csi.NodeUnpublishVolumeResponse, error)
  • func (ns *Server) NodeUnstageVolume(ctx context.Context, req *csi.NodeUnstageVolumeRequest) (*csi.NodeUnstageVolumeResponse, error)
• type Validate
• type Volume
• type VolumeResponse

Variables

var (
	ErrVolumeNotReady   = errors.New("volume is not yet ready to be setup")
	ErrNoImplementation = errors.New("no implementation")
)

Functions

func Readonly

func Readonly(vc *csi.VolumeCapability) bool

Types

type Block

type Block interface {
	AttachBlock(ctx context.Context, volumeContext map[string]string, controllerContext map[string]string, secrets map[string]string) (string, error)
	DetachBlock(ctx context.Context, path string) error
}

type Expand

type Expand interface {
	Expand()
}

type Interface

type Interface interface {
}

type Mount

type Mount interface {
	Mount(ctx context.Context, path string, fstype string, volumeContext map[string]string, controllerContext map[string]string, secrets map[string]string) (*MountResponse, error)
}

type MountResponse

type MountResponse struct {
	Source           string
	Fstype           string
	Options          []string
	SensitiveOptions []string
	Format           bool
}

type Populate

type Populate interface {
	Populate(ctx context.Context, path string, volumeContext map[string]string, controllerContext map[string]string, secrets map[string]string) error
}

type Server

type Server struct {
	DeviceUtils   mountmanager.DeviceUtils
	VolumeStatter mountmanager.Statter
	// contains filtered or unexported fields
}

func New

func New(nodeID string, maxVolumesPerNode int64, manager Interface) (*Server, error)

func (*Server) NodeExpandVolume

func (ns *Server) NodeExpandVolume(ctx context.Context, request *csi.NodeExpandVolumeRequest) (*csi.NodeExpandVolumeResponse, error)

func (*Server) NodeGetCapabilities

func (ns *Server) NodeGetCapabilities(ctx context.Context, request *csi.NodeGetCapabilitiesRequest) (*csi.NodeGetCapabilitiesResponse, error)

func (*Server) NodeGetInfo

func (ns *Server) NodeGetInfo(ctx context.Context, request *csi.NodeGetInfoRequest) (*csi.NodeGetInfoResponse, error)

func (*Server) NodeGetVolumeStats

func (ns *Server) NodeGetVolumeStats(ctx context.Context, request *csi.NodeGetVolumeStatsRequest) (*csi.NodeGetVolumeStatsResponse, error)

func (*Server) NodePublishVolume

func (ns *Server) NodePublishVolume(ctx context.Context, req *csi.NodePublishVolumeRequest) (*csi.NodePublishVolumeResponse, error)

func (*Server) NodeStageVolume

func (ns *Server) NodeStageVolume(ctx context.Context, req *csi.NodeStageVolumeRequest) (*csi.NodeStageVolumeResponse, error)

This operation MUST be idempotent https://github.com/container-storage-interface/spec/blob/master/spec.md#nodestagevolume

func (*Server) NodeUnpublishVolume

func (ns *Server) NodeUnpublishVolume(ctx context.Context, req *csi.NodeUnpublishVolumeRequest) (*csi.NodeUnpublishVolumeResponse, error)

func (*Server) NodeUnstageVolume

func (ns *Server) NodeUnstageVolume(ctx context.Context, req *csi.NodeUnstageVolumeRequest) (*csi.NodeUnstageVolumeResponse, error)

https://github.com/container-storage-interface/spec/blob/master/spec.md#nodeunstagevolume

type Validate

type Validate interface {
	ValidateCapability(vCap *csi.VolumeCapability) error
}

type Volume

type Volume struct {
	StagingPath   string
	PublishedPath string
}

type VolumeResponse

type VolumeResponse struct {
	Device string
	Mounts []struct {
		RelativePath     string
		Fstype           string
		Options          []string
		SensitiveOptions []string
	}
}