csi

package
v0.14.2 Latest Latest
Warning

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

 Go to latest Published: Apr 1, 2024 License: Apache-2.0 Imports: 37 Imported by: 3

Documentation

Overview

Package csi is a generated GoMock package.

Package csi is a generated GoMock package.

Package csi is a generated GoMock package.

Index

Constants

View Source 
const (
	RetryInterval = 1 * time.Second
	// SnapshotSize 1 GB snapshot size by default
	SnapshotSize = "1073741824"
)
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 MockServer 

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

MockServer is a mock of Server interface.

func NewMockServer 

func NewMockServer(ctrl *gomock.Controller) *MockServer

NewMockServer creates a new mock instance.

func (*MockServer) EXPECT 

func (m *MockServer) EXPECT() *MockServerMockRecorder

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

func (*MockServer) GracefulStop 

func (m *MockServer) GracefulStop()

GracefulStop mocks base method.

func (*MockServer) Init 

func (m *MockServer) Init(endpoint string)

Init mocks base method.

func (*MockServer) Run 

func (m *MockServer) Run(ids csi.IdentityServer, cs csi.ControllerServer, ns csi.NodeServer)

Run mocks base method.

func (*MockServer) Stop 

func (m *MockServer) Stop()

Stop mocks base method.

type MockServerMockRecorder 

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

MockServerMockRecorder is the mock recorder for MockServer.

func (*MockServerMockRecorder) GracefulStop 

func (mr *MockServerMockRecorder) GracefulStop() *gomock.Call

GracefulStop indicates an expected call of GracefulStop.

func (*MockServerMockRecorder) Init 

func (mr *MockServerMockRecorder) Init(endpoint interface{}) *gomock.Call

Init indicates an expected call of Init.

func (*MockServerMockRecorder) Run 

func (mr *MockServerMockRecorder) Run(ids, cs, ns interface{}) *gomock.Call

Run indicates an expected call of Run.

func (*MockServerMockRecorder) Stop 

func (mr *MockServerMockRecorder) Stop() *gomock.Call

Stop indicates an expected call of Stop.

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

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.