driver

package
v2.2.0+incompatible Latest Latest
Warning

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

Go to latest
Published: Aug 8, 2019 License: Apache-2.0 Imports: 14 Imported by: 0

Documentation

Overview

Package driver is a generated GoMock package.

Index

Constants

This section is empty.

Variables

View Source
var (
	// ErrNoCredentials is the error when a secret is enabled but not passed in the request.
	ErrNoCredentials = errors.New("secret must be provided")
	// ErrAuthFailed is the error when the secret is incorrect.
	ErrAuthFailed = errors.New("authentication failed")
)

Functions

This section is empty.

Types

type CSICreds

type CSICreds struct {
	CreateVolumeSecret                         string
	DeleteVolumeSecret                         string
	ControllerPublishVolumeSecret              string
	ControllerUnpublishVolumeSecret            string
	NodeStageVolumeSecret                      string
	NodePublishVolumeSecret                    string
	CreateSnapshotSecret                       string
	DeleteSnapshotSecret                       string
	ControllerValidateVolumeCapabilitiesSecret string
}

CSICreds is a driver specific secret type. Drivers can have a key-val pair of secrets. This mock driver has a single string secret with secretField as the key.

type CSIDriver

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

func NewCSIDriver

func NewCSIDriver(servers *CSIDriverServers) *CSIDriver

func (*CSIDriver) Address

func (c *CSIDriver) Address() string

func (*CSIDriver) Close

func (c *CSIDriver) Close()

func (*CSIDriver) IsRunning

func (c *CSIDriver) IsRunning() bool

func (*CSIDriver) SetDefaultCreds

func (c *CSIDriver) SetDefaultCreds()

SetDefaultCreds sets the default secrets for CSI creds.

func (*CSIDriver) Start

func (c *CSIDriver) Start(l net.Listener) error

func (*CSIDriver) Stop

func (c *CSIDriver) Stop()

type CSIDriverController

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

CSIDriverController is the CSI Driver Controller backend.

func NewCSIDriverController

func NewCSIDriverController(controllerServer *CSIDriverControllerServer) *CSIDriverController

func (*CSIDriverController) Address

func (c *CSIDriverController) Address() string

func (*CSIDriverController) Close

func (c *CSIDriverController) Close()

func (*CSIDriverController) IsRunning

func (c *CSIDriverController) IsRunning() bool

func (*CSIDriverController) SetDefaultCreds

func (c *CSIDriverController) SetDefaultCreds()

func (*CSIDriverController) Start

func (c *CSIDriverController) Start(l net.Listener) error

func (*CSIDriverController) Stop

func (c *CSIDriverController) Stop()

type CSIDriverControllerServer

type CSIDriverControllerServer struct {
	Controller csi.ControllerServer
	Identity   csi.IdentityServer
}

CSIDriverControllerServer is the Controller service component of the driver.

type CSIDriverNode

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

CSIDriverNode is the CSI Driver Node backend.

func NewCSIDriverNode

func NewCSIDriverNode(nodeServer *CSIDriverNodeServer) *CSIDriverNode

func (*CSIDriverNode) Address

func (c *CSIDriverNode) Address() string

func (*CSIDriverNode) Close

func (c *CSIDriverNode) Close()

func (*CSIDriverNode) IsRunning

func (c *CSIDriverNode) IsRunning() bool

func (*CSIDriverNode) SetDefaultCreds

func (c *CSIDriverNode) SetDefaultCreds()

func (*CSIDriverNode) Start

func (c *CSIDriverNode) Start(l net.Listener) error

func (*CSIDriverNode) Stop

func (c *CSIDriverNode) Stop()

type CSIDriverNodeServer

type CSIDriverNodeServer struct {
	Node     csi.NodeServer
	Identity csi.IdentityServer
}

CSIDriverNodeServer is the Node service component of the driver.

type CSIDriverServers

type CSIDriverServers struct {
	Controller csi.ControllerServer
	Identity   csi.IdentityServer
	Node       csi.NodeServer
}

CSIDriverServers is a unified driver component with both Controller and Node services.

type MockCSIDriver

type MockCSIDriver struct {
	CSIDriver
	// contains filtered or unexported fields
}

func NewMockCSIDriver

func NewMockCSIDriver(servers *MockCSIDriverServers) *MockCSIDriver

func (*MockCSIDriver) Close

func (m *MockCSIDriver) Close()

func (*MockCSIDriver) Nexus

func (m *MockCSIDriver) Nexus() (*grpc.ClientConn, error)

func (*MockCSIDriver) Start

func (m *MockCSIDriver) Start() error

Start starts a new gRPC server listening on a random TCP loopback port.

func (*MockCSIDriver) StartOnAddress added in v1.0.3

func (m *MockCSIDriver) StartOnAddress(network, address string) error

