fake

package
v1.20.5-rc.0 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Feb 18, 2021 License: Apache-2.0 Imports: 11 Imported by: 0

Documentation

Index

Constants

View Source
const (
	// NodePublishTimeOut_VolumeID is volume id that will result in NodePublish operation to timeout
	NodePublishTimeOut_VolumeID = "node-publish-timeout"

	// NodeStageTimeOut_VolumeID is a volume id that will result in NodeStage operation to timeout
	NodeStageTimeOut_VolumeID = "node-stage-timeout"
)

Variables

This section is empty.

Functions

This section is empty.

Types

type CSIVolume added in v1.12.0

type CSIVolume struct {
	VolumeHandle    string
	VolumeContext   map[string]string
	Path            string
	DeviceMountPath string
	FSType          string
	MountFlags      []string
}

type Closer added in v1.13.0

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

func NewCloser added in v1.13.0

func NewCloser(t *testing.T) *Closer

func (*Closer) Check added in v1.13.0

func (c *Closer) Check() *Closer

func (*Closer) Close added in v1.13.0

func (c *Closer) Close() error

type ControllerClient

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

ControllerClient represents a CSI Controller client

func NewControllerClient

func NewControllerClient() *ControllerClient

NewControllerClient returns a ControllerClient

func (*ControllerClient) ControllerGetCapabilities

ControllerGetCapabilities implements csi method

func (*ControllerClient) ControllerPublishVolume

ControllerPublishVolume implements csi method

func (*ControllerClient) ControllerUnpublishVolume

ControllerUnpublishVolume implements csi method

func (*ControllerClient) CreateVolume

CreateVolume implements csi method

func (*ControllerClient) DeleteVolume

DeleteVolume implements csi method

func (*ControllerClient) GetCapacity

GetCapacity implements csi method

func (*ControllerClient) ListVolumes

ListVolumes implements csi method

func (*ControllerClient) SetNextCapabilities

func (f *ControllerClient) SetNextCapabilities(caps []*csipb.ControllerServiceCapability)

SetNextCapabilities injects next expected capabilities

func (*ControllerClient) SetNextError

func (f *ControllerClient) SetNextError(err error)

SetNextError injects next expected error

func (*ControllerClient) ValidateVolumeCapabilities

ValidateVolumeCapabilities implements csi method

type IdentityClient

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

IdentityClient is a CSI identity client used for testing

func NewIdentityClient

func NewIdentityClient() *IdentityClient

NewIdentityClient returns a new IdentityClient

func (*IdentityClient) GetPluginCapabilities added in v1.10.0

GetPluginCapabilities implements csi method

func (*IdentityClient) GetPluginInfo

GetPluginInfo returns plugin info

func (*IdentityClient) Probe added in v1.10.0

Probe implements csi method

func (*IdentityClient) SetNextError

func (f *IdentityClient) SetNextError(err error)

SetNextError injects expected error

type NodeClient

type NodeClient struct {
	FakeNodeExpansionRequest *csipb.NodeExpandVolumeRequest
	// contains filtered or unexported fields
}

NodeClient returns CSI node client

func NewNodeClient

func NewNodeClient(stageUnstageSet bool) *NodeClient

NewNodeClient returns fake node client

func NewNodeClientWithExpansion added in v1.14.0

func NewNodeClientWithExpansion(stageUnstageSet bool, expansionSet bool) *NodeClient

func NewNodeClientWithVolumeStats added in v1.15.0

func NewNodeClientWithVolumeStats(volumeStatsSet bool) *NodeClient

func (*NodeClient) AddNodePublishedVolume added in v1.17.0

func (f *NodeClient) AddNodePublishedVolume(volID, deviceMountPath string, volumeContext map[string]string)

AddNodePublishedVolume adds specified volume to nodePublishedVolumes

func (*NodeClient) AddNodeStagedVolume added in v1.10.0

func (f *NodeClient) AddNodeStagedVolume(volID, deviceMountPath string, volumeContext map[string]string)

AddNodeStagedVolume adds specified volume to nodeStagedVolumes

func (*NodeClient) GetNodePublishedVolumes

func (f *NodeClient) GetNodePublishedVolumes() map[string]CSIVolume

GetNodePublishedVolumes returns node published volumes

func (*NodeClient) GetNodeStagedVolumes added in v1.10.0

func (f *NodeClient) GetNodeStagedVolumes() map[string]CSIVolume

GetNodeStagedVolumes returns node staged volumes

func (*NodeClient) NodeExpandVolume added in v1.14.0

NodeExpandVolume implements csi method

func (*NodeClient) NodeGetCapabilities

NodeGetCapabilities implements csi method

func (*NodeClient) NodeGetInfo added in v1.11.4

NodeGetId implements csi method

func (*NodeClient) NodeGetVolumeStats added in v1.13.0

NodeGetVolumeStats implements csi method

func (*NodeClient) NodePublishVolume

NodePublishVolume implements CSI NodePublishVolume

func (*NodeClient) NodeStageVolume added in v1.10.0

NodeStagevolume implements csi method

func (*NodeClient) NodeUnpublishVolume

NodeUnpublishVolume implements csi method

func (*NodeClient) NodeUnstageVolume added in v1.10.0

NodeUnstageVolume implements csi method

func (*NodeClient) SetNextError

func (f *NodeClient) SetNextError(err error)

SetNextError injects next expected error

func (*NodeClient) SetNodeGetInfoResp added in v1.11.4

func (f *NodeClient) SetNodeGetInfoResp(resp *csipb.NodeGetInfoResponse)

func (*NodeClient) SetNodeVolumeStatsResp added in v1.15.0

func (f *NodeClient) SetNodeVolumeStatsResp(resp *csipb.NodeGetVolumeStatsResponse)

Jump to

Keyboard shortcuts

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