package driver

import "k8s.io/kubernetes/test/e2e/storage/drivers/csi-test/driver"

Index

Variables 

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")
)

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, interceptor grpc.UnaryServerInterceptor) error

Start runs a gRPC server with all enabled services. If an interceptor is give, then it will be used. Otherwise, an interceptor which handles simple credential checks and logs gRPC calls in JSON format will be used.

func (*CSIDriver) Stop 

func (c *CSIDriver) Stop()

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 LogGRPC 

type LogGRPC func(method string, request, reply interface{}, err error)

type MockCSIDriver 

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

func NewMockCSIDriver 

func NewMockCSIDriver(servers *MockCSIDriverServers, interceptor grpc.UnaryServerInterceptor) *MockCSIDriver

func (*MockCSIDriver) Close 

func (m *MockCSIDriver) Close()

func (*MockCSIDriver) Start 

func (m *MockCSIDriver) Start() error

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

func (*MockCSIDriver) StartOnAddress 

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 {
	mock.Mock
}

MockControllerServer is an autogenerated mock type for the ControllerServer type

func NewMockControllerServer 

func NewMockControllerServer(t interface {
	mock.TestingT
	Cleanup(func())
}) *MockControllerServer

NewMockControllerServer creates a new instance of MockControllerServer. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations. The first argument is typically a *testing.T value.

func (*MockControllerServer) ControllerExpandVolume 

func (_m *MockControllerServer) ControllerExpandVolume(_a0 context.Context, _a1 *csi.ControllerExpandVolumeRequest) (*csi.ControllerExpandVolumeResponse, error)

ControllerExpandVolume provides a mock function with given fields: _a0, _a1

func (*MockControllerServer) ControllerGetCapabilities 

func (_m *MockControllerServer) ControllerGetCapabilities(_a0 context.Context, _a1 *csi.ControllerGetCapabilitiesRequest) (*csi.ControllerGetCapabilitiesResponse, error)

ControllerGetCapabilities provides a mock function with given fields: _a0, _a1

func (*MockControllerServer) ControllerGetVolume 

func (_m *MockControllerServer) ControllerGetVolume(_a0 context.Context, _a1 *csi.ControllerGetVolumeRequest) (*csi.ControllerGetVolumeResponse, error)

ControllerGetVolume provides a mock function with given fields: _a0, _a1

func (*MockControllerServer) ControllerModifyVolume 

func (_m *MockControllerServer) ControllerModifyVolume(_a0 context.Context, _a1 *csi.ControllerModifyVolumeRequest) (*csi.ControllerModifyVolumeResponse, error)

ControllerModifyVolume provides a mock function with given fields: _a0, _a1

func (*MockControllerServer) ControllerPublishVolume 

func (_m *MockControllerServer) ControllerPublishVolume(_a0 context.Context, _a1 *csi.ControllerPublishVolumeRequest) (*csi.ControllerPublishVolumeResponse, error)

ControllerPublishVolume provides a mock function with given fields: _a0, _a1

func (*MockControllerServer) ControllerUnpublishVolume 

func (_m *MockControllerServer) ControllerUnpublishVolume(_a0 context.Context, _a1 *csi.ControllerUnpublishVolumeRequest) (*csi.ControllerUnpublishVolumeResponse, error)

ControllerUnpublishVolume provides a mock function with given fields: _a0, _a1

func (*MockControllerServer) CreateSnapshot 

func (_m *MockControllerServer) CreateSnapshot(_a0 context.Context, _a1 *csi.CreateSnapshotRequest) (*csi.CreateSnapshotResponse, error)

CreateSnapshot provides a mock function with given fields: _a0, _a1

func (*MockControllerServer) CreateVolume 

func (_m *MockControllerServer) CreateVolume(_a0 context.Context, _a1 *csi.CreateVolumeRequest) (*csi.CreateVolumeResponse, error)

CreateVolume provides a mock function with given fields: _a0, _a1

func (*MockControllerServer) DeleteSnapshot 

func (_m *MockControllerServer) DeleteSnapshot(_a0 context.Context, _a1 *csi.DeleteSnapshotRequest) (*csi.DeleteSnapshotResponse, error)

DeleteSnapshot provides a mock function with given fields: _a0, _a1

func (*MockControllerServer) DeleteVolume 

func (_m *MockControllerServer) DeleteVolume(_a0 context.Context, _a1 *csi.DeleteVolumeRequest) (*csi.DeleteVolumeResponse, error)

DeleteVolume provides a mock function with given fields: _a0, _a1

func (*MockControllerServer) EXPECT 

func (_m *MockControllerServer) EXPECT() *MockControllerServer_Expecter

func (*MockControllerServer) GetCapacity 

func (_m *MockControllerServer) GetCapacity(_a0 context.Context, _a1 *csi.GetCapacityRequest) (*csi.GetCapacityResponse, error)

GetCapacity provides a mock function with given fields: _a0, _a1

func (*MockControllerServer) ListSnapshots 

func (_m *MockControllerServer) ListSnapshots(_a0 context.Context, _a1 *csi.ListSnapshotsRequest) (*csi.ListSnapshotsResponse, error)

ListSnapshots provides a mock function with given fields: _a0, _a1

func (*MockControllerServer) ListVolumes 

func (_m *MockControllerServer) ListVolumes(_a0 context.Context, _a1 *csi.ListVolumesRequest) (*csi.ListVolumesResponse, error)

ListVolumes provides a mock function with given fields: _a0, _a1

func (*MockControllerServer) ValidateVolumeCapabilities 

func (_m *MockControllerServer) ValidateVolumeCapabilities(_a0 context.Context, _a1 *csi.ValidateVolumeCapabilitiesRequest) (*csi.ValidateVolumeCapabilitiesResponse, error)

