mocks

package

Go to main page

Versions in this module

v2

v2.12.0

Oct 29, 2024

Changes in this version

type NodeLabelsRetrieverInterface

+ func (_m *NodeLabelsRetrieverInterface) GetNVMeUUIDs(ctx context.Context, k8sclientset *kubernetes.Clientset) (map[string]string, error)

type UtilInterface

+ func (_m *UtilInterface) GetNVMeController(device string) (string, error)

v2.11.1

Sep 23, 2024

v2.11.0

Jul 22, 2024

v2.10.1

May 28, 2024

v2.10.0

Mar 5, 2024

v2.9.1

Jan 25, 2024

v2.9.0

Dec 6, 2023

v2.8.0

Sep 20, 2023

Changes in this version

+ type NodeLabelsRetrieverInterface struct

+ func NewNodeLabelsRetrieverInterface(t interface{ ... }) *NodeLabelsRetrieverInterface

+ func (_m *NodeLabelsRetrieverInterface) BuildConfigFromFlags(masterURL string, kubeconfig string) (*rest.Config, error)

+ func (_m *NodeLabelsRetrieverInterface) GetNodeLabels(ctx context.Context, k8sclientset *kubernetes.Clientset, kubeNodeName string) (map[string]string, error)

+ func (_m *NodeLabelsRetrieverInterface) InClusterConfig() (*rest.Config, error)

+ func (_m *NodeLabelsRetrieverInterface) NewForConfig(config *rest.Config) (*kubernetes.Clientset, error)

v2.7.0

Jun 6, 2023

v2.6.0

Mar 7, 2023

Changes in this version

+ type Consumer struct

+ func (_m *Consumer) Arrays() map[string]*array.PowerStoreArray

+ func (_m *Consumer) DefaultArray() *array.PowerStoreArray

+ func (_m *Consumer) RegisterK8sCluster(_a0 fs.Interface) error

+ func (_m *Consumer) SetArrays(_a0 map[string]*array.PowerStoreArray)

+ func (_m *Consumer) SetDefaultArray(_a0 *array.PowerStoreArray)

+ func (_m *Consumer) UpdateArrays(_a0 string, _a1 fs.Interface) error

+ type ControllerInterface struct

+ func (_m *ControllerInterface) Arrays() map[string]*array.PowerStoreArray

+ func (_m *ControllerInterface) ControllerPublishVolume(ctx context.Context, req *csi.ControllerPublishVolumeRequest) (*csi.ControllerPublishVolumeResponse, error)

+ func (_m *ControllerInterface) ControllerUnpublishVolume(ctx context.Context, req *csi.ControllerUnpublishVolumeRequest) (*csi.ControllerUnpublishVolumeResponse, error)

+ func (_m *ControllerInterface) CreateVolume(ctx context.Context, req *csi.CreateVolumeRequest) (*csi.CreateVolumeResponse, error)

+ func (_m *ControllerInterface) DefaultArray() *array.PowerStoreArray

+ func (_m *ControllerInterface) DeleteVolume(ctx context.Context, req *csi.DeleteVolumeRequest) (*csi.DeleteVolumeResponse, error)

+ func (_m *ControllerInterface) RegisterK8sCluster(_a0 fs.Interface) error

+ func (_m *ControllerInterface) SetArrays(_a0 map[string]*array.PowerStoreArray)

+ func (_m *ControllerInterface) SetDefaultArray(_a0 *array.PowerStoreArray)

+ func (_m *ControllerInterface) UpdateArrays(_a0 string, _a1 fs.Interface) error

+ type FcConnector struct

+ func (_m *FcConnector) ConnectVolume(ctx context.Context, info gobrick.FCVolumeInfo) (gobrick.Device, error)

+ func (_m *FcConnector) DisconnectVolumeByDeviceName(ctx context.Context, name string) error

+ func (_m *FcConnector) GetInitiatorPorts(ctx context.Context) ([]string, error)

+ type FileInfo struct

+ func (_m *FileInfo) IsDir() bool

+ func (_m *FileInfo) ModTime() time.Time

+ func (_m *FileInfo) Mode() iofs.FileMode