StartOnAddress starts a new gRPC server listening on given address.

type MockCSIDriverServers

type MockCSIDriverServers struct {
	Controller *MockControllerServer
	Identity   *MockIdentityServer
	Node       *MockNodeServer
}

type MockControllerServer

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

MockControllerServer is a mock of ControllerServer interface

func NewMockControllerServer

func NewMockControllerServer(ctrl *gomock.Controller) *MockControllerServer

NewMockControllerServer creates a new mock instance

func (*MockControllerServer) ControllerExpandVolume added in v1.1.1

ControllerExpandVolume mocks base method

func (*MockControllerServer) ControllerGetCapabilities

ControllerGetCapabilities mocks base method

func (*MockControllerServer) ControllerPublishVolume

ControllerPublishVolume mocks base method

func (*MockControllerServer) ControllerUnpublishVolume

ControllerUnpublishVolume mocks base method

func (*MockControllerServer) CreateSnapshot

CreateSnapshot mocks base method

func (*MockControllerServer) CreateVolume

CreateVolume mocks base method

func (*MockControllerServer) DeleteSnapshot

DeleteSnapshot mocks base method

func (*MockControllerServer) DeleteVolume

DeleteVolume mocks base method

func (*MockControllerServer) EXPECT

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

func (*MockControllerServer) GetCapacity

GetCapacity mocks base method

func (*MockControllerServer) ListSnapshots

ListSnapshots mocks base method

func (*MockControllerServer) ListVolumes

ListVolumes mocks base method

func (*MockControllerServer) ValidateVolumeCapabilities

ValidateVolumeCapabilities mocks base method

type MockControllerServerMockRecorder

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

MockControllerServerMockRecorder is the mock recorder for MockControllerServer

func (*MockControllerServerMockRecorder) ControllerExpandVolume added in v1.1.1

func (mr *MockControllerServerMockRecorder) ControllerExpandVolume(arg0, arg1 interface{}) *gomock.Call

ControllerExpandVolume indicates an expected call of ControllerExpandVolume

func (*MockControllerServerMockRecorder) ControllerGetCapabilities

func (mr *MockControllerServerMockRecorder) ControllerGetCapabilities(arg0, arg1 interface{}) *gomock.Call

ControllerGetCapabilities indicates an expected call of ControllerGetCapabilities

func (*MockControllerServerMockRecorder) ControllerPublishVolume

func (mr *MockControllerServerMockRecorder) ControllerPublishVolume(arg0, arg1 interface{}) *gomock.Call

ControllerPublishVolume indicates an expected call of ControllerPublishVolume

func (*MockControllerServerMockRecorder) ControllerUnpublishVolume

func (mr *MockControllerServerMockRecorder) ControllerUnpublishVolume(arg0, arg1 interface{}) *gomock.Call

ControllerUnpublishVolume indicates an expected call of ControllerUnpublishVolume

func (*MockControllerServerMockRecorder) CreateSnapshot

func (mr *MockControllerServerMockRecorder) CreateSnapshot(arg0, arg1 interface{}) *gomock.Call

CreateSnapshot indicates an expected call of CreateSnapshot

func (*MockControllerServerMockRecorder) CreateVolume

func (mr *MockControllerServerMockRecorder) CreateVolume(arg0, arg1 interface{}) *gomock.Call

CreateVolume indicates an expected call of CreateVolume

func (*MockControllerServerMockRecorder) DeleteSnapshot

func (mr *MockControllerServerMockRecorder) DeleteSnapshot(arg0, arg1 interface{}) *gomock.Call

DeleteSnapshot indicates an expected call of DeleteSnapshot

func (*MockControllerServerMockRecorder) DeleteVolume

func (mr *MockControllerServerMockRecorder) DeleteVolume(arg0, arg1 interface{}) *gomock.Call

DeleteVolume indicates an expected call of DeleteVolume

func (*MockControllerServerMockRecorder) GetCapacity

func (mr *MockControllerServerMockRecorder) GetCapacity(arg0, arg1 interface{}) *gomock.Call

GetCapacity indicates an expected call of GetCapacity

func (*MockControllerServerMockRecorder) ListSnapshots

func (mr *MockControllerServerMockRecorder) ListSnapshots(arg0, arg1 interface{}) *gomock.Call

ListSnapshots indicates an expected call of ListSnapshots

func (*MockControllerServerMockRecorder) ListVolumes

func (mr *MockControllerServerMockRecorder) ListVolumes(arg0, arg1 interface{}) *gomock.Call

ListVolumes indicates an expected call of ListVolumes

func (*MockControllerServerMockRecorder) ValidateVolumeCapabilities

func (mr *MockControllerServerMockRecorder) ValidateVolumeCapabilities(arg0, arg1 interface{}) *gomock.Call

ValidateVolumeCapabilities indicates an expected call of ValidateVolumeCapabilities