ValidateVolumeCapabilities provides a mock function with given fields: _a0, _a1

type MockControllerServer_ControllerExpandVolume_Call 

type MockControllerServer_ControllerExpandVolume_Call struct {
	*mock.Call
}

MockControllerServer_ControllerExpandVolume_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'ControllerExpandVolume'

func (*MockControllerServer_ControllerExpandVolume_Call) Return 

func (_c *MockControllerServer_ControllerExpandVolume_Call) Return(_a0 *csi.ControllerExpandVolumeResponse, _a1 error) *MockControllerServer_ControllerExpandVolume_Call

func (*MockControllerServer_ControllerExpandVolume_Call) Run 

func (_c *MockControllerServer_ControllerExpandVolume_Call) Run(run func(_a0 context.Context, _a1 *csi.ControllerExpandVolumeRequest)) *MockControllerServer_ControllerExpandVolume_Call

func (*MockControllerServer_ControllerExpandVolume_Call) RunAndReturn 

func (_c *MockControllerServer_ControllerExpandVolume_Call) RunAndReturn(run func(context.Context, *csi.ControllerExpandVolumeRequest) (*csi.ControllerExpandVolumeResponse, error)) *MockControllerServer_ControllerExpandVolume_Call

type MockControllerServer_ControllerGetCapabilities_Call 

type MockControllerServer_ControllerGetCapabilities_Call struct {
	*mock.Call
}

MockControllerServer_ControllerGetCapabilities_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'ControllerGetCapabilities'

func (*MockControllerServer_ControllerGetCapabilities_Call) Return 

func (_c *MockControllerServer_ControllerGetCapabilities_Call) Return(_a0 *csi.ControllerGetCapabilitiesResponse, _a1 error) *MockControllerServer_ControllerGetCapabilities_Call

func (*MockControllerServer_ControllerGetCapabilities_Call) Run 

func (_c *MockControllerServer_ControllerGetCapabilities_Call) Run(run func(_a0 context.Context, _a1 *csi.ControllerGetCapabilitiesRequest)) *MockControllerServer_ControllerGetCapabilities_Call

func (*MockControllerServer_ControllerGetCapabilities_Call) RunAndReturn 

func (_c *MockControllerServer_ControllerGetCapabilities_Call) RunAndReturn(run func(context.Context, *csi.ControllerGetCapabilitiesRequest) (*csi.ControllerGetCapabilitiesResponse, error)) *MockControllerServer_ControllerGetCapabilities_Call

type MockControllerServer_ControllerGetVolume_Call 

type MockControllerServer_ControllerGetVolume_Call struct {
	*mock.Call
}

MockControllerServer_ControllerGetVolume_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'ControllerGetVolume'

func (*MockControllerServer_ControllerGetVolume_Call) Return 

func (_c *MockControllerServer_ControllerGetVolume_Call) Return(_a0 *csi.ControllerGetVolumeResponse, _a1 error) *MockControllerServer_ControllerGetVolume_Call

func (*MockControllerServer_ControllerGetVolume_Call) Run 

func (_c *MockControllerServer_ControllerGetVolume_Call) Run(run func(_a0 context.Context, _a1 *csi.ControllerGetVolumeRequest)) *MockControllerServer_ControllerGetVolume_Call

func (*MockControllerServer_ControllerGetVolume_Call) RunAndReturn 

func (_c *MockControllerServer_ControllerGetVolume_Call) RunAndReturn(run func(context.Context, *csi.ControllerGetVolumeRequest) (*csi.ControllerGetVolumeResponse, error)) *MockControllerServer_ControllerGetVolume_Call

type MockControllerServer_ControllerModifyVolume_Call 

type MockControllerServer_ControllerModifyVolume_Call struct {
	*mock.Call
}

MockControllerServer_ControllerModifyVolume_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'ControllerModifyVolume'

func (*MockControllerServer_ControllerModifyVolume_Call) Return 

func (_c *MockControllerServer_ControllerModifyVolume_Call) Return(_a0 *csi.ControllerModifyVolumeResponse, _a1 error) *MockControllerServer_ControllerModifyVolume_Call

func (*MockControllerServer_ControllerModifyVolume_Call) Run 

func (_c *MockControllerServer_ControllerModifyVolume_Call) Run(run func(_a0 context.Context, _a1 *csi.ControllerModifyVolumeRequest)) *MockControllerServer_ControllerModifyVolume_Call

func (*MockControllerServer_ControllerModifyVolume_Call) RunAndReturn 

func (_c *MockControllerServer_ControllerModifyVolume_Call) RunAndReturn(run func(context.Context, *csi.ControllerModifyVolumeRequest) (*csi.ControllerModifyVolumeResponse, error)) *MockControllerServer_ControllerModifyVolume_Call

type MockControllerServer_ControllerPublishVolume_Call 

type MockControllerServer_ControllerPublishVolume_Call struct {
	*mock.Call
}

MockControllerServer_ControllerPublishVolume_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'ControllerPublishVolume'

func (*MockControllerServer_ControllerPublishVolume_Call) Return 

func (_c *MockControllerServer_ControllerPublishVolume_Call) Return(_a0 *csi.ControllerPublishVolumeResponse, _a1 error) *MockControllerServer_ControllerPublishVolume_Call

func (*MockControllerServer_ControllerPublishVolume_Call) Run 

func (_c *MockControllerServer_ControllerPublishVolume_Call) Run(run func(_a0 context.Context, _a1 *csi.ControllerPublishVolumeRequest)) *MockControllerServer_ControllerPublishVolume_Call

func (*MockControllerServer_ControllerPublishVolume_Call) RunAndReturn 

