csi

Documentation

Overview

Package csi is a generated GoMock package.

Package csi is a generated GoMock package.

Index

• Constants
• type Driver
  • func New(nodeName string, namespace string, driverName string, sockAddr string, ...) Driver
• type MockDriver
  • func NewMockDriver(ctrl *gomock.Controller) *MockDriver
  • func (m *MockDriver) EXPECT() *MockDriverMockRecorder
  • func (m *MockDriver) Run(stopCh <-chan struct{})
• type MockDriverMockRecorder
  • func (mr *MockDriverMockRecorder) Run(stopCh interface{}) *gomock.Call
• type MockMounter
  • func NewMockMounter(ctrl *gomock.Controller) *MockMounter
  • func (m *MockMounter) BindMount(devPath, mountpoint string) error
  • func (m *MockMounter) EXPECT() *MockMounterMockRecorder
  • func (m *MockMounter) FormatAndMount(devPath, mountpoint, fsType string, flags []string) error
  • func (m *MockMounter) GetDeviceMountPoints(devPath string) []string
  • func (m *MockMounter) MountRawBlock(devPath, mountpoint string) error
  • func (m *MockMounter) Unmount(mountpoint string) error
• type MockMounterMockRecorder
  • func (mr *MockMounterMockRecorder) BindMount(devPath, mountpoint interface{}) *gomock.Call
  • func (mr *MockMounterMockRecorder) FormatAndMount(devPath, mountpoint, fsType, flags interface{}) *gomock.Call
  • func (mr *MockMounterMockRecorder) GetDeviceMountPoints(devPath interface{}) *gomock.Call
  • func (mr *MockMounterMockRecorder) MountRawBlock(devPath, mountpoint interface{}) *gomock.Call
  • func (mr *MockMounterMockRecorder) Unmount(mountpoint interface{}) *gomock.Call
• type Mounter
  • func NewLinuxMounter(logger *log.Entry) Mounter
• type RequestParameterHandler
• type Server
  • func NewGRPCServer(logger *log.Entry) Server
• type VolumeMetrics

Constants

const (
	VolumeReplicaDevicePathKey = "volumeReplicaDevicePath"
	VolumeReplicaNameKey       = "volumeReplicaName"
	VolumeReplicaKindKey       = "volumeReplicaKind"
)

consts

Types

type Driver

type Driver interface {
	Run(stopCh <-chan struct{})
}

Driver interface

func New

func New(nodeName string, namespace string, driverName string, sockAddr string, storageMember apis.LocalStorageMember, cli client.Client) Driver

New - create a new plugin instance

type MockDriver

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

MockDriver is a mock of Driver interface.

func NewMockDriver

func NewMockDriver(ctrl *gomock.Controller) *MockDriver

NewMockDriver creates a new mock instance.

func (*MockDriver) EXPECT

func (m *MockDriver) EXPECT() *MockDriverMockRecorder

EXPECT returns an object that allows the caller to indicate expected use.

func (*MockDriver) Run

func (m *MockDriver) Run(stopCh <-chan struct{})

Run mocks base method.

type MockDriverMockRecorder

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

MockDriverMockRecorder is the mock recorder for MockDriver.

func (*MockDriverMockRecorder) Run

func (mr *MockDriverMockRecorder) Run(stopCh interface{}) *gomock.Call

Run indicates an expected call of Run.

type MockMounter

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

MockMounter is a mock of Mounter interface.

func NewMockMounter

func NewMockMounter(ctrl *gomock.Controller) *MockMounter

NewMockMounter creates a new mock instance.

func (*MockMounter) BindMount

func (m *MockMounter) BindMount(devPath, mountpoint string) error

BindMount mocks base method.

func (*MockMounter) EXPECT

func (m *MockMounter) EXPECT() *MockMounterMockRecorder

EXPECT returns an object that allows the caller to indicate expected use.

func (*MockMounter) FormatAndMount

func (m *MockMounter) FormatAndMount(devPath, mountpoint, fsType string, flags []string) error

FormatAndMount mocks base method.

func (*MockMounter) GetDeviceMountPoints

func (m *MockMounter) GetDeviceMountPoints(devPath string) []string

GetDeviceMountPoints mocks base method.

func (*MockMounter) MountRawBlock

func (m *MockMounter) MountRawBlock(devPath, mountpoint string) error

MountRawBlock mocks base method.

func (*MockMounter) Unmount

func (m *MockMounter) Unmount(mountpoint string) error

Unmount mocks base method.

type MockMounterMockRecorder

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

MockMounterMockRecorder is the mock recorder for MockMounter.

func (*MockMounterMockRecorder) BindMount

func (mr *MockMounterMockRecorder) BindMount(devPath, mountpoint interface{}) *gomock.Call

BindMount indicates an expected call of BindMount.

func (*MockMounterMockRecorder) FormatAndMount

func (mr *MockMounterMockRecorder) FormatAndMount(devPath, mountpoint, fsType, flags interface{}) *gomock.Call

FormatAndMount indicates an expected call of FormatAndMount.

func (*MockMounterMockRecorder) GetDeviceMountPoints

func (mr *MockMounterMockRecorder) GetDeviceMountPoints(devPath interface{}) *gomock.Call

GetDeviceMountPoints indicates an expected call of GetDeviceMountPoints.

func (*MockMounterMockRecorder) MountRawBlock

func (mr *MockMounterMockRecorder) MountRawBlock(devPath, mountpoint interface{}) *gomock.Call

MountRawBlock indicates an expected call of MountRawBlock.

func (*MockMounterMockRecorder) Unmount

func (mr *MockMounterMockRecorder) Unmount(mountpoint interface{}) *gomock.Call

Unmount indicates an expected call of Unmount.

type Mounter

type Mounter interface {
	MountRawBlock(devPath string, mountpoint string) error
	BindMount(devPath string, mountpoint string) error
	FormatAndMount(devPath string, mountpoint string, fsType string, flags []string) error
	Unmount(mountpoint string) error
	GetDeviceMountPoints(devPath string) []string
}

Mounter interface

func NewLinuxMounter

func NewLinuxMounter(logger *log.Entry) Mounter

NewLinuxMounter creates a mounter

type RequestParameterHandler

type RequestParameterHandler interface {
	GetParameters() map[string]string
}

RequestParameterHandler interface

type Server

type Server interface {
	Init(endpoint string)
	Run(ids csi.IdentityServer, cs csi.ControllerServer, ns csi.NodeServer)
	GracefulStop()
	Stop()
}

Server - interface of grpc server which is for k8s communication

func NewGRPCServer

func NewGRPCServer(logger *log.Entry) Server

NewGRPCServer - create a grpc server instance

type VolumeMetrics

type VolumeMetrics struct {
	TotalCapacityBytes int64
	UsedCapacityBytes  int64
	FreeCapacityBytes  int64

	TotalINodeNumber int64
	UsedINodeNumber  int64
	FreeINodeNumber  int64
}

VolumeMetrics struct