+ func (_m *FileInfo) Name() string

+ func (_m *FileInfo) Size() int64

+ func (_m *FileInfo) Sys() interface{}

+ type FsInterface struct

+ func (_m *FsInterface) Chmod(name string, perm fs.FileMode) error

+ func (_m *FsInterface) Create(name string) (*os.File, error)

+ func (_m *FsInterface) ExecCommand(name string, args ...string) ([]byte, error)

+ func (_m *FsInterface) ExecCommandOutput(name string, args ...string) ([]byte, error)

+ func (_m *FsInterface) GetUtil() commonfs.UtilInterface

+ func (_m *FsInterface) IsDeviceOrResourceBusy(err error) bool

+ func (_m *FsInterface) IsNotExist(err error) bool

+ func (_m *FsInterface) MkFileIdempotent(path string) (bool, error)

+ func (_m *FsInterface) Mkdir(name string, perm fs.FileMode) error

+ func (_m *FsInterface) MkdirAll(name string, perm fs.FileMode) error

+ func (_m *FsInterface) NetDial(endpoint string) (net.Conn, error)

+ func (_m *FsInterface) OpenFile(name string, flag int, perm fs.FileMode) (*os.File, error)

+ func (_m *FsInterface) ParseProcMounts(ctx context.Context, content io.Reader) ([]gofsutil.Info, error)

+ func (_m *FsInterface) ReadFile(name string) ([]byte, error)

+ func (_m *FsInterface) Remove(name string) error

+ func (_m *FsInterface) RemoveAll(name string) error

+ func (_m *FsInterface) Stat(name string) (commonfs.FileInfo, error)

+ func (_m *FsInterface) WriteFile(filename string, data []byte, perm fs.FileMode) error

+ func (_m *FsInterface) WriteString(file *os.File, str string) (int, error)

+ type GeneralSnapshot struct

+ func (_m *GeneralSnapshot) GetID() string

+ func (_m *GeneralSnapshot) GetSize() int64

+ func (_m *GeneralSnapshot) GetSourceID() string

+ func (_m *GeneralSnapshot) GetType() controller.SnapshotType

+ type ISCSIConnector struct

+ func (_m *ISCSIConnector) ConnectVolume(ctx context.Context, info gobrick.ISCSIVolumeInfo) (gobrick.Device, error)

+ func (_m *ISCSIConnector) DisconnectVolumeByDeviceName(ctx context.Context, name string) error

+ func (_m *ISCSIConnector) GetInitiatorName(ctx context.Context) ([]string, error)

+ type NFSv4ACLsInterface struct

+ func (_m *NFSv4ACLsInterface) SetNfsv4Acls(acls string, dir string) error

+ type NVMEConnector struct

+ func NewNVMEConnector(t testing.TB) *NVMEConnector

+ func (_m *NVMEConnector) ConnectVolume(ctx context.Context, info gobrick.NVMeVolumeInfo, useFC bool) (gobrick.Device, error)

+ func (_m *NVMEConnector) DisconnectVolumeByDeviceName(ctx context.Context, name string) error

+ func (_m *NVMEConnector) GetInitiatorName(ctx context.Context) ([]string, error)

+ type NodeVolumePublisher struct

+ func (_m *NodeVolumePublisher) Publish(ctx context.Context, logFields logrus.Fields, _a2 fs.Interface, ...) (*csi.NodePublishVolumeResponse, error)

+ type NodeVolumeStager struct

+ func (_m *NodeVolumeStager) Stage(ctx context.Context, req *csi.NodeStageVolumeRequest, logFields logrus.Fields, ...) (*csi.NodeStageVolumeResponse, error)

+ type TracerConfigurator struct

+ func (_m *TracerConfigurator) FromEnv() (*config.Configuration, error)

+ type UtilInterface struct

+ func NewUtilInterface(t mockConstructorTestingTNewUtilInterface) *UtilInterface

+ func (_m *UtilInterface) BindMount(ctx context.Context, source string, target string, options ...string) error

+ func (_m *UtilInterface) DeviceRescan(ctx context.Context, devicePath string) error

+ func (_m *UtilInterface) FindFSType(ctx context.Context, mountpoint string) (string, error)