func (_c *MockControllerServer_ControllerPublishVolume_Call) RunAndReturn(run func(context.Context, *csi.ControllerPublishVolumeRequest) (*csi.ControllerPublishVolumeResponse, error)) *MockControllerServer_ControllerPublishVolume_Call

type MockControllerServer_ControllerUnpublishVolume_Call 

type MockControllerServer_ControllerUnpublishVolume_Call struct {
	*mock.Call
}

MockControllerServer_ControllerUnpublishVolume_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'ControllerUnpublishVolume'

func (*MockControllerServer_ControllerUnpublishVolume_Call) Return 

func (_c *MockControllerServer_ControllerUnpublishVolume_Call) Return(_a0 *csi.ControllerUnpublishVolumeResponse, _a1 error) *MockControllerServer_ControllerUnpublishVolume_Call

func (*MockControllerServer_ControllerUnpublishVolume_Call) Run 

func (_c *MockControllerServer_ControllerUnpublishVolume_Call) Run(run func(_a0 context.Context, _a1 *csi.ControllerUnpublishVolumeRequest)) *MockControllerServer_ControllerUnpublishVolume_Call

func (*MockControllerServer_ControllerUnpublishVolume_Call) RunAndReturn 

func (_c *MockControllerServer_ControllerUnpublishVolume_Call) RunAndReturn(run func(context.Context, *csi.ControllerUnpublishVolumeRequest) (*csi.ControllerUnpublishVolumeResponse, error)) *MockControllerServer_ControllerUnpublishVolume_Call

type MockControllerServer_CreateSnapshot_Call 

type MockControllerServer_CreateSnapshot_Call struct {
	*mock.Call
}

MockControllerServer_CreateSnapshot_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'CreateSnapshot'

func (*MockControllerServer_CreateSnapshot_Call) Return 

func (_c *MockControllerServer_CreateSnapshot_Call) Return(_a0 *csi.CreateSnapshotResponse, _a1 error) *MockControllerServer_CreateSnapshot_Call

func (*MockControllerServer_CreateSnapshot_Call) Run 

func (_c *MockControllerServer_CreateSnapshot_Call) Run(run func(_a0 context.Context, _a1 *csi.CreateSnapshotRequest)) *MockControllerServer_CreateSnapshot_Call

func (*MockControllerServer_CreateSnapshot_Call) RunAndReturn 

func (_c *MockControllerServer_CreateSnapshot_Call) RunAndReturn(run func(context.Context, *csi.CreateSnapshotRequest) (*csi.CreateSnapshotResponse, error)) *MockControllerServer_CreateSnapshot_Call

type MockControllerServer_CreateVolume_Call 

type MockControllerServer_CreateVolume_Call struct {
	*mock.Call
}

MockControllerServer_CreateVolume_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'CreateVolume'

func (*MockControllerServer_CreateVolume_Call) Return 

func (_c *MockControllerServer_CreateVolume_Call) Return(_a0 *csi.CreateVolumeResponse, _a1 error) *MockControllerServer_CreateVolume_Call

func (*MockControllerServer_CreateVolume_Call) Run 

func (_c *MockControllerServer_CreateVolume_Call) Run(run func(_a0 context.Context, _a1 *csi.CreateVolumeRequest)) *MockControllerServer_CreateVolume_Call

func (*MockControllerServer_CreateVolume_Call) RunAndReturn 

func (_c *MockControllerServer_CreateVolume_Call) RunAndReturn(run func(context.Context, *csi.CreateVolumeRequest) (*csi.CreateVolumeResponse, error)) *MockControllerServer_CreateVolume_Call

type MockControllerServer_DeleteSnapshot_Call 

type MockControllerServer_DeleteSnapshot_Call struct {
	*mock.Call
}

MockControllerServer_DeleteSnapshot_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'DeleteSnapshot'

func (*MockControllerServer_DeleteSnapshot_Call) Return 

func (_c *MockControllerServer_DeleteSnapshot_Call) Return(_a0 *csi.DeleteSnapshotResponse, _a1 error) *MockControllerServer_DeleteSnapshot_Call

func (*MockControllerServer_DeleteSnapshot_Call) Run 

func (_c *MockControllerServer_DeleteSnapshot_Call) Run(run func(_a0 context.Context, _a1 *csi.DeleteSnapshotRequest)) *MockControllerServer_DeleteSnapshot_Call

func (*MockControllerServer_DeleteSnapshot_Call) RunAndReturn 

func (_c *MockControllerServer_DeleteSnapshot_Call) RunAndReturn(run func(context.Context, *csi.DeleteSnapshotRequest) (*csi.DeleteSnapshotResponse, error)) *MockControllerServer_DeleteSnapshot_Call

type MockControllerServer_DeleteVolume_Call 

type MockControllerServer_DeleteVolume_Call struct {
	*mock.Call
}

MockControllerServer_DeleteVolume_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'DeleteVolume'

func (*MockControllerServer_DeleteVolume_Call) Return 

func (_c *MockControllerServer_DeleteVolume_Call) Return(_a0 *csi.DeleteVolumeResponse, _a1 error) *MockControllerServer_DeleteVolume_Call

func (*MockControllerServer_DeleteVolume_Call) Run 

func (_c *MockControllerServer_DeleteVolume_Call) Run(run func(_a0 context.Context, _a1 *csi.DeleteVolumeRequest)) *MockControllerServer_DeleteVolume_Call

func (*MockControllerServer_DeleteVolume_Call) RunAndReturn 

func (_c *MockControllerServer_DeleteVolume_Call) RunAndReturn(run func(context.Context, *csi.DeleteVolumeRequest) (*csi.DeleteVolumeResponse, error)) *MockControllerServer_DeleteVolume_Call

type MockControllerServer_Expecter 

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

func (*MockControllerServer_Expecter) ControllerExpandVolume 

