Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security Policy
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

mocks

package

Go to main page

Versions in this module

v2

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