mock

Documentation

Index

• Constants
• type Driver
  • func (m *Driver) CleanupSnapshotRestoreObjects(*stork_crd.VolumeSnapshotRestore) error
  • func (m *Driver) CompleteVolumeSnapshotRestore(snap *stork_crd.VolumeSnapshotRestore) error
  • func (m *Driver) CreateCluster(numNodes int, nodes *v1.NodeList) error
  • func (m *Driver) GetClusterID() (string, error)
  • func (m Driver) GetNodes() ([]*storkvolume.NodeInfo, error)
  • func (m Driver) GetPodVolumes(podSpec *v1.PodSpec, namespace string) ([]*storkvolume.Info, error)
  • func (m *Driver) GetSnapshotPlugin() snapshotVolume.Plugin
  • func (m *Driver) GetSnapshotType(snap *snapv1.VolumeSnapshot) (string, error)
  • func (m *Driver) GetStorageClassName() string
  • func (m *Driver) GetVolumeClaimTemplates([]v1.PersistentVolumeClaim) ([]v1.PersistentVolumeClaim, error)
  • func (m *Driver) GetVolumeSnapshotRestoreStatus(*stork_crd.VolumeSnapshotRestore) error
  • func (m Driver) Init(_ interface{}) error
  • func (m Driver) InspectVolume(volumeID string) (*storkvolume.Info, error)
  • func (m *Driver) NewPVC(volumeName string) *v1.PersistentVolumeClaim
  • func (m *Driver) OwnsPVC(pvc *v1.PersistentVolumeClaim) bool
  • func (m *Driver) ProvisionVolume(volumeName string, replicaIndexes []int, size uint64) error
  • func (m *Driver) SetInterfaceError(err error)
  • func (m *Driver) StartVolumeSnapshotRestore(*stork_crd.VolumeSnapshotRestore) error
  • func (m Driver) Stop() error
  • func (m Driver) String() string
  • func (m *Driver) UpdateNodeIP(nodeIndex int, ip string) error
  • func (m *Driver) UpdateNodeStatus(nodeIndex int, nodeStatus storkvolume.NodeStatus) error

Constants

const (

	// RackLabel Label used for the mock driver to set rack information
	RackLabel = "mock/rack"
	// ZoneLabel Label used for the mock driver to set zone information
	ZoneLabel = "mock/zone"
	// RegionLabel Label used for the mock driver to set region information
	RegionLabel = "mock/region"
)

Types

type Driver

type Driver struct {
	storkvolume.ClusterPairNotSupported
	storkvolume.MigrationNotSupported
	storkvolume.GroupSnapshotNotSupported
	storkvolume.ClusterDomainsNotSupported
	storkvolume.BackupRestoreNotSupported
	storkvolume.CloneNotSupported
	// contains filtered or unexported fields
}

Driver Mock driver for tests

func (*Driver) CleanupSnapshotRestoreObjects

func (m *Driver) CleanupSnapshotRestoreObjects(*stork_crd.VolumeSnapshotRestore) error

CleanupSnapshotRestoreObjects deletes restore objects if any

func (*Driver) CompleteVolumeSnapshotRestore

func (m *Driver) CompleteVolumeSnapshotRestore(snap *stork_crd.VolumeSnapshotRestore) error

CompleteVolumeSnapshotRestore will perform inplace restore

func (*Driver) CreateCluster

func (m *Driver) CreateCluster(numNodes int, nodes *v1.NodeList) error

CreateCluster Creates a cluster with specified number of nodes

func (*Driver) GetClusterID

func (m *Driver) GetClusterID() (string, error)

GetClusterID returns the clusterID for the driver

func (Driver) GetNodes

func (m Driver) GetNodes() ([]*storkvolume.NodeInfo, error)

GetNodes Get info about the nodes where the driver is running

func (Driver) GetPodVolumes

func (m Driver) GetPodVolumes(podSpec *v1.PodSpec, namespace string) ([]*storkvolume.Info, error)

GetPodVolumes Get the Volumes in the Pod that use the mock driver

func (*Driver) GetSnapshotPlugin

func (m *Driver) GetSnapshotPlugin() snapshotVolume.Plugin

GetSnapshotPlugin Returns nil since snapshot is not supported in the mock driver

func (*Driver) GetSnapshotType

func (m *Driver) GetSnapshotType(snap *snapv1.VolumeSnapshot) (string, error)

GetSnapshotType Not implemented for mock driver

func (*Driver) GetStorageClassName

func (m *Driver) GetStorageClassName() string

GetStorageClassName Returns the storageclass name to be used by tests

func (*Driver) GetVolumeClaimTemplates

func (m *Driver) GetVolumeClaimTemplates([]v1.PersistentVolumeClaim) (
	[]v1.PersistentVolumeClaim, error)

GetVolumeClaimTemplates Not implemented for mock driver

func (*Driver) GetVolumeSnapshotRestoreStatus

func (m *Driver) GetVolumeSnapshotRestoreStatus(*stork_crd.VolumeSnapshotRestore) error

GetVolumeSnapshotRestoreStatus returns snapshot restore status

func (Driver) Init

func (m Driver) Init(_ interface{}) error

Init Initialize the mock driver

func (Driver) InspectVolume

func (m Driver) InspectVolume(volumeID string) (*storkvolume.Info, error)

InspectVolume Return information for a given volume

func (*Driver) NewPVC

func (m *Driver) NewPVC(volumeName string) *v1.PersistentVolumeClaim

NewPVC Create a new PVC reference

func (*Driver) OwnsPVC

func (m *Driver) OwnsPVC(pvc *v1.PersistentVolumeClaim) bool

OwnsPVC returns true because it owns all PVCs created by tests

func (*Driver) ProvisionVolume

func (m *Driver) ProvisionVolume(
	volumeName string,
	replicaIndexes []int,
	size uint64,
) error

ProvisionVolume Provision a volume in the mock driver

func (*Driver) SetInterfaceError

func (m *Driver) SetInterfaceError(err error)

SetInterfaceError to the specified error. Used for negative testing

func (*Driver) StartVolumeSnapshotRestore

func (m *Driver) StartVolumeSnapshotRestore(*stork_crd.VolumeSnapshotRestore) error

StartVolumeSnapshotRestore will prepare volume for restore

func (Driver) Stop

func (m Driver) Stop() error

Stop Stops the mock driver

func (Driver) String

func (m Driver) String() string

String Returns the name for the driver

func (*Driver) UpdateNodeIP

func (m *Driver) UpdateNodeIP(
	nodeIndex int,
	ip string,
) error

UpdateNodeIP Update IP for a node

func (*Driver) UpdateNodeStatus

func (m *Driver) UpdateNodeStatus(
	nodeIndex int,
	nodeStatus storkvolume.NodeStatus,
) error

UpdateNodeStatus Update status for a node