func (_e *MockControllerServer_Expecter) ControllerExpandVolume(_a0 interface{}, _a1 interface{}) *MockControllerServer_ControllerExpandVolume_Call

ControllerExpandVolume is a helper method to define mock.On call

func (*MockControllerServer_Expecter) ControllerGetCapabilities 

func (_e *MockControllerServer_Expecter) ControllerGetCapabilities(_a0 interface{}, _a1 interface{}) *MockControllerServer_ControllerGetCapabilities_Call

ControllerGetCapabilities is a helper method to define mock.On call

func (*MockControllerServer_Expecter) ControllerGetVolume 

func (_e *MockControllerServer_Expecter) ControllerGetVolume(_a0 interface{}, _a1 interface{}) *MockControllerServer_ControllerGetVolume_Call

ControllerGetVolume is a helper method to define mock.On call

func (*MockControllerServer_Expecter) ControllerModifyVolume 

func (_e *MockControllerServer_Expecter) ControllerModifyVolume(_a0 interface{}, _a1 interface{}) *MockControllerServer_ControllerModifyVolume_Call

ControllerModifyVolume is a helper method to define mock.On call

func (*MockControllerServer_Expecter) ControllerPublishVolume 

func (_e *MockControllerServer_Expecter) ControllerPublishVolume(_a0 interface{}, _a1 interface{}) *MockControllerServer_ControllerPublishVolume_Call

ControllerPublishVolume is a helper method to define mock.On call

func (*MockControllerServer_Expecter) ControllerUnpublishVolume 

func (_e *MockControllerServer_Expecter) ControllerUnpublishVolume(_a0 interface{}, _a1 interface{}) *MockControllerServer_ControllerUnpublishVolume_Call

ControllerUnpublishVolume is a helper method to define mock.On call

func (*MockControllerServer_Expecter) CreateSnapshot 

func (_e *MockControllerServer_Expecter) CreateSnapshot(_a0 interface{}, _a1 interface{}) *MockControllerServer_CreateSnapshot_Call

CreateSnapshot is a helper method to define mock.On call

func (*MockControllerServer_Expecter) CreateVolume 

func (_e *MockControllerServer_Expecter) CreateVolume(_a0 interface{}, _a1 interface{}) *MockControllerServer_CreateVolume_Call

CreateVolume is a helper method to define mock.On call

func (*MockControllerServer_Expecter) DeleteSnapshot 

func (_e *MockControllerServer_Expecter) DeleteSnapshot(_a0 interface{}, _a1 interface{}) *MockControllerServer_DeleteSnapshot_Call

DeleteSnapshot is a helper method to define mock.On call

func (*MockControllerServer_Expecter) DeleteVolume 

func (_e *MockControllerServer_Expecter) DeleteVolume(_a0 interface{}, _a1 interface{}) *MockControllerServer_DeleteVolume_Call

DeleteVolume is a helper method to define mock.On call

func (*MockControllerServer_Expecter) GetCapacity 

func (_e *MockControllerServer_Expecter) GetCapacity(_a0 interface{}, _a1 interface{}) *MockControllerServer_GetCapacity_Call

GetCapacity is a helper method to define mock.On call

func (*MockControllerServer_Expecter) ListSnapshots 

func (_e *MockControllerServer_Expecter) ListSnapshots(_a0 interface{}, _a1 interface{}) *MockControllerServer_ListSnapshots_Call

ListSnapshots is a helper method to define mock.On call

func (*MockControllerServer_Expecter) ListVolumes 

func (_e *MockControllerServer_Expecter) ListVolumes(_a0 interface{}, _a1 interface{}) *MockControllerServer_ListVolumes_Call

ListVolumes is a helper method to define mock.On call

func (*MockControllerServer_Expecter) ValidateVolumeCapabilities 

func (_e *MockControllerServer_Expecter) ValidateVolumeCapabilities(_a0 interface{}, _a1 interface{}) *MockControllerServer_ValidateVolumeCapabilities_Call

ValidateVolumeCapabilities is a helper method to define mock.On call

type MockControllerServer_GetCapacity_Call 

type MockControllerServer_GetCapacity_Call struct {
	*mock.Call
}

MockControllerServer_GetCapacity_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'GetCapacity'

func (*MockControllerServer_GetCapacity_Call) Return 

func (_c *MockControllerServer_GetCapacity_Call) Return(_a0 *csi.GetCapacityResponse, _a1 error) *MockControllerServer_GetCapacity_Call

func (*MockControllerServer_GetCapacity_Call) Run 

func (_c *MockControllerServer_GetCapacity_Call) Run(run func(_a0 context.Context, _a1 *csi.GetCapacityRequest)) *MockControllerServer_GetCapacity_Call

func (*MockControllerServer_GetCapacity_Call) RunAndReturn 

func (_c *MockControllerServer_GetCapacity_Call) RunAndReturn(run func(context.Context, *csi.GetCapacityRequest) (*csi.GetCapacityResponse, error)) *MockControllerServer_GetCapacity_Call

type MockControllerServer_ListSnapshots_Call 

type MockControllerServer_ListSnapshots_Call struct {
	*mock.Call
}

MockControllerServer_ListSnapshots_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'ListSnapshots'

func (*MockControllerServer_ListSnapshots_Call) Return 

func (_c *MockControllerServer_ListSnapshots_Call) Return(_a0 *csi.ListSnapshotsResponse, _a1 error) *MockControllerServer_ListSnapshots_Call

func (*MockControllerServer_ListSnapshots_Call) Run 

func (_c *MockControllerServer_ListSnapshots_Call) Run(run func(_a0 context.Context, _a1 *csi.ListSnapshotsRequest)) *MockControllerServer_ListSnapshots_Call

