Documentation ¶
Index ¶
- Variables
- type CSICreds
- type CSIDriver
- type CSIDriverServers
- type LogGRPC
- type MockCSIDriver
- type MockCSIDriverServers
- type MockControllerServer
- func (_m *MockControllerServer) ControllerExpandVolume(_a0 context.Context, _a1 *csi.ControllerExpandVolumeRequest) (*csi.ControllerExpandVolumeResponse, error)
- func (_m *MockControllerServer) ControllerGetCapabilities(_a0 context.Context, _a1 *csi.ControllerGetCapabilitiesRequest) (*csi.ControllerGetCapabilitiesResponse, error)
- func (_m *MockControllerServer) ControllerGetVolume(_a0 context.Context, _a1 *csi.ControllerGetVolumeRequest) (*csi.ControllerGetVolumeResponse, error)
- func (_m *MockControllerServer) ControllerModifyVolume(_a0 context.Context, _a1 *csi.ControllerModifyVolumeRequest) (*csi.ControllerModifyVolumeResponse, error)
- func (_m *MockControllerServer) ControllerPublishVolume(_a0 context.Context, _a1 *csi.ControllerPublishVolumeRequest) (*csi.ControllerPublishVolumeResponse, error)
- func (_m *MockControllerServer) ControllerUnpublishVolume(_a0 context.Context, _a1 *csi.ControllerUnpublishVolumeRequest) (*csi.ControllerUnpublishVolumeResponse, error)
- func (_m *MockControllerServer) CreateSnapshot(_a0 context.Context, _a1 *csi.CreateSnapshotRequest) (*csi.CreateSnapshotResponse, error)
- func (_m *MockControllerServer) CreateVolume(_a0 context.Context, _a1 *csi.CreateVolumeRequest) (*csi.CreateVolumeResponse, error)
- func (_m *MockControllerServer) DeleteSnapshot(_a0 context.Context, _a1 *csi.DeleteSnapshotRequest) (*csi.DeleteSnapshotResponse, error)
- func (_m *MockControllerServer) DeleteVolume(_a0 context.Context, _a1 *csi.DeleteVolumeRequest) (*csi.DeleteVolumeResponse, error)
- func (_m *MockControllerServer) EXPECT() *MockControllerServer_Expecter
- func (_m *MockControllerServer) GetCapacity(_a0 context.Context, _a1 *csi.GetCapacityRequest) (*csi.GetCapacityResponse, error)
- func (_m *MockControllerServer) ListSnapshots(_a0 context.Context, _a1 *csi.ListSnapshotsRequest) (*csi.ListSnapshotsResponse, error)
- func (_m *MockControllerServer) ListVolumes(_a0 context.Context, _a1 *csi.ListVolumesRequest) (*csi.ListVolumesResponse, error)
- func (_m *MockControllerServer) ValidateVolumeCapabilities(_a0 context.Context, _a1 *csi.ValidateVolumeCapabilitiesRequest) (*csi.ValidateVolumeCapabilitiesResponse, error)
- type MockControllerServer_ControllerExpandVolume_Call
- func (_c *MockControllerServer_ControllerExpandVolume_Call) Return(_a0 *csi.ControllerExpandVolumeResponse, _a1 error) *MockControllerServer_ControllerExpandVolume_Call
- func (_c *MockControllerServer_ControllerExpandVolume_Call) Run(run func(_a0 context.Context, _a1 *csi.ControllerExpandVolumeRequest)) *MockControllerServer_ControllerExpandVolume_Call
- func (_c *MockControllerServer_ControllerExpandVolume_Call) RunAndReturn(...) *MockControllerServer_ControllerExpandVolume_Call
- type MockControllerServer_ControllerGetCapabilities_Call
- func (_c *MockControllerServer_ControllerGetCapabilities_Call) Return(_a0 *csi.ControllerGetCapabilitiesResponse, _a1 error) *MockControllerServer_ControllerGetCapabilities_Call
- func (_c *MockControllerServer_ControllerGetCapabilities_Call) Run(run func(_a0 context.Context, _a1 *csi.ControllerGetCapabilitiesRequest)) *MockControllerServer_ControllerGetCapabilities_Call
- func (_c *MockControllerServer_ControllerGetCapabilities_Call) RunAndReturn(...) *MockControllerServer_ControllerGetCapabilities_Call
- type MockControllerServer_ControllerGetVolume_Call
- func (_c *MockControllerServer_ControllerGetVolume_Call) Return(_a0 *csi.ControllerGetVolumeResponse, _a1 error) *MockControllerServer_ControllerGetVolume_Call
- func (_c *MockControllerServer_ControllerGetVolume_Call) Run(run func(_a0 context.Context, _a1 *csi.ControllerGetVolumeRequest)) *MockControllerServer_ControllerGetVolume_Call
- func (_c *MockControllerServer_ControllerGetVolume_Call) RunAndReturn(...) *MockControllerServer_ControllerGetVolume_Call
- type MockControllerServer_ControllerModifyVolume_Call
- func (_c *MockControllerServer_ControllerModifyVolume_Call) Return(_a0 *csi.ControllerModifyVolumeResponse, _a1 error) *MockControllerServer_ControllerModifyVolume_Call
- func (_c *MockControllerServer_ControllerModifyVolume_Call) Run(run func(_a0 context.Context, _a1 *csi.ControllerModifyVolumeRequest)) *MockControllerServer_ControllerModifyVolume_Call
- func (_c *MockControllerServer_ControllerModifyVolume_Call) RunAndReturn(...) *MockControllerServer_ControllerModifyVolume_Call
- type MockControllerServer_ControllerPublishVolume_Call
- func (_c *MockControllerServer_ControllerPublishVolume_Call) Return(_a0 *csi.ControllerPublishVolumeResponse, _a1 error) *MockControllerServer_ControllerPublishVolume_Call
- func (_c *MockControllerServer_ControllerPublishVolume_Call) Run(run func(_a0 context.Context, _a1 *csi.ControllerPublishVolumeRequest)) *MockControllerServer_ControllerPublishVolume_Call
- func (_c *MockControllerServer_ControllerPublishVolume_Call) RunAndReturn(...) *MockControllerServer_ControllerPublishVolume_Call
- type MockControllerServer_ControllerUnpublishVolume_Call
- func (_c *MockControllerServer_ControllerUnpublishVolume_Call) Return(_a0 *csi.ControllerUnpublishVolumeResponse, _a1 error) *MockControllerServer_ControllerUnpublishVolume_Call
- func (_c *MockControllerServer_ControllerUnpublishVolume_Call) Run(run func(_a0 context.Context, _a1 *csi.ControllerUnpublishVolumeRequest)) *MockControllerServer_ControllerUnpublishVolume_Call
- func (_c *MockControllerServer_ControllerUnpublishVolume_Call) RunAndReturn(...) *MockControllerServer_ControllerUnpublishVolume_Call
- type MockControllerServer_CreateSnapshot_Call
- func (_c *MockControllerServer_CreateSnapshot_Call) Return(_a0 *csi.CreateSnapshotResponse, _a1 error) *MockControllerServer_CreateSnapshot_Call
- func (_c *MockControllerServer_CreateSnapshot_Call) Run(run func(_a0 context.Context, _a1 *csi.CreateSnapshotRequest)) *MockControllerServer_CreateSnapshot_Call
- func (_c *MockControllerServer_CreateSnapshot_Call) RunAndReturn(...) *MockControllerServer_CreateSnapshot_Call
- type MockControllerServer_CreateVolume_Call
- func (_c *MockControllerServer_CreateVolume_Call) Return(_a0 *csi.CreateVolumeResponse, _a1 error) *MockControllerServer_CreateVolume_Call
- func (_c *MockControllerServer_CreateVolume_Call) Run(run func(_a0 context.Context, _a1 *csi.CreateVolumeRequest)) *MockControllerServer_CreateVolume_Call
- func (_c *MockControllerServer_CreateVolume_Call) RunAndReturn(...) *MockControllerServer_CreateVolume_Call
- type MockControllerServer_DeleteSnapshot_Call
- func (_c *MockControllerServer_DeleteSnapshot_Call) Return(_a0 *csi.DeleteSnapshotResponse, _a1 error) *MockControllerServer_DeleteSnapshot_Call
- func (_c *MockControllerServer_DeleteSnapshot_Call) Run(run func(_a0 context.Context, _a1 *csi.DeleteSnapshotRequest)) *MockControllerServer_DeleteSnapshot_Call
- func (_c *MockControllerServer_DeleteSnapshot_Call) RunAndReturn(...) *MockControllerServer_DeleteSnapshot_Call
- type MockControllerServer_DeleteVolume_Call
- func (_c *MockControllerServer_DeleteVolume_Call) Return(_a0 *csi.DeleteVolumeResponse, _a1 error) *MockControllerServer_DeleteVolume_Call
- func (_c *MockControllerServer_DeleteVolume_Call) Run(run func(_a0 context.Context, _a1 *csi.DeleteVolumeRequest)) *MockControllerServer_DeleteVolume_Call
- func (_c *MockControllerServer_DeleteVolume_Call) RunAndReturn(...) *MockControllerServer_DeleteVolume_Call
- type MockControllerServer_Expecter
- func (_e *MockControllerServer_Expecter) ControllerExpandVolume(_a0 interface{}, _a1 interface{}) *MockControllerServer_ControllerExpandVolume_Call
- func (_e *MockControllerServer_Expecter) ControllerGetCapabilities(_a0 interface{}, _a1 interface{}) *MockControllerServer_ControllerGetCapabilities_Call
- func (_e *MockControllerServer_Expecter) ControllerGetVolume(_a0 interface{}, _a1 interface{}) *MockControllerServer_ControllerGetVolume_Call
- func (_e *MockControllerServer_Expecter) ControllerModifyVolume(_a0 interface{}, _a1 interface{}) *MockControllerServer_ControllerModifyVolume_Call
- func (_e *MockControllerServer_Expecter) ControllerPublishVolume(_a0 interface{}, _a1 interface{}) *MockControllerServer_ControllerPublishVolume_Call
- func (_e *MockControllerServer_Expecter) ControllerUnpublishVolume(_a0 interface{}, _a1 interface{}) *MockControllerServer_ControllerUnpublishVolume_Call
- func (_e *MockControllerServer_Expecter) CreateSnapshot(_a0 interface{}, _a1 interface{}) *MockControllerServer_CreateSnapshot_Call
- func (_e *MockControllerServer_Expecter) CreateVolume(_a0 interface{}, _a1 interface{}) *MockControllerServer_CreateVolume_Call
- func (_e *MockControllerServer_Expecter) DeleteSnapshot(_a0 interface{}, _a1 interface{}) *MockControllerServer_DeleteSnapshot_Call
- func (_e *MockControllerServer_Expecter) DeleteVolume(_a0 interface{}, _a1 interface{}) *MockControllerServer_DeleteVolume_Call
- func (_e *MockControllerServer_Expecter) GetCapacity(_a0 interface{}, _a1 interface{}) *MockControllerServer_GetCapacity_Call
- func (_e *MockControllerServer_Expecter) ListSnapshots(_a0 interface{}, _a1 interface{}) *MockControllerServer_ListSnapshots_Call
- func (_e *MockControllerServer_Expecter) ListVolumes(_a0 interface{}, _a1 interface{}) *MockControllerServer_ListVolumes_Call
- func (_e *MockControllerServer_Expecter) ValidateVolumeCapabilities(_a0 interface{}, _a1 interface{}) *MockControllerServer_ValidateVolumeCapabilities_Call
- type MockControllerServer_GetCapacity_Call
- func (_c *MockControllerServer_GetCapacity_Call) Return(_a0 *csi.GetCapacityResponse, _a1 error) *MockControllerServer_GetCapacity_Call
- func (_c *MockControllerServer_GetCapacity_Call) Run(run func(_a0 context.Context, _a1 *csi.GetCapacityRequest)) *MockControllerServer_GetCapacity_Call
- func (_c *MockControllerServer_GetCapacity_Call) RunAndReturn(...) *MockControllerServer_GetCapacity_Call
- type MockControllerServer_ListSnapshots_Call
- func (_c *MockControllerServer_ListSnapshots_Call) Return(_a0 *csi.ListSnapshotsResponse, _a1 error) *MockControllerServer_ListSnapshots_Call
- func (_c *MockControllerServer_ListSnapshots_Call) Run(run func(_a0 context.Context, _a1 *csi.ListSnapshotsRequest)) *MockControllerServer_ListSnapshots_Call
- func (_c *MockControllerServer_ListSnapshots_Call) RunAndReturn(...) *MockControllerServer_ListSnapshots_Call
- type MockControllerServer_ListVolumes_Call
- func (_c *MockControllerServer_ListVolumes_Call) Return(_a0 *csi.ListVolumesResponse, _a1 error) *MockControllerServer_ListVolumes_Call
- func (_c *MockControllerServer_ListVolumes_Call) Run(run func(_a0 context.Context, _a1 *csi.ListVolumesRequest)) *MockControllerServer_ListVolumes_Call
- func (_c *MockControllerServer_ListVolumes_Call) RunAndReturn(...) *MockControllerServer_ListVolumes_Call
- type MockControllerServer_ValidateVolumeCapabilities_Call
- func (_c *MockControllerServer_ValidateVolumeCapabilities_Call) Return(_a0 *csi.ValidateVolumeCapabilitiesResponse, _a1 error) *MockControllerServer_ValidateVolumeCapabilities_Call
- func (_c *MockControllerServer_ValidateVolumeCapabilities_Call) Run(run func(_a0 context.Context, _a1 *csi.ValidateVolumeCapabilitiesRequest)) *MockControllerServer_ValidateVolumeCapabilities_Call
- func (_c *MockControllerServer_ValidateVolumeCapabilities_Call) RunAndReturn(...) *MockControllerServer_ValidateVolumeCapabilities_Call
- type MockIdentityServer
- func (_m *MockIdentityServer) EXPECT() *MockIdentityServer_Expecter
- func (_m *MockIdentityServer) GetPluginCapabilities(_a0 context.Context, _a1 *csi.GetPluginCapabilitiesRequest) (*csi.GetPluginCapabilitiesResponse, error)
- func (_m *MockIdentityServer) GetPluginInfo(_a0 context.Context, _a1 *csi.GetPluginInfoRequest) (*csi.GetPluginInfoResponse, error)
- func (_m *MockIdentityServer) Probe(_a0 context.Context, _a1 *csi.ProbeRequest) (*csi.ProbeResponse, error)
- type MockIdentityServer_Expecter
- func (_e *MockIdentityServer_Expecter) GetPluginCapabilities(_a0 interface{}, _a1 interface{}) *MockIdentityServer_GetPluginCapabilities_Call
- func (_e *MockIdentityServer_Expecter) GetPluginInfo(_a0 interface{}, _a1 interface{}) *MockIdentityServer_GetPluginInfo_Call
- func (_e *MockIdentityServer_Expecter) Probe(_a0 interface{}, _a1 interface{}) *MockIdentityServer_Probe_Call
- type MockIdentityServer_GetPluginCapabilities_Call
- func (_c *MockIdentityServer_GetPluginCapabilities_Call) Return(_a0 *csi.GetPluginCapabilitiesResponse, _a1 error) *MockIdentityServer_GetPluginCapabilities_Call
- func (_c *MockIdentityServer_GetPluginCapabilities_Call) Run(run func(_a0 context.Context, _a1 *csi.GetPluginCapabilitiesRequest)) *MockIdentityServer_GetPluginCapabilities_Call
- func (_c *MockIdentityServer_GetPluginCapabilities_Call) RunAndReturn(...) *MockIdentityServer_GetPluginCapabilities_Call
- type MockIdentityServer_GetPluginInfo_Call
- func (_c *MockIdentityServer_GetPluginInfo_Call) Return(_a0 *csi.GetPluginInfoResponse, _a1 error) *MockIdentityServer_GetPluginInfo_Call
- func (_c *MockIdentityServer_GetPluginInfo_Call) Run(run func(_a0 context.Context, _a1 *csi.GetPluginInfoRequest)) *MockIdentityServer_GetPluginInfo_Call
- func (_c *MockIdentityServer_GetPluginInfo_Call) RunAndReturn(...) *MockIdentityServer_GetPluginInfo_Call
- type MockIdentityServer_Probe_Call
- func (_c *MockIdentityServer_Probe_Call) Return(_a0 *csi.ProbeResponse, _a1 error) *MockIdentityServer_Probe_Call
- func (_c *MockIdentityServer_Probe_Call) Run(run func(_a0 context.Context, _a1 *csi.ProbeRequest)) *MockIdentityServer_Probe_Call
- func (_c *MockIdentityServer_Probe_Call) RunAndReturn(run func(context.Context, *csi.ProbeRequest) (*csi.ProbeResponse, error)) *MockIdentityServer_Probe_Call
- type MockNodeServer
- func (_m *MockNodeServer) EXPECT() *MockNodeServer_Expecter
- func (_m *MockNodeServer) NodeExpandVolume(_a0 context.Context, _a1 *csi.NodeExpandVolumeRequest) (*csi.NodeExpandVolumeResponse, error)
- func (_m *MockNodeServer) NodeGetCapabilities(_a0 context.Context, _a1 *csi.NodeGetCapabilitiesRequest) (*csi.NodeGetCapabilitiesResponse, error)
- func (_m *MockNodeServer) NodeGetInfo(_a0 context.Context, _a1 *csi.NodeGetInfoRequest) (*csi.NodeGetInfoResponse, error)
- func (_m *MockNodeServer) NodeGetVolumeStats(_a0 context.Context, _a1 *csi.NodeGetVolumeStatsRequest) (*csi.NodeGetVolumeStatsResponse, error)
- func (_m *MockNodeServer) NodePublishVolume(_a0 context.Context, _a1 *csi.NodePublishVolumeRequest) (*csi.NodePublishVolumeResponse, error)
- func (_m *MockNodeServer) NodeStageVolume(_a0 context.Context, _a1 *csi.NodeStageVolumeRequest) (*csi.NodeStageVolumeResponse, error)
- func (_m *MockNodeServer) NodeUnpublishVolume(_a0 context.Context, _a1 *csi.NodeUnpublishVolumeRequest) (*csi.NodeUnpublishVolumeResponse, error)
- func (_m *MockNodeServer) NodeUnstageVolume(_a0 context.Context, _a1 *csi.NodeUnstageVolumeRequest) (*csi.NodeUnstageVolumeResponse, error)
- type MockNodeServer_Expecter
- func (_e *MockNodeServer_Expecter) NodeExpandVolume(_a0 interface{}, _a1 interface{}) *MockNodeServer_NodeExpandVolume_Call
- func (_e *MockNodeServer_Expecter) NodeGetCapabilities(_a0 interface{}, _a1 interface{}) *MockNodeServer_NodeGetCapabilities_Call
- func (_e *MockNodeServer_Expecter) NodeGetInfo(_a0 interface{}, _a1 interface{}) *MockNodeServer_NodeGetInfo_Call
- func (_e *MockNodeServer_Expecter) NodeGetVolumeStats(_a0 interface{}, _a1 interface{}) *MockNodeServer_NodeGetVolumeStats_Call
- func (_e *MockNodeServer_Expecter) NodePublishVolume(_a0 interface{}, _a1 interface{}) *MockNodeServer_NodePublishVolume_Call
- func (_e *MockNodeServer_Expecter) NodeStageVolume(_a0 interface{}, _a1 interface{}) *MockNodeServer_NodeStageVolume_Call
- func (_e *MockNodeServer_Expecter) NodeUnpublishVolume(_a0 interface{}, _a1 interface{}) *MockNodeServer_NodeUnpublishVolume_Call
- func (_e *MockNodeServer_Expecter) NodeUnstageVolume(_a0 interface{}, _a1 interface{}) *MockNodeServer_NodeUnstageVolume_Call
- type MockNodeServer_NodeExpandVolume_Call
- func (_c *MockNodeServer_NodeExpandVolume_Call) Return(_a0 *csi.NodeExpandVolumeResponse, _a1 error) *MockNodeServer_NodeExpandVolume_Call
- func (_c *MockNodeServer_NodeExpandVolume_Call) Run(run func(_a0 context.Context, _a1 *csi.NodeExpandVolumeRequest)) *MockNodeServer_NodeExpandVolume_Call
- func (_c *MockNodeServer_NodeExpandVolume_Call) RunAndReturn(...) *MockNodeServer_NodeExpandVolume_Call
- type MockNodeServer_NodeGetCapabilities_Call
- func (_c *MockNodeServer_NodeGetCapabilities_Call) Return(_a0 *csi.NodeGetCapabilitiesResponse, _a1 error) *MockNodeServer_NodeGetCapabilities_Call
- func (_c *MockNodeServer_NodeGetCapabilities_Call) Run(run func(_a0 context.Context, _a1 *csi.NodeGetCapabilitiesRequest)) *MockNodeServer_NodeGetCapabilities_Call
- func (_c *MockNodeServer_NodeGetCapabilities_Call) RunAndReturn(...) *MockNodeServer_NodeGetCapabilities_Call
- type MockNodeServer_NodeGetInfo_Call
- func (_c *MockNodeServer_NodeGetInfo_Call) Return(_a0 *csi.NodeGetInfoResponse, _a1 error) *MockNodeServer_NodeGetInfo_Call
- func (_c *MockNodeServer_NodeGetInfo_Call) Run(run func(_a0 context.Context, _a1 *csi.NodeGetInfoRequest)) *MockNodeServer_NodeGetInfo_Call
- func (_c *MockNodeServer_NodeGetInfo_Call) RunAndReturn(...) *MockNodeServer_NodeGetInfo_Call
- type MockNodeServer_NodeGetVolumeStats_Call
- func (_c *MockNodeServer_NodeGetVolumeStats_Call) Return(_a0 *csi.NodeGetVolumeStatsResponse, _a1 error) *MockNodeServer_NodeGetVolumeStats_Call
- func (_c *MockNodeServer_NodeGetVolumeStats_Call) Run(run func(_a0 context.Context, _a1 *csi.NodeGetVolumeStatsRequest)) *MockNodeServer_NodeGetVolumeStats_Call
- func (_c *MockNodeServer_NodeGetVolumeStats_Call) RunAndReturn(...) *MockNodeServer_NodeGetVolumeStats_Call
- type MockNodeServer_NodePublishVolume_Call
- func (_c *MockNodeServer_NodePublishVolume_Call) Return(_a0 *csi.NodePublishVolumeResponse, _a1 error) *MockNodeServer_NodePublishVolume_Call
- func (_c *MockNodeServer_NodePublishVolume_Call) Run(run func(_a0 context.Context, _a1 *csi.NodePublishVolumeRequest)) *MockNodeServer_NodePublishVolume_Call
- func (_c *MockNodeServer_NodePublishVolume_Call) RunAndReturn(...) *MockNodeServer_NodePublishVolume_Call
- type MockNodeServer_NodeStageVolume_Call
- func (_c *MockNodeServer_NodeStageVolume_Call) Return(_a0 *csi.NodeStageVolumeResponse, _a1 error) *MockNodeServer_NodeStageVolume_Call
- func (_c *MockNodeServer_NodeStageVolume_Call) Run(run func(_a0 context.Context, _a1 *csi.NodeStageVolumeRequest)) *MockNodeServer_NodeStageVolume_Call
- func (_c *MockNodeServer_NodeStageVolume_Call) RunAndReturn(...) *MockNodeServer_NodeStageVolume_Call
- type MockNodeServer_NodeUnpublishVolume_Call
- func (_c *MockNodeServer_NodeUnpublishVolume_Call) Return(_a0 *csi.NodeUnpublishVolumeResponse, _a1 error) *MockNodeServer_NodeUnpublishVolume_Call
- func (_c *MockNodeServer_NodeUnpublishVolume_Call) Run(run func(_a0 context.Context, _a1 *csi.NodeUnpublishVolumeRequest)) *MockNodeServer_NodeUnpublishVolume_Call
- func (_c *MockNodeServer_NodeUnpublishVolume_Call) RunAndReturn(...) *MockNodeServer_NodeUnpublishVolume_Call
- type MockNodeServer_NodeUnstageVolume_Call
- func (_c *MockNodeServer_NodeUnstageVolume_Call) Return(_a0 *csi.NodeUnstageVolumeResponse, _a1 error) *MockNodeServer_NodeUnstageVolume_Call
- func (_c *MockNodeServer_NodeUnstageVolume_Call) Run(run func(_a0 context.Context, _a1 *csi.NodeUnstageVolumeRequest)) *MockNodeServer_NodeUnstageVolume_Call
- func (_c *MockNodeServer_NodeUnstageVolume_Call) RunAndReturn(...) *MockNodeServer_NodeUnstageVolume_Call
Constants ¶
This section is empty.
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") )
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) SetDefaultCreds ¶
func (c *CSIDriver) SetDefaultCreds()
SetDefaultCreds sets the default secrets for CSI creds.
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, 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 ¶
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 ¶ added in v1.31.0
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 ¶ added in v1.31.0
MockControllerServer_ControllerExpandVolume_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'ControllerExpandVolume'
func (*MockControllerServer_ControllerExpandVolume_Call) Return ¶ added in v1.31.0
func (_c *MockControllerServer_ControllerExpandVolume_Call) Return(_a0 *csi.ControllerExpandVolumeResponse, _a1 error) *MockControllerServer_ControllerExpandVolume_Call
func (*MockControllerServer_ControllerExpandVolume_Call) Run ¶ added in v1.31.0
func (_c *MockControllerServer_ControllerExpandVolume_Call) Run(run func(_a0 context.Context, _a1 *csi.ControllerExpandVolumeRequest)) *MockControllerServer_ControllerExpandVolume_Call
func (*MockControllerServer_ControllerExpandVolume_Call) RunAndReturn ¶ added in v1.31.0
func (_c *MockControllerServer_ControllerExpandVolume_Call) RunAndReturn(run func(context.Context, *csi.ControllerExpandVolumeRequest) (*csi.ControllerExpandVolumeResponse, error)) *MockControllerServer_ControllerExpandVolume_Call
type MockControllerServer_ControllerGetCapabilities_Call ¶ added in v1.31.0
MockControllerServer_ControllerGetCapabilities_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'ControllerGetCapabilities'
func (*MockControllerServer_ControllerGetCapabilities_Call) Run ¶ added in v1.31.0
func (_c *MockControllerServer_ControllerGetCapabilities_Call) Run(run func(_a0 context.Context, _a1 *csi.ControllerGetCapabilitiesRequest)) *MockControllerServer_ControllerGetCapabilities_Call
func (*MockControllerServer_ControllerGetCapabilities_Call) RunAndReturn ¶ added in v1.31.0
func (_c *MockControllerServer_ControllerGetCapabilities_Call) RunAndReturn(run func(context.Context, *csi.ControllerGetCapabilitiesRequest) (*csi.ControllerGetCapabilitiesResponse, error)) *MockControllerServer_ControllerGetCapabilities_Call
type MockControllerServer_ControllerGetVolume_Call ¶ added in v1.31.0
MockControllerServer_ControllerGetVolume_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'ControllerGetVolume'
func (*MockControllerServer_ControllerGetVolume_Call) Return ¶ added in v1.31.0
func (_c *MockControllerServer_ControllerGetVolume_Call) Return(_a0 *csi.ControllerGetVolumeResponse, _a1 error) *MockControllerServer_ControllerGetVolume_Call
func (*MockControllerServer_ControllerGetVolume_Call) Run ¶ added in v1.31.0
func (_c *MockControllerServer_ControllerGetVolume_Call) Run(run func(_a0 context.Context, _a1 *csi.ControllerGetVolumeRequest)) *MockControllerServer_ControllerGetVolume_Call
func (*MockControllerServer_ControllerGetVolume_Call) RunAndReturn ¶ added in v1.31.0
func (_c *MockControllerServer_ControllerGetVolume_Call) RunAndReturn(run func(context.Context, *csi.ControllerGetVolumeRequest) (*csi.ControllerGetVolumeResponse, error)) *MockControllerServer_ControllerGetVolume_Call
type MockControllerServer_ControllerModifyVolume_Call ¶ added in v1.31.0
MockControllerServer_ControllerModifyVolume_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'ControllerModifyVolume'
func (*MockControllerServer_ControllerModifyVolume_Call) Return ¶ added in v1.31.0
func (_c *MockControllerServer_ControllerModifyVolume_Call) Return(_a0 *csi.ControllerModifyVolumeResponse, _a1 error) *MockControllerServer_ControllerModifyVolume_Call
func (*MockControllerServer_ControllerModifyVolume_Call) Run ¶ added in v1.31.0
func (_c *MockControllerServer_ControllerModifyVolume_Call) Run(run func(_a0 context.Context, _a1 *csi.ControllerModifyVolumeRequest)) *MockControllerServer_ControllerModifyVolume_Call
func (*MockControllerServer_ControllerModifyVolume_Call) RunAndReturn ¶ added in v1.31.0
func (_c *MockControllerServer_ControllerModifyVolume_Call) RunAndReturn(run func(context.Context, *csi.ControllerModifyVolumeRequest) (*csi.ControllerModifyVolumeResponse, error)) *MockControllerServer_ControllerModifyVolume_Call
type MockControllerServer_ControllerPublishVolume_Call ¶ added in v1.31.0
MockControllerServer_ControllerPublishVolume_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'ControllerPublishVolume'
func (*MockControllerServer_ControllerPublishVolume_Call) Run ¶ added in v1.31.0
func (_c *MockControllerServer_ControllerPublishVolume_Call) Run(run func(_a0 context.Context, _a1 *csi.ControllerPublishVolumeRequest)) *MockControllerServer_ControllerPublishVolume_Call
func (*MockControllerServer_ControllerPublishVolume_Call) RunAndReturn ¶ added in v1.31.0
func (_c *MockControllerServer_ControllerPublishVolume_Call) RunAndReturn(run func(context.Context, *csi.ControllerPublishVolumeRequest) (*csi.ControllerPublishVolumeResponse, error)) *MockControllerServer_ControllerPublishVolume_Call
type MockControllerServer_ControllerUnpublishVolume_Call ¶ added in v1.31.0
MockControllerServer_ControllerUnpublishVolume_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'ControllerUnpublishVolume'
func (*MockControllerServer_ControllerUnpublishVolume_Call) Run ¶ added in v1.31.0
func (_c *MockControllerServer_ControllerUnpublishVolume_Call) Run(run func(_a0 context.Context, _a1 *csi.ControllerUnpublishVolumeRequest)) *MockControllerServer_ControllerUnpublishVolume_Call
func (*MockControllerServer_ControllerUnpublishVolume_Call) RunAndReturn ¶ added in v1.31.0
func (_c *MockControllerServer_ControllerUnpublishVolume_Call) RunAndReturn(run func(context.Context, *csi.ControllerUnpublishVolumeRequest) (*csi.ControllerUnpublishVolumeResponse, error)) *MockControllerServer_ControllerUnpublishVolume_Call
type MockControllerServer_CreateSnapshot_Call ¶ added in v1.31.0
MockControllerServer_CreateSnapshot_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'CreateSnapshot'
func (*MockControllerServer_CreateSnapshot_Call) Return ¶ added in v1.31.0
func (_c *MockControllerServer_CreateSnapshot_Call) Return(_a0 *csi.CreateSnapshotResponse, _a1 error) *MockControllerServer_CreateSnapshot_Call
func (*MockControllerServer_CreateSnapshot_Call) Run ¶ added in v1.31.0
func (_c *MockControllerServer_CreateSnapshot_Call) Run(run func(_a0 context.Context, _a1 *csi.CreateSnapshotRequest)) *MockControllerServer_CreateSnapshot_Call
func (*MockControllerServer_CreateSnapshot_Call) RunAndReturn ¶ added in v1.31.0
func (_c *MockControllerServer_CreateSnapshot_Call) RunAndReturn(run func(context.Context, *csi.CreateSnapshotRequest) (*csi.CreateSnapshotResponse, error)) *MockControllerServer_CreateSnapshot_Call
type MockControllerServer_CreateVolume_Call ¶ added in v1.31.0
MockControllerServer_CreateVolume_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'CreateVolume'
func (*MockControllerServer_CreateVolume_Call) Return ¶ added in v1.31.0
func (_c *MockControllerServer_CreateVolume_Call) Return(_a0 *csi.CreateVolumeResponse, _a1 error) *MockControllerServer_CreateVolume_Call
func (*MockControllerServer_CreateVolume_Call) Run ¶ added in v1.31.0
func (_c *MockControllerServer_CreateVolume_Call) Run(run func(_a0 context.Context, _a1 *csi.CreateVolumeRequest)) *MockControllerServer_CreateVolume_Call
func (*MockControllerServer_CreateVolume_Call) RunAndReturn ¶ added in v1.31.0
func (_c *MockControllerServer_CreateVolume_Call) RunAndReturn(run func(context.Context, *csi.CreateVolumeRequest) (*csi.CreateVolumeResponse, error)) *MockControllerServer_CreateVolume_Call
type MockControllerServer_DeleteSnapshot_Call ¶ added in v1.31.0
MockControllerServer_DeleteSnapshot_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'DeleteSnapshot'
func (*MockControllerServer_DeleteSnapshot_Call) Return ¶ added in v1.31.0
func (_c *MockControllerServer_DeleteSnapshot_Call) Return(_a0 *csi.DeleteSnapshotResponse, _a1 error) *MockControllerServer_DeleteSnapshot_Call
func (*MockControllerServer_DeleteSnapshot_Call) Run ¶ added in v1.31.0
func (_c *MockControllerServer_DeleteSnapshot_Call) Run(run func(_a0 context.Context, _a1 *csi.DeleteSnapshotRequest)) *MockControllerServer_DeleteSnapshot_Call
func (*MockControllerServer_DeleteSnapshot_Call) RunAndReturn ¶ added in v1.31.0
func (_c *MockControllerServer_DeleteSnapshot_Call) RunAndReturn(run func(context.Context, *csi.DeleteSnapshotRequest) (*csi.DeleteSnapshotResponse, error)) *MockControllerServer_DeleteSnapshot_Call
type MockControllerServer_DeleteVolume_Call ¶ added in v1.31.0
MockControllerServer_DeleteVolume_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'DeleteVolume'
func (*MockControllerServer_DeleteVolume_Call) Return ¶ added in v1.31.0
func (_c *MockControllerServer_DeleteVolume_Call) Return(_a0 *csi.DeleteVolumeResponse, _a1 error) *MockControllerServer_DeleteVolume_Call
func (*MockControllerServer_DeleteVolume_Call) Run ¶ added in v1.31.0
func (_c *MockControllerServer_DeleteVolume_Call) Run(run func(_a0 context.Context, _a1 *csi.DeleteVolumeRequest)) *MockControllerServer_DeleteVolume_Call
func (*MockControllerServer_DeleteVolume_Call) RunAndReturn ¶ added in v1.31.0
func (_c *MockControllerServer_DeleteVolume_Call) RunAndReturn(run func(context.Context, *csi.DeleteVolumeRequest) (*csi.DeleteVolumeResponse, error)) *MockControllerServer_DeleteVolume_Call
type MockControllerServer_Expecter ¶ added in v1.31.0
type MockControllerServer_Expecter struct {
// contains filtered or unexported fields
}
func (*MockControllerServer_Expecter) ControllerExpandVolume ¶ added in v1.31.0
func (_e *MockControllerServer_Expecter) ControllerExpandVolume(_a0 interface{}, _a1 interface{}) *MockControllerServer_ControllerExpandVolume_Call
ControllerExpandVolume is a helper method to define mock.On call
- _a0 context.Context
- _a1 *csi.ControllerExpandVolumeRequest
func (*MockControllerServer_Expecter) ControllerGetCapabilities ¶ added in v1.31.0
func (_e *MockControllerServer_Expecter) ControllerGetCapabilities(_a0 interface{}, _a1 interface{}) *MockControllerServer_ControllerGetCapabilities_Call
ControllerGetCapabilities is a helper method to define mock.On call
- _a0 context.Context
- _a1 *csi.ControllerGetCapabilitiesRequest
func (*MockControllerServer_Expecter) ControllerGetVolume ¶ added in v1.31.0
func (_e *MockControllerServer_Expecter) ControllerGetVolume(_a0 interface{}, _a1 interface{}) *MockControllerServer_ControllerGetVolume_Call
ControllerGetVolume is a helper method to define mock.On call
- _a0 context.Context
- _a1 *csi.ControllerGetVolumeRequest
func (*MockControllerServer_Expecter) ControllerModifyVolume ¶ added in v1.31.0
func (_e *MockControllerServer_Expecter) ControllerModifyVolume(_a0 interface{}, _a1 interface{}) *MockControllerServer_ControllerModifyVolume_Call
ControllerModifyVolume is a helper method to define mock.On call
- _a0 context.Context
- _a1 *csi.ControllerModifyVolumeRequest
func (*MockControllerServer_Expecter) ControllerPublishVolume ¶ added in v1.31.0
func (_e *MockControllerServer_Expecter) ControllerPublishVolume(_a0 interface{}, _a1 interface{}) *MockControllerServer_ControllerPublishVolume_Call
ControllerPublishVolume is a helper method to define mock.On call
- _a0 context.Context
- _a1 *csi.ControllerPublishVolumeRequest
func (*MockControllerServer_Expecter) ControllerUnpublishVolume ¶ added in v1.31.0
func (_e *MockControllerServer_Expecter) ControllerUnpublishVolume(_a0 interface{}, _a1 interface{}) *MockControllerServer_ControllerUnpublishVolume_Call
ControllerUnpublishVolume is a helper method to define mock.On call
- _a0 context.Context
- _a1 *csi.ControllerUnpublishVolumeRequest
func (*MockControllerServer_Expecter) CreateSnapshot ¶ added in v1.31.0
func (_e *MockControllerServer_Expecter) CreateSnapshot(_a0 interface{}, _a1 interface{}) *MockControllerServer_CreateSnapshot_Call
CreateSnapshot is a helper method to define mock.On call
- _a0 context.Context
- _a1 *csi.CreateSnapshotRequest
func (*MockControllerServer_Expecter) CreateVolume ¶ added in v1.31.0
func (_e *MockControllerServer_Expecter) CreateVolume(_a0 interface{}, _a1 interface{}) *MockControllerServer_CreateVolume_Call
CreateVolume is a helper method to define mock.On call
- _a0 context.Context
- _a1 *csi.CreateVolumeRequest
func (*MockControllerServer_Expecter) DeleteSnapshot ¶ added in v1.31.0
func (_e *MockControllerServer_Expecter) DeleteSnapshot(_a0 interface{}, _a1 interface{}) *MockControllerServer_DeleteSnapshot_Call
DeleteSnapshot is a helper method to define mock.On call
- _a0 context.Context
- _a1 *csi.DeleteSnapshotRequest
func (*MockControllerServer_Expecter) DeleteVolume ¶ added in v1.31.0
func (_e *MockControllerServer_Expecter) DeleteVolume(_a0 interface{}, _a1 interface{}) *MockControllerServer_DeleteVolume_Call
DeleteVolume is a helper method to define mock.On call
- _a0 context.Context
- _a1 *csi.DeleteVolumeRequest
func (*MockControllerServer_Expecter) GetCapacity ¶ added in v1.31.0
func (_e *MockControllerServer_Expecter) GetCapacity(_a0 interface{}, _a1 interface{}) *MockControllerServer_GetCapacity_Call
GetCapacity is a helper method to define mock.On call
- _a0 context.Context
- _a1 *csi.GetCapacityRequest
func (*MockControllerServer_Expecter) ListSnapshots ¶ added in v1.31.0
func (_e *MockControllerServer_Expecter) ListSnapshots(_a0 interface{}, _a1 interface{}) *MockControllerServer_ListSnapshots_Call
ListSnapshots is a helper method to define mock.On call
- _a0 context.Context
- _a1 *csi.ListSnapshotsRequest
func (*MockControllerServer_Expecter) ListVolumes ¶ added in v1.31.0
func (_e *MockControllerServer_Expecter) ListVolumes(_a0 interface{}, _a1 interface{}) *MockControllerServer_ListVolumes_Call
ListVolumes is a helper method to define mock.On call
- _a0 context.Context
- _a1 *csi.ListVolumesRequest
func (*MockControllerServer_Expecter) ValidateVolumeCapabilities ¶ added in v1.31.0
func (_e *MockControllerServer_Expecter) ValidateVolumeCapabilities(_a0 interface{}, _a1 interface{}) *MockControllerServer_ValidateVolumeCapabilities_Call
ValidateVolumeCapabilities is a helper method to define mock.On call
- _a0 context.Context
- _a1 *csi.ValidateVolumeCapabilitiesRequest
type MockControllerServer_GetCapacity_Call ¶ added in v1.31.0
MockControllerServer_GetCapacity_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'GetCapacity'
func (*MockControllerServer_GetCapacity_Call) Return ¶ added in v1.31.0
func (_c *MockControllerServer_GetCapacity_Call) Return(_a0 *csi.GetCapacityResponse, _a1 error) *MockControllerServer_GetCapacity_Call
func (*MockControllerServer_GetCapacity_Call) Run ¶ added in v1.31.0
func (_c *MockControllerServer_GetCapacity_Call) Run(run func(_a0 context.Context, _a1 *csi.GetCapacityRequest)) *MockControllerServer_GetCapacity_Call
func (*MockControllerServer_GetCapacity_Call) RunAndReturn ¶ added in v1.31.0
func (_c *MockControllerServer_GetCapacity_Call) RunAndReturn(run func(context.Context, *csi.GetCapacityRequest) (*csi.GetCapacityResponse, error)) *MockControllerServer_GetCapacity_Call
type MockControllerServer_ListSnapshots_Call ¶ added in v1.31.0
MockControllerServer_ListSnapshots_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'ListSnapshots'
func (*MockControllerServer_ListSnapshots_Call) Return ¶ added in v1.31.0
func (_c *MockControllerServer_ListSnapshots_Call) Return(_a0 *csi.ListSnapshotsResponse, _a1 error) *MockControllerServer_ListSnapshots_Call
func (*MockControllerServer_ListSnapshots_Call) Run ¶ added in v1.31.0
func (_c *MockControllerServer_ListSnapshots_Call) Run(run func(_a0 context.Context, _a1 *csi.ListSnapshotsRequest)) *MockControllerServer_ListSnapshots_Call
func (*MockControllerServer_ListSnapshots_Call) RunAndReturn ¶ added in v1.31.0
func (_c *MockControllerServer_ListSnapshots_Call) RunAndReturn(run func(context.Context, *csi.ListSnapshotsRequest) (*csi.ListSnapshotsResponse, error)) *MockControllerServer_ListSnapshots_Call
type MockControllerServer_ListVolumes_Call ¶ added in v1.31.0
MockControllerServer_ListVolumes_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'ListVolumes'
func (*MockControllerServer_ListVolumes_Call) Return ¶ added in v1.31.0
func (_c *MockControllerServer_ListVolumes_Call) Return(_a0 *csi.ListVolumesResponse, _a1 error) *MockControllerServer_ListVolumes_Call
func (*MockControllerServer_ListVolumes_Call) Run ¶ added in v1.31.0
func (_c *MockControllerServer_ListVolumes_Call) Run(run func(_a0 context.Context, _a1 *csi.ListVolumesRequest)) *MockControllerServer_ListVolumes_Call
func (*MockControllerServer_ListVolumes_Call) RunAndReturn ¶ added in v1.31.0
func (_c *MockControllerServer_ListVolumes_Call) RunAndReturn(run func(context.Context, *csi.ListVolumesRequest) (*csi.ListVolumesResponse, error)) *MockControllerServer_ListVolumes_Call
type MockControllerServer_ValidateVolumeCapabilities_Call ¶ added in v1.31.0
MockControllerServer_ValidateVolumeCapabilities_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'ValidateVolumeCapabilities'
func (*MockControllerServer_ValidateVolumeCapabilities_Call) Run ¶ added in v1.31.0
func (_c *MockControllerServer_ValidateVolumeCapabilities_Call) Run(run func(_a0 context.Context, _a1 *csi.ValidateVolumeCapabilitiesRequest)) *MockControllerServer_ValidateVolumeCapabilities_Call
func (*MockControllerServer_ValidateVolumeCapabilities_Call) RunAndReturn ¶ added in v1.31.0
func (_c *MockControllerServer_ValidateVolumeCapabilities_Call) RunAndReturn(run func(context.Context, *csi.ValidateVolumeCapabilitiesRequest) (*csi.ValidateVolumeCapabilitiesResponse, error)) *MockControllerServer_ValidateVolumeCapabilities_Call
type MockIdentityServer ¶
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 ¶ added in v1.31.0
type MockIdentityServer_Expecter struct {
// contains filtered or unexported fields
}
func (*MockIdentityServer_Expecter) GetPluginCapabilities ¶ added in v1.31.0
func (_e *MockIdentityServer_Expecter) GetPluginCapabilities(_a0 interface{}, _a1 interface{}) *MockIdentityServer_GetPluginCapabilities_Call
GetPluginCapabilities is a helper method to define mock.On call
- _a0 context.Context
- _a1 *csi.GetPluginCapabilitiesRequest
func (*MockIdentityServer_Expecter) GetPluginInfo ¶ added in v1.31.0
func (_e *MockIdentityServer_Expecter) GetPluginInfo(_a0 interface{}, _a1 interface{}) *MockIdentityServer_GetPluginInfo_Call
GetPluginInfo is a helper method to define mock.On call
- _a0 context.Context
- _a1 *csi.GetPluginInfoRequest
func (*MockIdentityServer_Expecter) Probe ¶ added in v1.31.0
func (_e *MockIdentityServer_Expecter) Probe(_a0 interface{}, _a1 interface{}) *MockIdentityServer_Probe_Call
Probe is a helper method to define mock.On call
- _a0 context.Context
- _a1 *csi.ProbeRequest
type MockIdentityServer_GetPluginCapabilities_Call ¶ added in v1.31.0
MockIdentityServer_GetPluginCapabilities_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'GetPluginCapabilities'
func (*MockIdentityServer_GetPluginCapabilities_Call) Return ¶ added in v1.31.0
func (_c *MockIdentityServer_GetPluginCapabilities_Call) Return(_a0 *csi.GetPluginCapabilitiesResponse, _a1 error) *MockIdentityServer_GetPluginCapabilities_Call
func (*MockIdentityServer_GetPluginCapabilities_Call) Run ¶ added in v1.31.0
func (_c *MockIdentityServer_GetPluginCapabilities_Call) Run(run func(_a0 context.Context, _a1 *csi.GetPluginCapabilitiesRequest)) *MockIdentityServer_GetPluginCapabilities_Call
func (*MockIdentityServer_GetPluginCapabilities_Call) RunAndReturn ¶ added in v1.31.0
func (_c *MockIdentityServer_GetPluginCapabilities_Call) RunAndReturn(run func(context.Context, *csi.GetPluginCapabilitiesRequest) (*csi.GetPluginCapabilitiesResponse, error)) *MockIdentityServer_GetPluginCapabilities_Call
type MockIdentityServer_GetPluginInfo_Call ¶ added in v1.31.0
MockIdentityServer_GetPluginInfo_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'GetPluginInfo'
func (*MockIdentityServer_GetPluginInfo_Call) Return ¶ added in v1.31.0
func (_c *MockIdentityServer_GetPluginInfo_Call) Return(_a0 *csi.GetPluginInfoResponse, _a1 error) *MockIdentityServer_GetPluginInfo_Call
func (*MockIdentityServer_GetPluginInfo_Call) Run ¶ added in v1.31.0
func (_c *MockIdentityServer_GetPluginInfo_Call) Run(run func(_a0 context.Context, _a1 *csi.GetPluginInfoRequest)) *MockIdentityServer_GetPluginInfo_Call
func (*MockIdentityServer_GetPluginInfo_Call) RunAndReturn ¶ added in v1.31.0
func (_c *MockIdentityServer_GetPluginInfo_Call) RunAndReturn(run func(context.Context, *csi.GetPluginInfoRequest) (*csi.GetPluginInfoResponse, error)) *MockIdentityServer_GetPluginInfo_Call
type MockIdentityServer_Probe_Call ¶ added in v1.31.0
MockIdentityServer_Probe_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Probe'
func (*MockIdentityServer_Probe_Call) Return ¶ added in v1.31.0
func (_c *MockIdentityServer_Probe_Call) Return(_a0 *csi.ProbeResponse, _a1 error) *MockIdentityServer_Probe_Call
func (*MockIdentityServer_Probe_Call) Run ¶ added in v1.31.0
func (_c *MockIdentityServer_Probe_Call) Run(run func(_a0 context.Context, _a1 *csi.ProbeRequest)) *MockIdentityServer_Probe_Call
func (*MockIdentityServer_Probe_Call) RunAndReturn ¶ added in v1.31.0
func (_c *MockIdentityServer_Probe_Call) RunAndReturn(run func(context.Context, *csi.ProbeRequest) (*csi.ProbeResponse, error)) *MockIdentityServer_Probe_Call
type MockNodeServer ¶
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 ¶ added in v1.31.0
type MockNodeServer_Expecter struct {
// contains filtered or unexported fields
}
func (*MockNodeServer_Expecter) NodeExpandVolume ¶ added in v1.31.0
func (_e *MockNodeServer_Expecter) NodeExpandVolume(_a0 interface{}, _a1 interface{}) *MockNodeServer_NodeExpandVolume_Call
NodeExpandVolume is a helper method to define mock.On call
- _a0 context.Context
- _a1 *csi.NodeExpandVolumeRequest
func (*MockNodeServer_Expecter) NodeGetCapabilities ¶ added in v1.31.0
func (_e *MockNodeServer_Expecter) NodeGetCapabilities(_a0 interface{}, _a1 interface{}) *MockNodeServer_NodeGetCapabilities_Call
NodeGetCapabilities is a helper method to define mock.On call
- _a0 context.Context
- _a1 *csi.NodeGetCapabilitiesRequest
func (*MockNodeServer_Expecter) NodeGetInfo ¶ added in v1.31.0
func (_e *MockNodeServer_Expecter) NodeGetInfo(_a0 interface{}, _a1 interface{}) *MockNodeServer_NodeGetInfo_Call
NodeGetInfo is a helper method to define mock.On call
- _a0 context.Context
- _a1 *csi.NodeGetInfoRequest
func (*MockNodeServer_Expecter) NodeGetVolumeStats ¶ added in v1.31.0
func (_e *MockNodeServer_Expecter) NodeGetVolumeStats(_a0 interface{}, _a1 interface{}) *MockNodeServer_NodeGetVolumeStats_Call
NodeGetVolumeStats is a helper method to define mock.On call
- _a0 context.Context
- _a1 *csi.NodeGetVolumeStatsRequest
func (*MockNodeServer_Expecter) NodePublishVolume ¶ added in v1.31.0
func (_e *MockNodeServer_Expecter) NodePublishVolume(_a0 interface{}, _a1 interface{}) *MockNodeServer_NodePublishVolume_Call
NodePublishVolume is a helper method to define mock.On call
- _a0 context.Context
- _a1 *csi.NodePublishVolumeRequest
func (*MockNodeServer_Expecter) NodeStageVolume ¶ added in v1.31.0
func (_e *MockNodeServer_Expecter) NodeStageVolume(_a0 interface{}, _a1 interface{}) *MockNodeServer_NodeStageVolume_Call
NodeStageVolume is a helper method to define mock.On call
- _a0 context.Context
- _a1 *csi.NodeStageVolumeRequest
func (*MockNodeServer_Expecter) NodeUnpublishVolume ¶ added in v1.31.0
func (_e *MockNodeServer_Expecter) NodeUnpublishVolume(_a0 interface{}, _a1 interface{}) *MockNodeServer_NodeUnpublishVolume_Call
NodeUnpublishVolume is a helper method to define mock.On call
- _a0 context.Context
- _a1 *csi.NodeUnpublishVolumeRequest
func (*MockNodeServer_Expecter) NodeUnstageVolume ¶ added in v1.31.0
func (_e *MockNodeServer_Expecter) NodeUnstageVolume(_a0 interface{}, _a1 interface{}) *MockNodeServer_NodeUnstageVolume_Call
NodeUnstageVolume is a helper method to define mock.On call
- _a0 context.Context
- _a1 *csi.NodeUnstageVolumeRequest
type MockNodeServer_NodeExpandVolume_Call ¶ added in v1.31.0
MockNodeServer_NodeExpandVolume_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'NodeExpandVolume'
func (*MockNodeServer_NodeExpandVolume_Call) Return ¶ added in v1.31.0
func (_c *MockNodeServer_NodeExpandVolume_Call) Return(_a0 *csi.NodeExpandVolumeResponse, _a1 error) *MockNodeServer_NodeExpandVolume_Call
func (*MockNodeServer_NodeExpandVolume_Call) Run ¶ added in v1.31.0
func (_c *MockNodeServer_NodeExpandVolume_Call) Run(run func(_a0 context.Context, _a1 *csi.NodeExpandVolumeRequest)) *MockNodeServer_NodeExpandVolume_Call
func (*MockNodeServer_NodeExpandVolume_Call) RunAndReturn ¶ added in v1.31.0
func (_c *MockNodeServer_NodeExpandVolume_Call) RunAndReturn(run func(context.Context, *csi.NodeExpandVolumeRequest) (*csi.NodeExpandVolumeResponse, error)) *MockNodeServer_NodeExpandVolume_Call
type MockNodeServer_NodeGetCapabilities_Call ¶ added in v1.31.0
MockNodeServer_NodeGetCapabilities_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'NodeGetCapabilities'
func (*MockNodeServer_NodeGetCapabilities_Call) Return ¶ added in v1.31.0
func (_c *MockNodeServer_NodeGetCapabilities_Call) Return(_a0 *csi.NodeGetCapabilitiesResponse, _a1 error) *MockNodeServer_NodeGetCapabilities_Call
func (*MockNodeServer_NodeGetCapabilities_Call) Run ¶ added in v1.31.0
func (_c *MockNodeServer_NodeGetCapabilities_Call) Run(run func(_a0 context.Context, _a1 *csi.NodeGetCapabilitiesRequest)) *MockNodeServer_NodeGetCapabilities_Call
func (*MockNodeServer_NodeGetCapabilities_Call) RunAndReturn ¶ added in v1.31.0
func (_c *MockNodeServer_NodeGetCapabilities_Call) RunAndReturn(run func(context.Context, *csi.NodeGetCapabilitiesRequest) (*csi.NodeGetCapabilitiesResponse, error)) *MockNodeServer_NodeGetCapabilities_Call
type MockNodeServer_NodeGetInfo_Call ¶ added in v1.31.0
MockNodeServer_NodeGetInfo_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'NodeGetInfo'
func (*MockNodeServer_NodeGetInfo_Call) Return ¶ added in v1.31.0
func (_c *MockNodeServer_NodeGetInfo_Call) Return(_a0 *csi.NodeGetInfoResponse, _a1 error) *MockNodeServer_NodeGetInfo_Call
func (*MockNodeServer_NodeGetInfo_Call) Run ¶ added in v1.31.0
func (_c *MockNodeServer_NodeGetInfo_Call) Run(run func(_a0 context.Context, _a1 *csi.NodeGetInfoRequest)) *MockNodeServer_NodeGetInfo_Call
func (*MockNodeServer_NodeGetInfo_Call) RunAndReturn ¶ added in v1.31.0
func (_c *MockNodeServer_NodeGetInfo_Call) RunAndReturn(run func(context.Context, *csi.NodeGetInfoRequest) (*csi.NodeGetInfoResponse, error)) *MockNodeServer_NodeGetInfo_Call
type MockNodeServer_NodeGetVolumeStats_Call ¶ added in v1.31.0
MockNodeServer_NodeGetVolumeStats_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'NodeGetVolumeStats'
func (*MockNodeServer_NodeGetVolumeStats_Call) Return ¶ added in v1.31.0
func (_c *MockNodeServer_NodeGetVolumeStats_Call) Return(_a0 *csi.NodeGetVolumeStatsResponse, _a1 error) *MockNodeServer_NodeGetVolumeStats_Call
func (*MockNodeServer_NodeGetVolumeStats_Call) Run ¶ added in v1.31.0
func (_c *MockNodeServer_NodeGetVolumeStats_Call) Run(run func(_a0 context.Context, _a1 *csi.NodeGetVolumeStatsRequest)) *MockNodeServer_NodeGetVolumeStats_Call
func (*MockNodeServer_NodeGetVolumeStats_Call) RunAndReturn ¶ added in v1.31.0
func (_c *MockNodeServer_NodeGetVolumeStats_Call) RunAndReturn(run func(context.Context, *csi.NodeGetVolumeStatsRequest) (*csi.NodeGetVolumeStatsResponse, error)) *MockNodeServer_NodeGetVolumeStats_Call
type MockNodeServer_NodePublishVolume_Call ¶ added in v1.31.0
MockNodeServer_NodePublishVolume_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'NodePublishVolume'
func (*MockNodeServer_NodePublishVolume_Call) Return ¶ added in v1.31.0
func (_c *MockNodeServer_NodePublishVolume_Call) Return(_a0 *csi.NodePublishVolumeResponse, _a1 error) *MockNodeServer_NodePublishVolume_Call
func (*MockNodeServer_NodePublishVolume_Call) Run ¶ added in v1.31.0
func (_c *MockNodeServer_NodePublishVolume_Call) Run(run func(_a0 context.Context, _a1 *csi.NodePublishVolumeRequest)) *MockNodeServer_NodePublishVolume_Call
func (*MockNodeServer_NodePublishVolume_Call) RunAndReturn ¶ added in v1.31.0
func (_c *MockNodeServer_NodePublishVolume_Call) RunAndReturn(run func(context.Context, *csi.NodePublishVolumeRequest) (*csi.NodePublishVolumeResponse, error)) *MockNodeServer_NodePublishVolume_Call
type MockNodeServer_NodeStageVolume_Call ¶ added in v1.31.0
MockNodeServer_NodeStageVolume_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'NodeStageVolume'
func (*MockNodeServer_NodeStageVolume_Call) Return ¶ added in v1.31.0
func (_c *MockNodeServer_NodeStageVolume_Call) Return(_a0 *csi.NodeStageVolumeResponse, _a1 error) *MockNodeServer_NodeStageVolume_Call
func (*MockNodeServer_NodeStageVolume_Call) Run ¶ added in v1.31.0
func (_c *MockNodeServer_NodeStageVolume_Call) Run(run func(_a0 context.Context, _a1 *csi.NodeStageVolumeRequest)) *MockNodeServer_NodeStageVolume_Call
func (*MockNodeServer_NodeStageVolume_Call) RunAndReturn ¶ added in v1.31.0
func (_c *MockNodeServer_NodeStageVolume_Call) RunAndReturn(run func(context.Context, *csi.NodeStageVolumeRequest) (*csi.NodeStageVolumeResponse, error)) *MockNodeServer_NodeStageVolume_Call
type MockNodeServer_NodeUnpublishVolume_Call ¶ added in v1.31.0
MockNodeServer_NodeUnpublishVolume_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'NodeUnpublishVolume'
func (*MockNodeServer_NodeUnpublishVolume_Call) Return ¶ added in v1.31.0
func (_c *MockNodeServer_NodeUnpublishVolume_Call) Return(_a0 *csi.NodeUnpublishVolumeResponse, _a1 error) *MockNodeServer_NodeUnpublishVolume_Call
func (*MockNodeServer_NodeUnpublishVolume_Call) Run ¶ added in v1.31.0
func (_c *MockNodeServer_NodeUnpublishVolume_Call) Run(run func(_a0 context.Context, _a1 *csi.NodeUnpublishVolumeRequest)) *MockNodeServer_NodeUnpublishVolume_Call
func (*MockNodeServer_NodeUnpublishVolume_Call) RunAndReturn ¶ added in v1.31.0
func (_c *MockNodeServer_NodeUnpublishVolume_Call) RunAndReturn(run func(context.Context, *csi.NodeUnpublishVolumeRequest) (*csi.NodeUnpublishVolumeResponse, error)) *MockNodeServer_NodeUnpublishVolume_Call
type MockNodeServer_NodeUnstageVolume_Call ¶ added in v1.31.0
MockNodeServer_NodeUnstageVolume_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'NodeUnstageVolume'
func (*MockNodeServer_NodeUnstageVolume_Call) Return ¶ added in v1.31.0
func (_c *MockNodeServer_NodeUnstageVolume_Call) Return(_a0 *csi.NodeUnstageVolumeResponse, _a1 error) *MockNodeServer_NodeUnstageVolume_Call
func (*MockNodeServer_NodeUnstageVolume_Call) Run ¶ added in v1.31.0
func (_c *MockNodeServer_NodeUnstageVolume_Call) Run(run func(_a0 context.Context, _a1 *csi.NodeUnstageVolumeRequest)) *MockNodeServer_NodeUnstageVolume_Call
func (*MockNodeServer_NodeUnstageVolume_Call) RunAndReturn ¶ added in v1.31.0
func (_c *MockNodeServer_NodeUnstageVolume_Call) RunAndReturn(run func(context.Context, *csi.NodeUnstageVolumeRequest) (*csi.NodeUnstageVolumeResponse, error)) *MockNodeServer_NodeUnstageVolume_Call