driver

Documentation

Index

• Variables
• func CreateListener(csiEndpoint string) (net.Listener, error)
• func CreategRPCServer() *grpc.Server
• func Init(sanityTestRun bool, logLevel int, orasLog bool) error
• func StartService(service *Service, mode, csiEndpoint string) error
• type IdentityService
  • func (is *IdentityService) GetPluginCapabilities(ctx context.Context, req *csi.GetPluginCapabilitiesRequest) (*csi.GetPluginCapabilitiesResponse, error)
  • func (is *IdentityService) GetPluginInfo(ctx context.Context, req *csi.GetPluginInfoRequest) (*csi.GetPluginInfoResponse, error)
  • func (is *IdentityService) Probe(ctx context.Context, req *csi.ProbeRequest) (*csi.ProbeResponse, error)
• type NodeService
  • func NewNodeService(rootPath, pluginDataPath, nodeId string, handlersCount int, ...) (*NodeService, error)
  • func (ns *NodeService) NodeExpandVolume(ctx context.Context, req *csi.NodeExpandVolumeRequest) (*csi.NodeExpandVolumeResponse, error)
  • func (ns *NodeService) NodeGetCapabilities(ctx context.Context, req *csi.NodeGetCapabilitiesRequest) (*csi.NodeGetCapabilitiesResponse, error)
  • func (ns *NodeService) NodeGetInfo(ctx context.Context, req *csi.NodeGetInfoRequest) (*csi.NodeGetInfoResponse, error)
  • func (ns *NodeService) NodeGetVolumeStats(ctx context.Context, in *csi.NodeGetVolumeStatsRequest) (*csi.NodeGetVolumeStatsResponse, error)
  • func (ns *NodeService) NodePublishVolume(ctx context.Context, req *csi.NodePublishVolumeRequest) (*csi.NodePublishVolumeResponse, error)
  • func (ns *NodeService) NodeStageVolume(ctx context.Context, req *csi.NodeStageVolumeRequest) (*csi.NodeStageVolumeResponse, error)
  • func (ns *NodeService) NodeUnpublishVolume(ctx context.Context, req *csi.NodeUnpublishVolumeRequest) (*csi.NodeUnpublishVolumeResponse, error)
  • func (ns *NodeService) NodeUnstageVolume(ctx context.Context, req *csi.NodeUnstageVolumeRequest) (*csi.NodeUnstageVolumeResponse, error)
• type Service

Variables

var (
	DefaultMode              = "unspecified"
	DefaultCSISocket         = "unix:///var/lib/csi/sockets/pluginproxy/csi.sock"
	DefaultNodeID            = ""
	DefaultRootDir           = "/"
	DefaultPluginDataDir     = "/"
	DefaultHandlersCount     = 1
	DefaultSanityTestRun     = false
	DefaultLogLevel          = 5
	DefaultEnforceNamespaces = true
)

var OrasLog bool // enable logging

var SanityTestRun bool // is this a test run?

I think this refers to csi-sanity https://github.com/kubernetes-csi/csi-test/blob/v4.4.0/cmd/csi-sanity/main.go

Functions

func CreateListener

func CreateListener(csiEndpoint string) (net.Listener, error)

CreateListener create listener ready for communication over given csi endpoint

func CreategRPCServer

func CreategRPCServer() *grpc.Server

func Init

func Init(sanityTestRun bool, logLevel int, orasLog bool) error

Init primarily sets logging levels for TBA services

func StartService

func StartService(service *Service, mode, csiEndpoint string) error

Types

type IdentityService

type IdentityService struct {
	csi.UnimplementedIdentityServer
	Service
}

func (*IdentityService) GetPluginCapabilities

func (is *IdentityService) GetPluginCapabilities(ctx context.Context, req *csi.GetPluginCapabilitiesRequest) (*csi.GetPluginCapabilitiesResponse, error)

GetPluginCapabilities returns the message of what the csi provides

func (*IdentityService) GetPluginInfo

func (is *IdentityService) GetPluginInfo(ctx context.Context, req *csi.GetPluginInfoRequest) (*csi.GetPluginInfoResponse, error)

func (*IdentityService) Probe

func (is *IdentityService) Probe(ctx context.Context, req *csi.ProbeRequest) (*csi.ProbeResponse, error)

Probe indicates that the plugin is in a healthy state

type NodeService

type NodeService struct {
	csi.UnimplementedNodeServer
	Service
	// contains filtered or unexported fields
}

func NewNodeService

func NewNodeService(rootPath, pluginDataPath, nodeId string, handlersCount int, enforceNamespaces bool) (*NodeService, error)

NewNodeService creates the node service that runs on every node.

func (*NodeService) NodeExpandVolume

func (ns *NodeService) NodeExpandVolume(ctx context.Context, req *csi.NodeExpandVolumeRequest) (*csi.NodeExpandVolumeResponse, error)

NodeExpandVolume not implemented

func (*NodeService) NodeGetCapabilities

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

func (*NodeService) NodeGetInfo

func (ns *NodeService) NodeGetInfo(ctx context.Context, req *csi.NodeGetInfoRequest) (*csi.NodeGetInfoResponse, error)

NodeGetInfo returns the nodeid

func (*NodeService) NodeGetVolumeStats

func (ns *NodeService) NodeGetVolumeStats(ctx context.Context, in *csi.NodeGetVolumeStatsRequest) (*csi.NodeGetVolumeStatsResponse, error)

NodeGetVolumeStats not implemented

func (*NodeService) NodePublishVolume

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

func (*NodeService) NodeStageVolume

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

NodeStageVolume only exists to validate arguments

func (*NodeService) NodeUnpublishVolume

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

NodeUnpublishVolume removes the bind

func (*NodeService) NodeUnstageVolume

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

type Service

type Service interface{}