+ func (_m *UtilInterface) Format(ctx context.Context, source string, target string, fsType string, ...) error

+ func (_m *UtilInterface) FormatAndMount(ctx context.Context, source string, target string, fsType string, ...) error

+ func (_m *UtilInterface) GetDevMounts(ctx context.Context, dev string) ([]gofsutil.Info, error)

+ func (_m *UtilInterface) GetDiskFormat(ctx context.Context, disk string) (string, error)

+ func (_m *UtilInterface) GetFCHostPortWWNs(ctx context.Context) ([]string, error)

+ func (_m *UtilInterface) GetMountInfoFromDevice(ctx context.Context, devID string) (*gofsutil.DeviceMountInfo, error)

+ func (_m *UtilInterface) GetMounts(ctx context.Context) ([]gofsutil.Info, error)

+ func (_m *UtilInterface) GetMpathNameFromDevice(ctx context.Context, device string) (string, error)

+ func (_m *UtilInterface) GetSysBlockDevicesForVolumeWWN(ctx context.Context, volumeWWN string) ([]string, error)

+ func (_m *UtilInterface) IssueLIPToAllFCHosts(ctx context.Context) error

+ func (_m *UtilInterface) Mount(ctx context.Context, source string, target string, fsType string, ...) error

+ func (_m *UtilInterface) MultipathCommand(ctx context.Context, timeout time.Duration, chroot string, arguments ...string) ([]byte, error)

+ func (_m *UtilInterface) RemoveBlockDevice(ctx context.Context, blockDevicePath string) error

+ func (_m *UtilInterface) RescanSCSIHost(ctx context.Context, targets []string, lun string) error

+ func (_m *UtilInterface) ResizeFS(ctx context.Context, volumePath string, devicePath string, ppathDevice string, ...) error

+ func (_m *UtilInterface) ResizeMultipath(ctx context.Context, deviceName string) error

+ func (_m *UtilInterface) TargetIPLUNToDevicePath(ctx context.Context, targetIP string, lunID int) (map[string]string, error)

+ func (_m *UtilInterface) Unmount(ctx context.Context, target string) error

+ func (_m *UtilInterface) ValidateDevice(ctx context.Context, source string) (string, error)

+ func (_m *UtilInterface) WWNToDevicePath(ctx context.Context, wwn string) (string, string, error)

+ type VolumeCreator struct

+ func (_m *VolumeCreator) CheckIfAlreadyExists(ctx context.Context, name string, sizeInBytes int64, ...) (*csi.Volume, error)

+ func (_m *VolumeCreator) CheckName(ctx context.Context, name string) error

+ func (_m *VolumeCreator) CheckSize(ctx context.Context, cr *csi.CapacityRange) (int64, error)

+ func (_m *VolumeCreator) Clone(ctx context.Context, volumeSource *csi.VolumeContentSource_VolumeSource, ...) (*csi.Volume, error)

+ func (_m *VolumeCreator) Create(ctx context.Context, req *csi.CreateVolumeRequest, sizeInBytes int64, ...) (gopowerstore.CreateResponse, error)

+ func (_m *VolumeCreator) CreateVolumeFromSnapshot(ctx context.Context, snapshotSource *csi.VolumeContentSource_SnapshotSource, ...) (*csi.Volume, error)

+ type VolumePublisher struct

+ func (_m *VolumePublisher) CheckIfVolumeExists(ctx context.Context, client gopowerstore.Client, volID string) error

+ func (_m *VolumePublisher) Publish(ctx context.Context, req *csi.ControllerPublishVolumeRequest, ...) (*csi.ControllerPublishVolumeResponse, error)

+ type VolumeSnapshotter struct

+ func (_m *VolumeSnapshotter) Create(_a0 context.Context, _a1 string, _a2 string, _a3 gopowerstore.Client) (gopowerstore.CreateResponse, error)

+ func (_m *VolumeSnapshotter) GetExistingSnapshot(_a0 context.Context, _a1 string, _a2 gopowerstore.Client) (controller.GeneralSnapshot, error)

Other modules containing this package

github.com/dell/csi-powerstore

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