func (*MockControllerServer_ListSnapshots_Call) RunAndReturn 

func (_c *MockControllerServer_ListSnapshots_Call) RunAndReturn(run func(context.Context, *csi.ListSnapshotsRequest) (*csi.ListSnapshotsResponse, error)) *MockControllerServer_ListSnapshots_Call

type MockControllerServer_ListVolumes_Call 

type MockControllerServer_ListVolumes_Call struct {
	*mock.Call
}

MockControllerServer_ListVolumes_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'ListVolumes'

func (*MockControllerServer_ListVolumes_Call) Return 

func (_c *MockControllerServer_ListVolumes_Call) Return(_a0 *csi.ListVolumesResponse, _a1 error) *MockControllerServer_ListVolumes_Call

func (*MockControllerServer_ListVolumes_Call) Run 

func (_c *MockControllerServer_ListVolumes_Call) Run(run func(_a0 context.Context, _a1 *csi.ListVolumesRequest)) *MockControllerServer_ListVolumes_Call

func (*MockControllerServer_ListVolumes_Call) RunAndReturn 

func (_c *MockControllerServer_ListVolumes_Call) RunAndReturn(run func(context.Context, *csi.ListVolumesRequest) (*csi.ListVolumesResponse, error)) *MockControllerServer_ListVolumes_Call

type MockControllerServer_ValidateVolumeCapabilities_Call 

type MockControllerServer_ValidateVolumeCapabilities_Call struct {
	*mock.Call
}

MockControllerServer_ValidateVolumeCapabilities_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'ValidateVolumeCapabilities'

func (*MockControllerServer_ValidateVolumeCapabilities_Call) Return 

func (_c *MockControllerServer_ValidateVolumeCapabilities_Call) Return(_a0 *csi.ValidateVolumeCapabilitiesResponse, _a1 error) *MockControllerServer_ValidateVolumeCapabilities_Call

func (*MockControllerServer_ValidateVolumeCapabilities_Call) Run 

func (_c *MockControllerServer_ValidateVolumeCapabilities_Call) Run(run func(_a0 context.Context, _a1 *csi.ValidateVolumeCapabilitiesRequest)) *MockControllerServer_ValidateVolumeCapabilities_Call

func (*MockControllerServer_ValidateVolumeCapabilities_Call) RunAndReturn 

func (_c *MockControllerServer_ValidateVolumeCapabilities_Call) RunAndReturn(run func(context.Context, *csi.ValidateVolumeCapabilitiesRequest) (*csi.ValidateVolumeCapabilitiesResponse, error)) *MockControllerServer_ValidateVolumeCapabilities_Call

type MockIdentityServer 

type MockIdentityServer struct {
	mock.Mock
}

MockIdentityServer is an autogenerated mock type for the IdentityServer type

func NewMockIdentityServer 

func NewMockIdentityServer(t interface {
	mock.TestingT
	Cleanup(func())
}) *MockIdentityServer

NewMockIdentityServer creates a new instance of MockIdentityServer. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations. The first argument is typically a *testing.T value.

func (*MockIdentityServer) EXPECT 

func (_m *MockIdentityServer) EXPECT() *MockIdentityServer_Expecter

func (*MockIdentityServer) GetPluginCapabilities 

func (_m *MockIdentityServer) GetPluginCapabilities(_a0 context.Context, _a1 *csi.GetPluginCapabilitiesRequest) (*csi.GetPluginCapabilitiesResponse, error)

GetPluginCapabilities provides a mock function with given fields: _a0, _a1

func (*MockIdentityServer) GetPluginInfo 

func (_m *MockIdentityServer) GetPluginInfo(_a0 context.Context, _a1 *csi.GetPluginInfoRequest) (*csi.GetPluginInfoResponse, error)

GetPluginInfo provides a mock function with given fields: _a0, _a1

func (*MockIdentityServer) Probe 

func (_m *MockIdentityServer) Probe(_a0 context.Context, _a1 *csi.ProbeRequest) (*csi.ProbeResponse, error)

Probe provides a mock function with given fields: _a0, _a1

type MockIdentityServer_Expecter 

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

func (*MockIdentityServer_Expecter) GetPluginCapabilities 

func (_e *MockIdentityServer_Expecter) GetPluginCapabilities(_a0 interface{}, _a1 interface{}) *MockIdentityServer_GetPluginCapabilities_Call

GetPluginCapabilities is a helper method to define mock.On call

func (*MockIdentityServer_Expecter) GetPluginInfo 

func (_e *MockIdentityServer_Expecter) GetPluginInfo(_a0 interface{}, _a1 interface{}) *MockIdentityServer_GetPluginInfo_Call

GetPluginInfo is a helper method to define mock.On call

func (*MockIdentityServer_Expecter) Probe 

func (_e *MockIdentityServer_Expecter) Probe(_a0 interface{}, _a1 interface{}) *MockIdentityServer_Probe_Call

Probe is a helper method to define mock.On call

type MockIdentityServer_GetPluginCapabilities_Call 

type MockIdentityServer_GetPluginCapabilities_Call struct {
	*mock.Call
}

MockIdentityServer_GetPluginCapabilities_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'GetPluginCapabilities'

func (*MockIdentityServer_GetPluginCapabilities_Call) Return 

func (_c *MockIdentityServer_GetPluginCapabilities_Call) Return(_a0 *csi.GetPluginCapabilitiesResponse, _a1 error) *MockIdentityServer_GetPluginCapabilities_Call

func (*MockIdentityServer_GetPluginCapabilities_Call) Run 

func (_c *MockIdentityServer_GetPluginCapabilities_Call) Run(run func(_a0 context.Context, _a1 *csi.GetPluginCapabilitiesRequest)) *MockIdentityServer_GetPluginCapabilities_Call

func (*MockIdentityServer_GetPluginCapabilities_Call) RunAndReturn 

func (_c *MockIdentityServer_GetPluginCapabilities_Call) RunAndReturn(run func(context.Context, *csi.GetPluginCapabilitiesRequest) (*csi.GetPluginCapabilitiesResponse, error)) *MockIdentityServer_GetPluginCapabilities_Call

type MockIdentityServer_GetPluginInfo_Call 

type MockIdentityServer_GetPluginInfo_Call struct {
	*mock.Call
}

MockIdentityServer_GetPluginInfo_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'GetPluginInfo'

func (*MockIdentityServer_GetPluginInfo_Call) Return 

func (_c *MockIdentityServer_GetPluginInfo_Call) Return(_a0 *csi.GetPluginInfoResponse, _a1 error) *MockIdentityServer_GetPluginInfo_Call

func (*MockIdentityServer_GetPluginInfo_Call) Run 

func (_c *MockIdentityServer_GetPluginInfo_Call) Run(run func(_a0 context.Context, _a1 *csi.GetPluginInfoRequest)) *MockIdentityServer_GetPluginInfo_Call

func (*MockIdentityServer_GetPluginInfo_Call) RunAndReturn 

func (_c *MockIdentityServer_GetPluginInfo_Call) RunAndReturn(run func(context.Context, *csi.GetPluginInfoRequest) (*csi.GetPluginInfoResponse, error)) *MockIdentityServer_GetPluginInfo_Call

type MockIdentityServer_Probe_Call 

type MockIdentityServer_Probe_Call struct {
	*mock.Call
}

MockIdentityServer_Probe_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Probe'

func (*MockIdentityServer_Probe_Call) Return 

func (_c *MockIdentityServer_Probe_Call) Return(_a0 *csi.ProbeResponse, _a1 error) *MockIdentityServer_Probe_Call

func (*MockIdentityServer_Probe_Call) Run 

func (_c *MockIdentityServer_Probe_Call) Run(run func(_a0 context.Context, _a1 *csi.ProbeRequest)) *MockIdentityServer_Probe_Call

func (*MockIdentityServer_Probe_Call) RunAndReturn 

func (_c *MockIdentityServer_Probe_Call) RunAndReturn(run func(context.Context, *csi.ProbeRequest) (*csi.ProbeResponse, error)) *MockIdentityServer_Probe_Call

type MockNodeServer 

type MockNodeServer struct {
	mock.Mock
}

MockNodeServer is an autogenerated mock type for the NodeServer type

func NewMockNodeServer 

func NewMockNodeServer(t interface {
	mock.TestingT
	Cleanup(func())
}) *MockNodeServer

NewMockNodeServer creates a new instance of MockNodeServer. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations. The first argument is typically a *testing.T value.

func (*MockNodeServer) EXPECT 

func (_m *MockNodeServer) EXPECT() *MockNodeServer_Expecter

func (*MockNodeServer) NodeExpandVolume 

func (_m *MockNodeServer) NodeExpandVolume(_a0 context.Context, _a1 *csi.NodeExpandVolumeRequest) (*csi.NodeExpandVolumeResponse, error)

NodeExpandVolume provides a mock function with given fields: _a0, _a1

func (*MockNodeServer) NodeGetCapabilities 

func (_m *MockNodeServer) NodeGetCapabilities(_a0 context.Context, _a1 *csi.NodeGetCapabilitiesRequest) (*csi.NodeGetCapabilitiesResponse, error)

NodeGetCapabilities provides a mock function with given fields: _a0, _a1

func (*MockNodeServer) NodeGetInfo 

func (_m *MockNodeServer) NodeGetInfo(_a0 context.Context, _a1 *csi.NodeGetInfoRequest) (*csi.NodeGetInfoResponse, error)

NodeGetInfo provides a mock function with given fields: _a0, _a1

func (*MockNodeServer) NodeGetVolumeStats 

func (_m *MockNodeServer) NodeGetVolumeStats(_a0 context.Context, _a1 *csi.NodeGetVolumeStatsRequest) (*csi.NodeGetVolumeStatsResponse, error)

NodeGetVolumeStats provides a mock function with given fields: _a0, _a1

func (*MockNodeServer) NodePublishVolume 

func (_m *MockNodeServer) NodePublishVolume(_a0 context.Context, _a1 *csi.NodePublishVolumeRequest) (*csi.NodePublishVolumeResponse, error)

NodePublishVolume provides a mock function with given fields: _a0, _a1

func (*MockNodeServer) NodeStageVolume 

func (_m *MockNodeServer) NodeStageVolume(_a0 context.Context, _a1 *csi.NodeStageVolumeRequest) (*csi.NodeStageVolumeResponse, error)

NodeStageVolume provides a mock function with given fields: _a0, _a1

func (*MockNodeServer) NodeUnpublishVolume 

func (_m *MockNodeServer) NodeUnpublishVolume(_a0 context.Context, _a1 *csi.NodeUnpublishVolumeRequest) (*csi.NodeUnpublishVolumeResponse, error)

NodeUnpublishVolume provides a mock function with given fields: _a0, _a1

func (*MockNodeServer) NodeUnstageVolume 

func (_m *MockNodeServer) NodeUnstageVolume(_a0 context.Context, _a1 *csi.NodeUnstageVolumeRequest) (*csi.NodeUnstageVolumeResponse, error)

NodeUnstageVolume provides a mock function with given fields: _a0, _a1

type MockNodeServer_Expecter 

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

func (*MockNodeServer_Expecter) NodeExpandVolume 

func (_e *MockNodeServer_Expecter) NodeExpandVolume(_a0 interface{}, _a1 interface{}) *MockNodeServer_NodeExpandVolume_Call

NodeExpandVolume is a helper method to define mock.On call

func (*MockNodeServer_Expecter) NodeGetCapabilities 

func (_e *MockNodeServer_Expecter) NodeGetCapabilities(_a0 interface{}, _a1 interface{}) *MockNodeServer_NodeGetCapabilities_Call

NodeGetCapabilities is a helper method to define mock.On call

func (*MockNodeServer_Expecter) NodeGetInfo 

func (_e *MockNodeServer_Expecter) NodeGetInfo(_a0 interface{}, _a1 interface{}) *MockNodeServer_NodeGetInfo_Call

NodeGetInfo is a helper method to define mock.On call

func (*MockNodeServer_Expecter) NodeGetVolumeStats 

func (_e *MockNodeServer_Expecter) NodeGetVolumeStats(_a0 interface{}, _a1 interface{}) *MockNodeServer_NodeGetVolumeStats_Call

NodeGetVolumeStats is a helper method to define mock.On call

func (*MockNodeServer_Expecter) NodePublishVolume 

func (_e *MockNodeServer_Expecter) NodePublishVolume(_a0 interface{}, _a1 interface{}) *MockNodeServer_NodePublishVolume_Call

NodePublishVolume is a helper method to define mock.On call

func (*MockNodeServer_Expecter) NodeStageVolume 

func (_e *MockNodeServer_Expecter) NodeStageVolume(_a0 interface{}, _a1 interface{}) *MockNodeServer_NodeStageVolume_Call

NodeStageVolume is a helper method to define mock.On call

func (*MockNodeServer_Expecter) NodeUnpublishVolume 

func (_e *MockNodeServer_Expecter) NodeUnpublishVolume(_a0 interface{}, _a1 interface{}) *MockNodeServer_NodeUnpublishVolume_Call

NodeUnpublishVolume is a helper method to define mock.On call

func (*MockNodeServer_Expecter) NodeUnstageVolume 

func (_e *MockNodeServer_Expecter) NodeUnstageVolume(_a0 interface{}, _a1 interface{}) *MockNodeServer_NodeUnstageVolume_Call

NodeUnstageVolume is a helper method to define mock.On call

type MockNodeServer_NodeExpandVolume_Call 

type MockNodeServer_NodeExpandVolume_Call struct {
	*mock.Call
}

MockNodeServer_NodeExpandVolume_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'NodeExpandVolume'

func (*MockNodeServer_NodeExpandVolume_Call) Return 

func (_c *MockNodeServer_NodeExpandVolume_Call) Return(_a0 *csi.NodeExpandVolumeResponse, _a1 error) *MockNodeServer_NodeExpandVolume_Call

func (*MockNodeServer_NodeExpandVolume_Call) Run 

func (_c *MockNodeServer_NodeExpandVolume_Call) Run(run func(_a0 context.Context, _a1 *csi.NodeExpandVolumeRequest)) *MockNodeServer_NodeExpandVolume_Call

func (*MockNodeServer_NodeExpandVolume_Call) RunAndReturn 

func (_c *MockNodeServer_NodeExpandVolume_Call) RunAndReturn(run func(context.Context, *csi.NodeExpandVolumeRequest) (*csi.NodeExpandVolumeResponse, error)) *MockNodeServer_NodeExpandVolume_Call

type MockNodeServer_NodeGetCapabilities_Call 

type MockNodeServer_NodeGetCapabilities_Call struct {
	*mock.Call
}

MockNodeServer_NodeGetCapabilities_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'NodeGetCapabilities'

func (*MockNodeServer_NodeGetCapabilities_Call) Return 

func (_c *MockNodeServer_NodeGetCapabilities_Call) Return(_a0 *csi.NodeGetCapabilitiesResponse, _a1 error) *MockNodeServer_NodeGetCapabilities_Call

func (*MockNodeServer_NodeGetCapabilities_Call) Run 

func (_c *MockNodeServer_NodeGetCapabilities_Call) Run(run func(_a0 context.Context, _a1 *csi.NodeGetCapabilitiesRequest)) *MockNodeServer_NodeGetCapabilities_Call

func (*MockNodeServer_NodeGetCapabilities_Call) RunAndReturn 

func (_c *MockNodeServer_NodeGetCapabilities_Call) RunAndReturn(run func(context.Context, *csi.NodeGetCapabilitiesRequest) (*csi.NodeGetCapabilitiesResponse, error)) *MockNodeServer_NodeGetCapabilities_Call

type MockNodeServer_NodeGetInfo_Call 

type MockNodeServer_NodeGetInfo_Call struct {
	*mock.Call
}

MockNodeServer_NodeGetInfo_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'NodeGetInfo'

func (*MockNodeServer_NodeGetInfo_Call) Return 

func (_c *MockNodeServer_NodeGetInfo_Call) Return(_a0 *csi.NodeGetInfoResponse, _a1 error) *MockNodeServer_NodeGetInfo_Call

func (*MockNodeServer_NodeGetInfo_Call) Run 

func (_c *MockNodeServer_NodeGetInfo_Call) Run(run func(_a0 context.Context, _a1 *csi.NodeGetInfoRequest)) *MockNodeServer_NodeGetInfo_Call

func (*MockNodeServer_NodeGetInfo_Call) RunAndReturn 

func (_c *MockNodeServer_NodeGetInfo_Call) RunAndReturn(run func(context.Context, *csi.NodeGetInfoRequest) (*csi.NodeGetInfoResponse, error)) *MockNodeServer_NodeGetInfo_Call

type MockNodeServer_NodeGetVolumeStats_Call 

type MockNodeServer_NodeGetVolumeStats_Call struct {
	*mock.Call
}

MockNodeServer_NodeGetVolumeStats_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'NodeGetVolumeStats'

