fake

package

v1.12.10 Latest Latest Go to latest Published: Jul 11, 2019 License: Apache-2.0 Imports: 5 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/jadarsie/kubernetes

Documentation ¶

Index ¶

type CSIVolume
type ControllerClient
- func NewControllerClient() *ControllerClient
type IdentityClient
- func NewIdentityClient() *IdentityClient
type NodeClient
- func NewNodeClient(stageUnstageSet bool) *NodeClient

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

This section is empty.

Types ¶

type CSIVolume ¶ added in v1.12.6

type CSIVolume struct {
	Attributes map[string]string
	Path       string
}

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 ¶

func (f *ControllerClient) ControllerGetCapabilities(ctx context.Context, in *csipb.ControllerGetCapabilitiesRequest, opts ...grpc.CallOption) (*csipb.ControllerGetCapabilitiesResponse, error)

ControllerGetCapabilities implements csi method

func (*ControllerClient) ControllerPublishVolume ¶

func (f *ControllerClient) ControllerPublishVolume(ctx context.Context, in *csipb.ControllerPublishVolumeRequest, opts ...grpc.CallOption) (*csipb.ControllerPublishVolumeResponse, error)

ControllerPublishVolume implements csi method

func (*ControllerClient) ControllerUnpublishVolume ¶

func (f *ControllerClient) ControllerUnpublishVolume(ctx context.Context, in *csipb.ControllerUnpublishVolumeRequest, opts ...grpc.CallOption) (*csipb.ControllerUnpublishVolumeResponse, error)

ControllerUnpublishVolume implements csi method

func (*ControllerClient) CreateVolume ¶

func (f *ControllerClient) CreateVolume(ctx context.Context, in *csipb.CreateVolumeRequest, opts ...grpc.CallOption) (*csipb.CreateVolumeResponse, error)

CreateVolume implements csi method

func (*ControllerClient) DeleteVolume ¶

func (f *ControllerClient) DeleteVolume(ctx context.Context, in *csipb.DeleteVolumeRequest, opts ...grpc.CallOption) (*csipb.DeleteVolumeResponse, error)

DeleteVolume implements csi method

func (*ControllerClient) GetCapacity ¶

func (f *ControllerClient) GetCapacity(ctx context.Context, in *csipb.GetCapacityRequest, opts ...grpc.CallOption) (*csipb.GetCapacityResponse, error)

GetCapacity implements csi method

func (*ControllerClient) ListVolumes ¶

func (f *ControllerClient) ListVolumes(ctx context.Context, in *csipb.ListVolumesRequest, opts ...grpc.CallOption) (*csipb.ListVolumesResponse, error)

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 ¶

func (f *ControllerClient) ValidateVolumeCapabilities(ctx context.Context, in *csipb.ValidateVolumeCapabilitiesRequest, opts ...grpc.CallOption) (*csipb.ValidateVolumeCapabilitiesResponse, error)

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.6

func (f *IdentityClient) GetPluginCapabilities(ctx context.Context, in *csipb.GetPluginCapabilitiesRequest, opts ...grpc.CallOption) (*csipb.GetPluginCapabilitiesResponse, error)

GetPluginCapabilities implements csi method

func (*IdentityClient) GetPluginInfo ¶

func (f *IdentityClient) GetPluginInfo(ctx context.Context, in *csipb.GetPluginInfoRequest, opts ...grpc.CallOption) (*csipb.GetPluginInfoResponse, error)

GetPluginInfo returns plugin info

func (*IdentityClient) Probe ¶ added in v1.10.6

func (f *IdentityClient) Probe(ctx context.Context, in *csipb.ProbeRequest, opts ...grpc.CallOption) (*csipb.ProbeResponse, error)

Probe implements csi method

func (*IdentityClient) SetNextError ¶

func (f *IdentityClient) SetNextError(err error)

SetNextError injects expected error

type NodeClient ¶

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

NodeClient returns CSI node client

func NewNodeClient ¶

func NewNodeClient(stageUnstageSet bool) *NodeClient

NewNodeClient returns fake node client

func (*NodeClient) AddNodeStagedVolume ¶ added in v1.10.6

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

func (*NodeClient) GetNodePublishedVolumes ¶

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

GetNodePublishedVolumes returns node published volumes

func (*NodeClient) GetNodeStagedVolumes ¶ added in v1.10.6

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

GetNodeStagedVolumes returns node staged volumes

func (*NodeClient) NodeGetCapabilities ¶

func (f *NodeClient) NodeGetCapabilities(ctx context.Context, in *csipb.NodeGetCapabilitiesRequest, opts ...grpc.CallOption) (*csipb.NodeGetCapabilitiesResponse, error)

NodeGetCapabilities implements csi method

func (*NodeClient) NodeGetId ¶ added in v1.10.6

func (f *NodeClient) NodeGetId(ctx context.Context, in *csipb.NodeGetIdRequest, opts ...grpc.CallOption) (*csipb.NodeGetIdResponse, error)

NodeGetId implements method

func (*NodeClient) NodeGetInfo ¶ added in v1.11.7

func (f *NodeClient) NodeGetInfo(ctx context.Context, in *csipb.NodeGetInfoRequest, opts ...grpc.CallOption) (*csipb.NodeGetInfoResponse, error)

NodeGetId implements csi method

func (*NodeClient) NodePublishVolume ¶

func (f *NodeClient) NodePublishVolume(ctx context.Context, req *csipb.NodePublishVolumeRequest, opts ...grpc.CallOption) (*csipb.NodePublishVolumeResponse, error)

NodePublishVolume implements CSI NodePublishVolume

func (*NodeClient) NodeStageVolume ¶ added in v1.10.6

func (f *NodeClient) NodeStageVolume(ctx context.Context, req *csipb.NodeStageVolumeRequest, opts ...grpc.CallOption) (*csipb.NodeStageVolumeResponse, error)

NodeStagevolume implements csi method

func (*NodeClient) NodeUnpublishVolume ¶

func (f *NodeClient) NodeUnpublishVolume(ctx context.Context, req *csipb.NodeUnpublishVolumeRequest, opts ...grpc.CallOption) (*csipb.NodeUnpublishVolumeResponse, error)

NodeUnpublishVolume implements csi method

func (*NodeClient) NodeUnstageVolume ¶ added in v1.10.6

func (f *NodeClient) NodeUnstageVolume(ctx context.Context, req *csipb.NodeUnstageVolumeRequest, opts ...grpc.CallOption) (*csipb.NodeUnstageVolumeResponse, error)

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.7

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

Source Files ¶

View all Source files

fake_client.go

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