csi

package
v0.1.11 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Jun 24, 2022 License: Apache-2.0 Imports: 31 Imported by: 1

Documentation

Overview

Package csi is a generated GoMock package.

Package csi is a generated GoMock package.

Index

Constants

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

consts

Variables

This section is empty.

Functions

This section is empty.

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

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL