obs

Documentation

Index

• Constants
• Variables
• func PrintVersionAndExit1()
• type CommandRPC
• type Driver
  • func NewDriver(endpoint string, cloud *config.CloudCredentials) *Driver
  • func (d *Driver) AddControllerServiceCapabilities(cl []csi.ControllerServiceCapability_RPC_Type)
  • func (d *Driver) AddNodeServiceCapabilities(nl []csi.NodeServiceCapability_RPC_Type)
  • func (d *Driver) AddVolumeCapabilityAccessModes(vc []csi.VolumeCapability_AccessMode_Mode) []*csi.VolumeCapability_AccessMode
  • func (d *Driver) GetVolumeCapabilityAccessModes() []*csi.VolumeCapability_AccessMode
  • func (d *Driver) Run()
  • func (d *Driver) SetupDriver(mount mounts.IMount, metadata metadatas.IMetadata, mountClient http.Client)
  • func (d *Driver) ValidateControllerServiceRequest(c csi.ControllerServiceCapability_RPC_Type) error
• type NonBlockingGRPCServer
  • func NewNonBlockingGRPCServer() NonBlockingGRPCServer

Constants

const (
	ActionMount string = "mount"
)

const (
	SocketPath = "/var/lib/csi/connector.sock"
)

Variables

var Secret string

Secret is set by the linker flags in the Makefile.

Functions

func PrintVersionAndExit1

func PrintVersionAndExit1()

Types

type CommandRPC

type CommandRPC struct {
	Action     string
	Token      string
	Parameters map[string]string
}

type Driver

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

func NewDriver

func NewDriver(endpoint string, cloud *config.CloudCredentials) *Driver

func (*Driver) AddControllerServiceCapabilities

func (d *Driver) AddControllerServiceCapabilities(cl []csi.ControllerServiceCapability_RPC_Type)

func (*Driver) AddNodeServiceCapabilities

func (d *Driver) AddNodeServiceCapabilities(nl []csi.NodeServiceCapability_RPC_Type)

func (*Driver) AddVolumeCapabilityAccessModes

func (d *Driver) AddVolumeCapabilityAccessModes(vc []csi.VolumeCapability_AccessMode_Mode) []*csi.VolumeCapability_AccessMode

func (*Driver) GetVolumeCapabilityAccessModes

func (d *Driver) GetVolumeCapabilityAccessModes() []*csi.VolumeCapability_AccessMode

func (*Driver) Run

func (d *Driver) Run()

func (*Driver) SetupDriver

func (d *Driver) SetupDriver(mount mounts.IMount, metadata metadatas.IMetadata, mountClient http.Client)

func (*Driver) ValidateControllerServiceRequest

func (d *Driver) ValidateControllerServiceRequest(c csi.ControllerServiceCapability_RPC_Type) error

type NonBlockingGRPCServer

type NonBlockingGRPCServer interface {
	Start(endpoint string, ids csi.IdentityServer, cs csi.ControllerServer, ns csi.NodeServer)
	Wait()
	Stop()
	ForceStop()
}

NonBlockingGRPCServer defines Non blocking GRPC server interfaces

func NewNonBlockingGRPCServer

func NewNonBlockingGRPCServer() NonBlockingGRPCServer