type MockIdentityServer

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

MockIdentityServer is a mock of IdentityServer interface

func NewMockIdentityServer

func NewMockIdentityServer(ctrl *gomock.Controller) *MockIdentityServer

NewMockIdentityServer creates a new mock instance

func (*MockIdentityServer) EXPECT

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

func (*MockIdentityServer) GetPluginCapabilities

GetPluginCapabilities mocks base method

func (*MockIdentityServer) GetPluginInfo

GetPluginInfo mocks base method

func (*MockIdentityServer) Probe

Probe mocks base method

type MockIdentityServerMockRecorder

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

MockIdentityServerMockRecorder is the mock recorder for MockIdentityServer

func (*MockIdentityServerMockRecorder) GetPluginCapabilities

func (mr *MockIdentityServerMockRecorder) GetPluginCapabilities(arg0, arg1 interface{}) *gomock.Call

GetPluginCapabilities indicates an expected call of GetPluginCapabilities

func (*MockIdentityServerMockRecorder) GetPluginInfo

func (mr *MockIdentityServerMockRecorder) GetPluginInfo(arg0, arg1 interface{}) *gomock.Call

GetPluginInfo indicates an expected call of GetPluginInfo

func (*MockIdentityServerMockRecorder) Probe

func (mr *MockIdentityServerMockRecorder) Probe(arg0, arg1 interface{}) *gomock.Call

Probe indicates an expected call of Probe

type MockNodeServer

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

MockNodeServer is a mock of NodeServer interface

func NewMockNodeServer

func NewMockNodeServer(ctrl *gomock.Controller) *MockNodeServer

NewMockNodeServer creates a new mock instance

func (*MockNodeServer) EXPECT

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

func (*MockNodeServer) NodeExpandVolume added in v1.1.1

NodeExpandVolume mocks base method

func (*MockNodeServer) NodeGetCapabilities

NodeGetCapabilities mocks base method

func (*MockNodeServer) NodeGetInfo

NodeGetInfo mocks base method

func (*MockNodeServer) NodeGetVolumeStats added in v1.0.1

NodeGetVolumeStats mocks base method

func (*MockNodeServer) NodePublishVolume

NodePublishVolume mocks base method

func (*MockNodeServer) NodeStageVolume

NodeStageVolume mocks base method

func (*MockNodeServer) NodeUnpublishVolume

NodeUnpublishVolume mocks base method

func (*MockNodeServer) NodeUnstageVolume

NodeUnstageVolume mocks base method

type MockNodeServerMockRecorder

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

MockNodeServerMockRecorder is the mock recorder for MockNodeServer

func (*MockNodeServerMockRecorder) NodeExpandVolume added in v1.1.1

func (mr *MockNodeServerMockRecorder) NodeExpandVolume(arg0, arg1 interface{}) *gomock.Call

NodeExpandVolume indicates an expected call of NodeExpandVolume

func (*MockNodeServerMockRecorder) NodeGetCapabilities

func (mr *MockNodeServerMockRecorder) NodeGetCapabilities(arg0, arg1 interface{}) *gomock.Call

NodeGetCapabilities indicates an expected call of NodeGetCapabilities

func (*MockNodeServerMockRecorder) NodeGetInfo

func (mr *MockNodeServerMockRecorder) NodeGetInfo(arg0, arg1 interface{}) *gomock.Call

NodeGetInfo indicates an expected call of NodeGetInfo

func (*MockNodeServerMockRecorder) NodeGetVolumeStats added in v1.0.1

func (mr *MockNodeServerMockRecorder) NodeGetVolumeStats(arg0, arg1 interface{}) *gomock.Call

NodeGetVolumeStats indicates an expected call of NodeGetVolumeStats

func (*MockNodeServerMockRecorder) NodePublishVolume

func (mr *MockNodeServerMockRecorder) NodePublishVolume(arg0, arg1 interface{}) *gomock.Call

NodePublishVolume indicates an expected call of NodePublishVolume

func (*MockNodeServerMockRecorder) NodeStageVolume

func (mr *MockNodeServerMockRecorder) NodeStageVolume(arg0, arg1 interface{}) *gomock.Call

NodeStageVolume indicates an expected call of NodeStageVolume

func (*MockNodeServerMockRecorder) NodeUnpublishVolume

func (mr *MockNodeServerMockRecorder) NodeUnpublishVolume(arg0, arg1 interface{}) *gomock.Call

NodeUnpublishVolume indicates an expected call of NodeUnpublishVolume

func (*MockNodeServerMockRecorder) NodeUnstageVolume

func (mr *MockNodeServerMockRecorder) NodeUnstageVolume(arg0, arg1 interface{}) *gomock.Call

NodeUnstageVolume indicates an expected call of NodeUnstageVolume

Jump to

Keyboard shortcuts

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