func (*MockNodeServer_NodeGetVolumeStats_Call) Return 

func (_c *MockNodeServer_NodeGetVolumeStats_Call) Return(_a0 *csi.NodeGetVolumeStatsResponse, _a1 error) *MockNodeServer_NodeGetVolumeStats_Call

func (*MockNodeServer_NodeGetVolumeStats_Call) Run 

func (_c *MockNodeServer_NodeGetVolumeStats_Call) Run(run func(_a0 context.Context, _a1 *csi.NodeGetVolumeStatsRequest)) *MockNodeServer_NodeGetVolumeStats_Call

func (*MockNodeServer_NodeGetVolumeStats_Call) RunAndReturn 

func (_c *MockNodeServer_NodeGetVolumeStats_Call) RunAndReturn(run func(context.Context, *csi.NodeGetVolumeStatsRequest) (*csi.NodeGetVolumeStatsResponse, error)) *MockNodeServer_NodeGetVolumeStats_Call

type MockNodeServer_NodePublishVolume_Call 

type MockNodeServer_NodePublishVolume_Call struct {
	*mock.Call
}

MockNodeServer_NodePublishVolume_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'NodePublishVolume'

func (*MockNodeServer_NodePublishVolume_Call) Return 

func (_c *MockNodeServer_NodePublishVolume_Call) Return(_a0 *csi.NodePublishVolumeResponse, _a1 error) *MockNodeServer_NodePublishVolume_Call

func (*MockNodeServer_NodePublishVolume_Call) Run 

func (_c *MockNodeServer_NodePublishVolume_Call) Run(run func(_a0 context.Context, _a1 *csi.NodePublishVolumeRequest)) *MockNodeServer_NodePublishVolume_Call

func (*MockNodeServer_NodePublishVolume_Call) RunAndReturn 

func (_c *MockNodeServer_NodePublishVolume_Call) RunAndReturn(run func(context.Context, *csi.NodePublishVolumeRequest) (*csi.NodePublishVolumeResponse, error)) *MockNodeServer_NodePublishVolume_Call

type MockNodeServer_NodeStageVolume_Call 

type MockNodeServer_NodeStageVolume_Call struct {
	*mock.Call
}

MockNodeServer_NodeStageVolume_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'NodeStageVolume'

func (*MockNodeServer_NodeStageVolume_Call) Return 

func (_c *MockNodeServer_NodeStageVolume_Call) Return(_a0 *csi.NodeStageVolumeResponse, _a1 error) *MockNodeServer_NodeStageVolume_Call

func (*MockNodeServer_NodeStageVolume_Call) Run 

func (_c *MockNodeServer_NodeStageVolume_Call) Run(run func(_a0 context.Context, _a1 *csi.NodeStageVolumeRequest)) *MockNodeServer_NodeStageVolume_Call

func (*MockNodeServer_NodeStageVolume_Call) RunAndReturn 

func (_c *MockNodeServer_NodeStageVolume_Call) RunAndReturn(run func(context.Context, *csi.NodeStageVolumeRequest) (*csi.NodeStageVolumeResponse, error)) *MockNodeServer_NodeStageVolume_Call

type MockNodeServer_NodeUnpublishVolume_Call 

type MockNodeServer_NodeUnpublishVolume_Call struct {
	*mock.Call
}

MockNodeServer_NodeUnpublishVolume_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'NodeUnpublishVolume'

func (*MockNodeServer_NodeUnpublishVolume_Call) Return 

func (_c *MockNodeServer_NodeUnpublishVolume_Call) Return(_a0 *csi.NodeUnpublishVolumeResponse, _a1 error) *MockNodeServer_NodeUnpublishVolume_Call

func (*MockNodeServer_NodeUnpublishVolume_Call) Run 

func (_c *MockNodeServer_NodeUnpublishVolume_Call) Run(run func(_a0 context.Context, _a1 *csi.NodeUnpublishVolumeRequest)) *MockNodeServer_NodeUnpublishVolume_Call

func (*MockNodeServer_NodeUnpublishVolume_Call) RunAndReturn 

func (_c *MockNodeServer_NodeUnpublishVolume_Call) RunAndReturn(run func(context.Context, *csi.NodeUnpublishVolumeRequest) (*csi.NodeUnpublishVolumeResponse, error)) *MockNodeServer_NodeUnpublishVolume_Call

type MockNodeServer_NodeUnstageVolume_Call 

type MockNodeServer_NodeUnstageVolume_Call struct {
	*mock.Call
}

MockNodeServer_NodeUnstageVolume_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'NodeUnstageVolume'

func (*MockNodeServer_NodeUnstageVolume_Call) Return 

func (_c *MockNodeServer_NodeUnstageVolume_Call) Return(_a0 *csi.NodeUnstageVolumeResponse, _a1 error) *MockNodeServer_NodeUnstageVolume_Call

func (*MockNodeServer_NodeUnstageVolume_Call) Run 

func (_c *MockNodeServer_NodeUnstageVolume_Call) Run(run func(_a0 context.Context, _a1 *csi.NodeUnstageVolumeRequest)) *MockNodeServer_NodeUnstageVolume_Call

func (*MockNodeServer_NodeUnstageVolume_Call) RunAndReturn 

func (_c *MockNodeServer_NodeUnstageVolume_Call) RunAndReturn(run func(context.Context, *csi.NodeUnstageVolumeRequest) (*csi.NodeUnstageVolumeResponse, error)) *MockNodeServer_NodeUnstageVolume_Call

Source Files

driver.go mock.go mock_controller_server.go mock_identity_server.go mock_node_server.go

Version
v1.33.0 (latest)
Published
Apr 23, 2025
Platform
linux/amd64
Imports
11 packages
Last checked
5 hours ago –

Tools for package owners.