driver

package
v1.23.2 Latest Latest
Warning

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

 Go to latest Published: Oct 27, 2023 License: Apache-2.0 Imports: 97 Imported by: 1

Documentation

Overview

Package driver is a generated GoMock package.

Package driver is a generated GoMock package.

Package driver is a generated GoMock package.

Package driver is a generated GoMock package.

Index

Constants

View Source 
const (
	// VolumeTypeKey represents key for volume type
	VolumeTypeKey = "type"

	// IopsPerGBKey represents key for IOPS per GB
	IopsPerGBKey = "iopspergb"

	// AllowAutoIOPSPerGBIncreaseKey represents key for allowing automatic increase of IOPS
	AllowAutoIOPSPerGBIncreaseKey = "allowautoiopspergbincrease"

	// Iops represents key for IOPS for volume
	IopsKey = "iops"

	// ThroughputKey represents key for throughput
	ThroughputKey = "throughput"

	// EncryptedKey represents key for whether filesystem is encrypted
	EncryptedKey = "encrypted"

	// KmsKeyId represents key for KMS encryption key
	KmsKeyIDKey = "kmskeyid"

	// PVCNameKey contains name of the PVC for which is a volume provisioned.
	PVCNameKey = "csi.storage.k8s.io/pvc/name"

	// PVCNamespaceKey contains namespace of the PVC for which is a volume provisioned.
	PVCNamespaceKey = "csi.storage.k8s.io/pvc/namespace"

	// PVNameKey contains name of the final PV that will be used for the dynamically
	// provisioned volume
	PVNameKey = "csi.storage.k8s.io/pv/name"

	// VolumeSnapshotNameKey contains name of the snapshot
	VolumeSnapshotNameKey = "csi.storage.k8s.io/volumesnapshot/name"

	// VolumeSnapshotNamespaceKey contains namespace of the snapshot
	VolumeSnapshotNamespaceKey = "csi.storage.k8s.io/volumesnapshot/namespace"

	// VolumeSnapshotCotentNameKey contains name of the VolumeSnapshotContent that is the source
	// for the snapshot
	VolumeSnapshotContentNameKey = "csi.storage.k8s.io/volumesnapshotcontent/name"

	// BlockExpressKey increases the iops limit for io2 volumes to the block express limit
	BlockExpressKey = "blockexpress"

	// BlockSizeKey configures the block size when formatting a volume
	BlockSizeKey = "blocksize"

	// INodeSizeKey configures the inode size when formatting a volume
	INodeSizeKey = "inodesize"

	// BytesPerINodeKey configures the `bytes-per-inode` when formatting a volume
	BytesPerINodeKey = "bytesperinode"

	// NumberOfINodesKey configures the `number-of-inodes` when formatting a volume
	NumberOfINodesKey = "numberofinodes"

	// TagKeyPrefix contains the prefix of a volume parameter that designates it as
	// a tag to be attached to the resource
	TagKeyPrefix = "tagSpecification"
)

constants of keys in volume parameters

View Source 
const (
	// ResourceLifecycleTagPrefix is prefix of tag for provisioned EBS volume that
	// marks them as owned by the cluster. Used only when --cluster-id is set.
	ResourceLifecycleTagPrefix = "kubernetes.io/cluster/"

	// ResourceLifecycleOwned is the value we use when tagging resources to indicate
	// that the resource is considered owned and managed by the cluster,
	// and in particular that the lifecycle is tied to the lifecycle of the cluster.
	// From k8s.io/legacy-cloud-providers/aws/tags.go.
	ResourceLifecycleOwned = "owned"

	// NameTag is tag applied to provisioned EBS volume for backward compatibility with
	// in-tree volume plugin. Used only when --cluster-id is set.
	NameTag = "Name"

	// KubernetesClusterTag is tag applied to provisioned EBS volume for backward compatibility with
	// in-tree volume plugin. Used only when --cluster-id is set.
	// See https://github.com/kubernetes/cloud-provider-aws/blob/release-1.20/pkg/providers/v1/tags.go#L38-L41.
	KubernetesClusterTag = "KubernetesCluster"

	// PVCNameTag is tag applied to provisioned EBS volume for backward compatibility
	// with in-tree volume plugin. Value of the tag is PVC name. It is applied only when
	// the external provisioner sidecar is started with --extra-create-metadata=true and
	// thus provides such metadata to the CSI driver.
	PVCNameTag = "kubernetes.io/created-for/pvc/name"

	// PVCNamespaceTag is tag applied to provisioned EBS volume for backward compatibility
	// with in-tree volume plugin. Value of the tag is PVC namespace. It is applied only when
	// the external provisioner sidecar is started with --extra-create-metadata=true and
	// thus provides such metadata to the CSI driver.
	PVCNamespaceTag = "kubernetes.io/created-for/pvc/namespace"

	// PVNameTag is tag applied to provisioned EBS volume for backward compatibility
	// with in-tree volume plugin. Value of the tag is PV name. It is applied only when
	// the external provisioner sidecar is started with --extra-create-metadata=true and
	// thus provides such metadata to the CSI driver.
	PVNameTag = "kubernetes.io/created-for/pv/name"
)

constants for volume tags and their values

View Source 
const (
	// FSTypeExt2 represents the ext2 filesystem type
	FSTypeExt2 = "ext2"
	// FSTypeExt3 represents the ext3 filesystem type
	FSTypeExt3 = "ext3"
	// FSTypeExt4 represents the ext4 filesystem type
	FSTypeExt4 = "ext4"
	// FSTypeXfs represents the xfs filesystem type
	FSTypeXfs = "xfs"
	// FSTypeNtfs represents the ntfs filesystem type
	FSTypeNtfs = "ntfs"
)

constants for fstypes

View Source 
const (
	ModificationKeyVolumeType = "volumeType"

	ModificationKeyIOPS = "iops"

	ModificationKeyThroughput = "throughput"
)
View Source 
const (
	DriverName      = "ebs.csi.aws.com"
	AwsPartitionKey = "topology." + DriverName + "/partition"
	AwsAccountIDKey = "topology." + DriverName + "/account-id"
	AwsRegionKey    = "topology." + DriverName + "/region"
	AwsOutpostIDKey = "topology." + DriverName + "/outpost-id"

	WellKnownTopologyKey = "topology.kubernetes.io/zone"
	// DEPRECATED Use the WellKnownTopologyKey instead
	TopologyKey = "topology." + DriverName + "/zone"
)
View Source 
const (
	// AgentNotReadyNodeTaintKey contains the key of taints to be removed on driver startup
	AgentNotReadyNodeTaintKey = "ebs.csi.aws.com/agent-not-ready"
)

constants for node k8s API use

View Source 
const (
	//DefaultBlockSize represents the default block size (4KB)
	DefaultBlockSize = 4096
)

constants for disk block size

View Source 
const (
	DefaultCSIEndpoint = "unix://tmp/csi.sock"
)

constants for default command line flag values

View Source 
const (
	// devicePathKey represents key for device path in PublishContext
	// devicePath is the device path where the volume is attached to
	DevicePathKey = "devicePath"
)

constants of keys in PublishContext

View Source 
const (
	// FastSnapShotRestoreAvailabilityZones represents key for fast snapshot restore availability zones
	FastSnapshotRestoreAvailabilityZones = "fastsnapshotrestoreavailabilityzones"
)

constants of keys in snapshot parameters

View Source 
const (
	// VolumeAttributePartition represents key for partition config in VolumeContext
	// this represents the partition number on a device used to mount
	VolumeAttributePartition = "partition"
)

constants of keys in VolumeContext

View Source 
const (

	// VolumeOperationAlreadyExists is message fmt returned to CO when there is another in-flight call on the given volumeID
	VolumeOperationAlreadyExists = "An operation with the given volume=%q is already in progress"
)

Variables

View Source 
var (
	// NewMetadataFunc is a variable for the cloud.NewMetadata function that can
	// be overwritten in unit tests.
	NewMetadataFunc = cloud.NewMetadataService
	// NewCloudFunc is a variable for the cloud.NewCloud function that can
	// be overwritten in unit tests.
	NewCloudFunc = cloud.NewCloud
)
View Source 
var (
	FileSystemConfigs = map[string]fileSystemConfig{
		FSTypeExt2: {
			NotSupportedParams: map[string]struct{}{},
		},
		FSTypeExt3: {
			NotSupportedParams: map[string]struct{}{},
		},
		FSTypeExt4: {
			NotSupportedParams: map[string]struct{}{},
		},
		FSTypeXfs: {
			NotSupportedParams: map[string]struct{}{
				BytesPerINodeKey:  {},
				NumberOfINodesKey: {},
			},
		},
		FSTypeNtfs: {
			NotSupportedParams: map[string]struct{}{
				BlockSizeKey:      {},
				INodeSizeKey:      {},
				BytesPerINodeKey:  {},
				NumberOfINodesKey: {},
			},
		},
	}
)
View Source 
var (
	ValidFSTypes = map[string]struct{}{
		FSTypeExt2: {},
		FSTypeExt3: {},
		FSTypeExt4: {},
		FSTypeXfs:  {},
		FSTypeNtfs: {},
	}
)

Functions

func BuildOutpostArn added in v0.7.0 

func BuildOutpostArn(segments map[string]string) string

BuildOutpostArn returns the string representation of the outpost ARN from the given csi.TopologyRequirement.segments

func GetVersionJSON added in v0.2.0 

func GetVersionJSON() (string, error)

func InitOtelTracing added in v1.23.0 

func InitOtelTracing() (*otlptrace.Exporter, error)

func ValidateDriverOptions added in v0.5.0 

func ValidateDriverOptions(options *DriverOptions) error

func WithAwsSdkDebugLog added in v1.0.0 

func WithAwsSdkDebugLog(enableSdkDebugLog bool) func(*DriverOptions)

func WithEndpoint added in v0.5.0 

func WithEndpoint(endpoint string) func(*DriverOptions)

func WithExtraTags added in v0.8.0 

func WithExtraTags(extraTags map[string]string) func(*DriverOptions)

func WithExtraVolumeTags added in v0.5.0 

func WithExtraVolumeTags(extraVolumeTags map[string]string) func(*DriverOptions)

func WithKubernetesClusterID added in v0.6.0 

func WithKubernetesClusterID(clusterID string) func(*DriverOptions)

func WithMode added in v0.5.0 

func WithMode(mode Mode) func(*DriverOptions)

func WithOtelTracing added in v1.23.0 

func WithOtelTracing(enableOtelTracing bool) func(*DriverOptions)

func WithUserAgentExtra added in v1.19.0 

func WithUserAgentExtra(userAgentExtra string) func(*DriverOptions)

func WithVolumeAttachLimit added in v0.6.0 

func WithVolumeAttachLimit(volumeAttachLimit int64) func(*DriverOptions)

func WithWarnOnInvalidTag added in v1.6.0 

func WithWarnOnInvalidTag(warnOnInvalidTag bool) func(*DriverOptions)

Types

type DeviceIdentifier added in v1.4.0 

type DeviceIdentifier interface {
	Lstat(name string) (os.FileInfo, error)
	EvalSymlinks(path string) (string, error)
}

DeviceIdentifier is for mocking os io functions used for the driver to identify an EBS volume's corresponding device (in Linux, the path under /dev; in Windows, the volume number) so that it can mount it. For volumes already mounted, see GetDeviceNameFromMount. https://docs.aws.amazon.com/AWSEC2/latest/UserGuide/nvme-ebs-volumes.html#identify-nvme-ebs-device

type Driver 

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

func NewDriver 

func NewDriver(options ...func(*DriverOptions)) (*Driver, error)

func (*Driver) ControllerExpandVolume added in v0.4.0 

func (d *Driver) ControllerExpandVolume(ctx context.Context, req *csi.ControllerExpandVolumeRequest) (*csi.ControllerExpandVolumeResponse, error)

func (*Driver) ControllerGetCapabilities 

func (d *Driver) ControllerGetCapabilities(ctx context.Context, req *csi.ControllerGetCapabilitiesRequest) (*csi.ControllerGetCapabilitiesResponse, error)

func (*Driver) ControllerGetVolume added in v1.0.0 

func (d *Driver) ControllerGetVolume(ctx context.Context, req *csi.ControllerGetVolumeRequest) (*csi.ControllerGetVolumeResponse, error)

func (*Driver) ControllerPublishVolume 

func (d *Driver) ControllerPublishVolume(ctx context.Context, req *csi.ControllerPublishVolumeRequest) (*csi.ControllerPublishVolumeResponse, error)

func (*Driver) ControllerUnpublishVolume 

func (d *Driver) ControllerUnpublishVolume(ctx context.Context, req *csi.ControllerUnpublishVolumeRequest) (*csi.ControllerUnpublishVolumeResponse, error)

func (*Driver) CreateSnapshot 

func (d *Driver) CreateSnapshot(ctx context.Context, req *csi.CreateSnapshotRequest) (*csi.CreateSnapshotResponse, error)

func (*Driver) CreateVolume 

func (d *Driver) CreateVolume(ctx context.Context, req *csi.CreateVolumeRequest) (*csi.CreateVolumeResponse, error)

func (*Driver) DeleteSnapshot 

func (d *Driver) DeleteSnapshot(ctx context.Context, req *csi.DeleteSnapshotRequest) (*csi.DeleteSnapshotResponse, error)

func (*Driver) DeleteVolume 

func (d *Driver) DeleteVolume(ctx context.Context, req *csi.DeleteVolumeRequest) (*csi.DeleteVolumeResponse, error)

func (*Driver) GetCSIDriverModificationCapability added in v1.19.0 

func (d *Driver) GetCSIDriverModificationCapability(
	_ context.Context,
	_ *rpc.GetCSIDriverModificationCapabilityRequest,
) (*rpc.GetCSIDriverModificationCapabilityResponse, error)

func (*Driver) GetCapacity 

func (d *Driver) GetCapacity(ctx context.Context, req *csi.GetCapacityRequest) (*csi.GetCapacityResponse, error)

func (*Driver) GetPluginCapabilities 

func (d *Driver) GetPluginCapabilities(ctx context.Context, req *csi.GetPluginCapabilitiesRequest) (*csi.GetPluginCapabilitiesResponse, error)

func (*Driver) GetPluginInfo 

func (d *Driver) GetPluginInfo(ctx context.Context, req *csi.GetPluginInfoRequest) (*csi.GetPluginInfoResponse, error)

func (*Driver) IsBlockDevice added in v0.9.0 

func (d *Driver) IsBlockDevice(fullPath string) (bool, error)

IsBlock checks if the given path is a block device

func (*Driver) ListSnapshots 

func (d *Driver) ListSnapshots(ctx context.Context, req *csi.ListSnapshotsRequest) (*csi.ListSnapshotsResponse, error)

func (*Driver) ListVolumes 

func (d *Driver) ListVolumes(ctx context.Context, req *csi.ListVolumesRequest) (*csi.ListVolumesResponse, error)

func (*Driver) ModifyVolumeProperties added in v1.19.0 

func (d *Driver) ModifyVolumeProperties(
	ctx context.Context,
	req *rpc.ModifyVolumePropertiesRequest,
) (*rpc.ModifyVolumePropertiesResponse, error)

func (*Driver) NodeExpandVolume added in v0.4.0 

func (d *Driver) NodeExpandVolume(ctx context.Context, req *csi.NodeExpandVolumeRequest) (*csi.NodeExpandVolumeResponse, error)

func (*Driver) NodeGetCapabilities 

func (d *Driver) NodeGetCapabilities(ctx context.Context, req *csi.NodeGetCapabilitiesRequest) (*csi.NodeGetCapabilitiesResponse, error)

func (*Driver) NodeGetInfo 

func (d *Driver) NodeGetInfo(ctx context.Context, req *csi.NodeGetInfoRequest) (*csi.NodeGetInfoResponse, error)

func (*Driver) NodeGetVolumeStats added in v0.2.0 

func (d *Driver) NodeGetVolumeStats(ctx context.Context, req *csi.NodeGetVolumeStatsRequest) (*csi.NodeGetVolumeStatsResponse, error)

func (*Driver) NodePublishVolume 

func (d *Driver) NodePublishVolume(ctx context.Context, req *csi.NodePublishVolumeRequest) (*csi.NodePublishVolumeResponse, error)

func (*Driver) NodeStageVolume 

func (d *Driver) NodeStageVolume(ctx context.Context, req *csi.NodeStageVolumeRequest) (*csi.NodeStageVolumeResponse, error)

func (*Driver) NodeUnpublishVolume 

func (d *Driver) NodeUnpublishVolume(ctx context.Context, req *csi.NodeUnpublishVolumeRequest) (*csi.NodeUnpublishVolumeResponse, error)

func (*Driver) NodeUnstageVolume 

func (d *Driver) NodeUnstageVolume(ctx context.Context, req *csi.NodeUnstageVolumeRequest) (*csi.NodeUnstageVolumeResponse, error)

func (*Driver) Probe 

func (d *Driver) Probe(ctx context.Context, req *csi.ProbeRequest) (*csi.ProbeResponse, error)

func (*Driver) Run 

func (d *Driver) Run() error

func (*Driver) Stop 

func (d *Driver) Stop()

func (*Driver) ValidateVolumeCapabilities 

func (d *Driver) ValidateVolumeCapabilities(ctx context.Context, req *csi.ValidateVolumeCapabilitiesRequest) (*csi.ValidateVolumeCapabilitiesResponse, error)

type DriverOptions added in v0.5.0 

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

type JSONPatch added in v1.19.0 

type JSONPatch struct {
	OP    string      `json:"op,omitempty"`
	Path  string      `json:"path,omitempty"`
	Value interface{} `json:"value"`
}

Struct for JSON patch operations

type MockCoreV1Interface added in v1.19.0 

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

MockCoreV1Interface is a mock of CoreV1Interface interface.

func NewMockCoreV1Interface added in v1.19.0 

func NewMockCoreV1Interface(ctrl *gomock.Controller) *MockCoreV1Interface

NewMockCoreV1Interface creates a new mock instance.

func (*MockCoreV1Interface) ComponentStatuses added in v1.19.0 

func (m *MockCoreV1Interface) ComponentStatuses() v12.ComponentStatusInterface

ComponentStatuses mocks base method.

func (*MockCoreV1Interface) ConfigMaps added in v1.19.0 

func (m *MockCoreV1Interface) ConfigMaps(arg0 string) v12.ConfigMapInterface

ConfigMaps mocks base method.

func (*MockCoreV1Interface) EXPECT added in v1.19.0 

func (m *MockCoreV1Interface) EXPECT() *MockCoreV1InterfaceMockRecorder

EXPECT returns an object that allows the caller to indicate expected use.

func (*MockCoreV1Interface) Endpoints added in v1.19.0 

func (m *MockCoreV1Interface) Endpoints(arg0 string) v12.EndpointsInterface

Endpoints mocks base method.

func (*MockCoreV1Interface) Events added in v1.19.0 

func (m *MockCoreV1Interface) Events(arg0 string) v12.EventInterface

Events mocks base method.

func (*MockCoreV1Interface) LimitRanges added in v1.19.0 

func (m *MockCoreV1Interface) LimitRanges(arg0 string) v12.LimitRangeInterface

LimitRanges mocks base method.

func (*MockCoreV1Interface) Namespaces added in v1.19.0 

func (m *MockCoreV1Interface) Namespaces() v12.NamespaceInterface

Namespaces mocks base method.

func (*MockCoreV1Interface) Nodes added in v1.19.0 

func (m *MockCoreV1Interface) Nodes() v12.NodeInterface

Nodes mocks base method.

func (*MockCoreV1Interface) PersistentVolumeClaims added in v1.19.0 

func (m *MockCoreV1Interface) PersistentVolumeClaims(arg0 string) v12.PersistentVolumeClaimInterface

PersistentVolumeClaims mocks base method.

func (*MockCoreV1Interface) PersistentVolumes added in v1.19.0 

func (m *MockCoreV1Interface) PersistentVolumes() v12.PersistentVolumeInterface

PersistentVolumes mocks base method.

func (*MockCoreV1Interface) PodTemplates added in v1.19.0 

func (m *MockCoreV1Interface) PodTemplates(arg0 string) v12.PodTemplateInterface

PodTemplates mocks base method.

func (*MockCoreV1Interface) Pods added in v1.19.0 

func (m *MockCoreV1Interface) Pods(arg0 string) v12.PodInterface

Pods mocks base method.

func (*MockCoreV1Interface) RESTClient added in v1.19.0 

func (m *MockCoreV1Interface) RESTClient() rest.Interface

RESTClient mocks base method.

func (*MockCoreV1Interface) ReplicationControllers added in v1.19.0 

func (m *MockCoreV1Interface) ReplicationControllers(arg0 string) v12.ReplicationControllerInterface

ReplicationControllers mocks base method.

func (*MockCoreV1Interface) ResourceQuotas added in v1.19.0 

func (m *MockCoreV1Interface) ResourceQuotas(arg0 string) v12.ResourceQuotaInterface

ResourceQuotas mocks base method.

func (*MockCoreV1Interface) Secrets added in v1.19.0 

func (m *MockCoreV1Interface) Secrets(arg0 string) v12.SecretInterface

Secrets mocks base method.

func (*MockCoreV1Interface) ServiceAccounts added in v1.19.0 

func (m *MockCoreV1Interface) ServiceAccounts(arg0 string) v12.ServiceAccountInterface

ServiceAccounts mocks base method.

func (*MockCoreV1Interface) Services added in v1.19.0 

func (m *MockCoreV1Interface) Services(arg0 string) v12.ServiceInterface

Services mocks base method.

type MockCoreV1InterfaceMockRecorder added in v1.19.0 

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

MockCoreV1InterfaceMockRecorder is the mock recorder for MockCoreV1Interface.

func (*MockCoreV1InterfaceMockRecorder) ComponentStatuses added in v1.19.0 

func (mr *MockCoreV1InterfaceMockRecorder) ComponentStatuses() *gomock.Call

ComponentStatuses indicates an expected call of ComponentStatuses.

func (*MockCoreV1InterfaceMockRecorder) ConfigMaps added in v1.19.0 

func (mr *MockCoreV1InterfaceMockRecorder) ConfigMaps(arg0 interface{}) *gomock.Call

ConfigMaps indicates an expected call of ConfigMaps.

func (*MockCoreV1InterfaceMockRecorder) Endpoints added in v1.19.0 

func (mr *MockCoreV1InterfaceMockRecorder) Endpoints(arg0 interface{}) *gomock.Call

Endpoints indicates an expected call of Endpoints.

func (*MockCoreV1InterfaceMockRecorder) Events added in v1.19.0 

func (mr *MockCoreV1InterfaceMockRecorder) Events(arg0 interface{}) *gomock.Call

Events indicates an expected call of Events.

func (*MockCoreV1InterfaceMockRecorder) LimitRanges added in v1.19.0 

func (mr *MockCoreV1InterfaceMockRecorder) LimitRanges(arg0 interface{}) *gomock.Call

LimitRanges indicates an expected call of LimitRanges.

func (*MockCoreV1InterfaceMockRecorder) Namespaces added in v1.19.0 

func (mr *MockCoreV1InterfaceMockRecorder) Namespaces() *gomock.Call

Namespaces indicates an expected call of Namespaces.

func (*MockCoreV1InterfaceMockRecorder) Nodes added in v1.19.0 

func (mr *MockCoreV1InterfaceMockRecorder) Nodes() *gomock.Call

Nodes indicates an expected call of Nodes.

func (*MockCoreV1InterfaceMockRecorder) PersistentVolumeClaims added in v1.19.0 

func (mr *MockCoreV1InterfaceMockRecorder) PersistentVolumeClaims(arg0 interface{}) *gomock.Call

PersistentVolumeClaims indicates an expected call of PersistentVolumeClaims.

func (*MockCoreV1InterfaceMockRecorder) PersistentVolumes added in v1.19.0 

func (mr *MockCoreV1InterfaceMockRecorder) PersistentVolumes() *gomock.Call

PersistentVolumes indicates an expected call of PersistentVolumes.

func (*MockCoreV1InterfaceMockRecorder) PodTemplates added in v1.19.0 

func (mr *MockCoreV1InterfaceMockRecorder) PodTemplates(arg0 interface{}) *gomock.Call

PodTemplates indicates an expected call of PodTemplates.

func (*MockCoreV1InterfaceMockRecorder) Pods added in v1.19.0 

func (mr *MockCoreV1InterfaceMockRecorder) Pods(arg0 interface{}) *gomock.Call

Pods indicates an expected call of Pods.

func (*MockCoreV1InterfaceMockRecorder) RESTClient added in v1.19.0 

func (mr *MockCoreV1InterfaceMockRecorder) RESTClient() *gomock.Call

RESTClient indicates an expected call of RESTClient.

func (*MockCoreV1InterfaceMockRecorder) ReplicationControllers added in v1.19.0 

func (mr *MockCoreV1InterfaceMockRecorder) ReplicationControllers(arg0 interface{}) *gomock.Call

ReplicationControllers indicates an expected call of ReplicationControllers.

func (*MockCoreV1InterfaceMockRecorder) ResourceQuotas added in v1.19.0 

func (mr *MockCoreV1InterfaceMockRecorder) ResourceQuotas(arg0 interface{}) *gomock.Call

ResourceQuotas indicates an expected call of ResourceQuotas.

func (*MockCoreV1InterfaceMockRecorder) Secrets added in v1.19.0 

func (mr *MockCoreV1InterfaceMockRecorder) Secrets(arg0 interface{}) *gomock.Call

Secrets indicates an expected call of Secrets.

func (*MockCoreV1InterfaceMockRecorder) ServiceAccounts added in v1.19.0 

func (mr *MockCoreV1InterfaceMockRecorder) ServiceAccounts(arg0 interface{}) *gomock.Call

ServiceAccounts indicates an expected call of ServiceAccounts.

func (*MockCoreV1InterfaceMockRecorder) Services added in v1.19.0 

func (mr *MockCoreV1InterfaceMockRecorder) Services(arg0 interface{}) *gomock.Call

Services indicates an expected call of Services.

type MockDeviceIdentifier added in v1.4.0 

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

MockDeviceIdentifier is a mock of DeviceIdentifier interface.

func NewMockDeviceIdentifier added in v1.4.0 

func NewMockDeviceIdentifier(ctrl *gomock.Controller) *MockDeviceIdentifier

NewMockDeviceIdentifier creates a new mock instance.

func (*MockDeviceIdentifier) EXPECT added in v1.4.0 

func (m *MockDeviceIdentifier) EXPECT() *MockDeviceIdentifierMockRecorder

EXPECT returns an object that allows the caller to indicate expected use. 

func (m *MockDeviceIdentifier) EvalSymlinks(path string) (string, error)

EvalSymlinks mocks base method.

func (*MockDeviceIdentifier) Lstat added in v1.4.0 

func (m *MockDeviceIdentifier) Lstat(name string) (os.FileInfo, error)

Lstat mocks base method.

type MockDeviceIdentifierMockRecorder added in v1.4.0 

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

MockDeviceIdentifierMockRecorder is the mock recorder for MockDeviceIdentifier. 

func (mr *MockDeviceIdentifierMockRecorder) EvalSymlinks(path interface{}) *gomock.Call

EvalSymlinks indicates an expected call of EvalSymlinks.

func (*MockDeviceIdentifierMockRecorder) Lstat added in v1.4.0 

func (mr *MockDeviceIdentifierMockRecorder) Lstat(name interface{}) *gomock.Call

Lstat indicates an expected call of Lstat.

type MockKubernetesClient added in v1.19.0 

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

MockKubernetesClient is a mock of Interface interface.

func NewMockKubernetesClient added in v1.19.0 

func NewMockKubernetesClient(ctrl *gomock.Controller) *MockKubernetesClient

NewMockKubernetesClient creates a new mock instance.

func (*MockKubernetesClient) AdmissionregistrationV1 added in v1.19.0 

func (m *MockKubernetesClient) AdmissionregistrationV1() v1.AdmissionregistrationV1Interface

AdmissionregistrationV1 mocks base method.

func (*MockKubernetesClient) AdmissionregistrationV1alpha1 added in v1.19.0 

func (m *MockKubernetesClient) AdmissionregistrationV1alpha1() v1alpha1.AdmissionregistrationV1alpha1Interface

AdmissionregistrationV1alpha1 mocks base method.

func (*MockKubernetesClient) AdmissionregistrationV1beta1 added in v1.19.0 

func (m *MockKubernetesClient) AdmissionregistrationV1beta1() v1beta1.AdmissionregistrationV1beta1Interface

AdmissionregistrationV1beta1 mocks base method.

func (*MockKubernetesClient) AppsV1 added in v1.19.0 

func (m *MockKubernetesClient) AppsV1() v10.AppsV1Interface

AppsV1 mocks base method.

func (*MockKubernetesClient) AppsV1beta1 added in v1.19.0 

func (m *MockKubernetesClient) AppsV1beta1() v1beta10.AppsV1beta1Interface

AppsV1beta1 mocks base method.

func (*MockKubernetesClient) AppsV1beta2 added in v1.19.0 

func (m *MockKubernetesClient) AppsV1beta2() v1beta2.AppsV1beta2Interface

AppsV1beta2 mocks base method.

func (*MockKubernetesClient) AuthenticationV1 added in v1.19.0 

func (m *MockKubernetesClient) AuthenticationV1() v11.AuthenticationV1Interface

AuthenticationV1 mocks base method.

func (*MockKubernetesClient) AuthenticationV1alpha1 added in v1.19.0 

func (m *MockKubernetesClient) AuthenticationV1alpha1() v1alpha11.AuthenticationV1alpha1Interface

AuthenticationV1alpha1 mocks base method.

func (*MockKubernetesClient) AuthenticationV1beta1 added in v1.19.0 

func (m *MockKubernetesClient) AuthenticationV1beta1() v1beta11.AuthenticationV1beta1Interface

AuthenticationV1beta1 mocks base method.

func (*MockKubernetesClient) AuthorizationV1 added in v1.19.0 

func (m *MockKubernetesClient) AuthorizationV1() v12.AuthorizationV1Interface

AuthorizationV1 mocks base method.

func (*MockKubernetesClient) AuthorizationV1beta1 added in v1.19.0 

func (m *MockKubernetesClient) AuthorizationV1beta1() v1beta12.AuthorizationV1beta1Interface

AuthorizationV1beta1 mocks base method.

func (*MockKubernetesClient) AutoscalingV1 added in v1.19.0 

func (m *MockKubernetesClient) AutoscalingV1() v13.AutoscalingV1Interface

AutoscalingV1 mocks base method.

func (*MockKubernetesClient) AutoscalingV2 added in v1.19.0 

func (m *MockKubernetesClient) AutoscalingV2() v2.AutoscalingV2Interface

AutoscalingV2 mocks base method.

func (*MockKubernetesClient) AutoscalingV2beta1 added in v1.19.0 

func (m *MockKubernetesClient) AutoscalingV2beta1() v2beta1.AutoscalingV2beta1Interface

AutoscalingV2beta1 mocks base method.

func (*MockKubernetesClient) AutoscalingV2beta2 added in v1.19.0 

func (m *MockKubernetesClient) AutoscalingV2beta2() v2beta2.AutoscalingV2beta2Interface

AutoscalingV2beta2 mocks base method.

func (*MockKubernetesClient) BatchV1 added in v1.19.0 

func (m *MockKubernetesClient) BatchV1() v14.BatchV1Interface

BatchV1 mocks base method.

func (*MockKubernetesClient) BatchV1beta1 added in v1.19.0 

func (m *MockKubernetesClient) BatchV1beta1() v1beta13.BatchV1beta1Interface

BatchV1beta1 mocks base method.

func (*MockKubernetesClient) CertificatesV1 added in v1.19.0 

func (m *MockKubernetesClient) CertificatesV1() v15.CertificatesV1Interface

CertificatesV1 mocks base method.

func (*MockKubernetesClient) CertificatesV1alpha1 added in v1.19.0 

func (m *MockKubernetesClient) CertificatesV1alpha1() v1alpha12.CertificatesV1alpha1Interface

CertificatesV1alpha1 mocks base method.

func (*MockKubernetesClient) CertificatesV1beta1 added in v1.19.0 

func (m *MockKubernetesClient) CertificatesV1beta1() v1beta14.CertificatesV1beta1Interface

CertificatesV1beta1 mocks base method.

func (*MockKubernetesClient) CoordinationV1 added in v1.19.0 

func (m *MockKubernetesClient) CoordinationV1() v16.CoordinationV1Interface

CoordinationV1 mocks base method.

func (*MockKubernetesClient) CoordinationV1beta1 added in v1.19.0 

func (m *MockKubernetesClient) CoordinationV1beta1() v1beta15.CoordinationV1beta1Interface

CoordinationV1beta1 mocks base method.

func (*MockKubernetesClient) CoreV1 added in v1.19.0 

func (m *MockKubernetesClient) CoreV1() v17.CoreV1Interface

CoreV1 mocks base method.

func (*MockKubernetesClient) Discovery added in v1.19.0 

func (m *MockKubernetesClient) Discovery() discovery.DiscoveryInterface

Discovery mocks base method.

func (*MockKubernetesClient) DiscoveryV1 added in v1.19.0 

func (m *MockKubernetesClient) DiscoveryV1() v18.DiscoveryV1Interface

DiscoveryV1 mocks base method.

func (*MockKubernetesClient) DiscoveryV1beta1 added in v1.19.0 

func (m *MockKubernetesClient) DiscoveryV1beta1() v1beta16.DiscoveryV1beta1Interface

DiscoveryV1beta1 mocks base method.

func (*MockKubernetesClient) EXPECT added in v1.19.0 

func (m *MockKubernetesClient) EXPECT() *MockKubernetesClientMockRecorder

EXPECT returns an object that allows the caller to indicate expected use.

func (*MockKubernetesClient) EventsV1 added in v1.19.0 

func (m *MockKubernetesClient) EventsV1() v19.EventsV1Interface

EventsV1 mocks base method.

func (*MockKubernetesClient) EventsV1beta1 added in v1.19.0 

func (m *MockKubernetesClient) EventsV1beta1() v1beta17.EventsV1beta1Interface

EventsV1beta1 mocks base method.

func (*MockKubernetesClient) ExtensionsV1beta1 added in v1.19.0 

func (m *MockKubernetesClient) ExtensionsV1beta1() v1beta18.ExtensionsV1beta1Interface

ExtensionsV1beta1 mocks base method.

func (*MockKubernetesClient) FlowcontrolV1alpha1 added in v1.19.0 

func (m *MockKubernetesClient) FlowcontrolV1alpha1() v1alpha13.FlowcontrolV1alpha1Interface

FlowcontrolV1alpha1 mocks base method.

func (*MockKubernetesClient) FlowcontrolV1beta1 added in v1.19.0 

func (m *MockKubernetesClient) FlowcontrolV1beta1() v1beta19.FlowcontrolV1beta1Interface

FlowcontrolV1beta1 mocks base method.

func (*MockKubernetesClient) FlowcontrolV1beta2 added in v1.19.0 

func (m *MockKubernetesClient) FlowcontrolV1beta2() v1beta20.FlowcontrolV1beta2Interface

FlowcontrolV1beta2 mocks base method.

func (*MockKubernetesClient) FlowcontrolV1beta3 added in v1.19.0 

func (m *MockKubernetesClient) FlowcontrolV1beta3() v1beta3.FlowcontrolV1beta3Interface

FlowcontrolV1beta3 mocks base method.

func (*MockKubernetesClient) InternalV1alpha1 added in v1.19.0 

func (m *MockKubernetesClient) InternalV1alpha1() v1alpha10.InternalV1alpha1Interface

InternalV1alpha1 mocks base method.

func (*MockKubernetesClient) NetworkingV1 added in v1.19.0 

func (m *MockKubernetesClient) NetworkingV1() v110.NetworkingV1Interface

NetworkingV1 mocks base method.

func (*MockKubernetesClient) NetworkingV1alpha1 added in v1.19.0 

func (m *MockKubernetesClient) NetworkingV1alpha1() v1alpha14.NetworkingV1alpha1Interface

NetworkingV1alpha1 mocks base method.

func (*MockKubernetesClient) NetworkingV1beta1 added in v1.19.0 

func (m *MockKubernetesClient) NetworkingV1beta1() v1beta110.NetworkingV1beta1Interface

NetworkingV1beta1 mocks base method.

func (*MockKubernetesClient) NodeV1 added in v1.19.0 

func (m *MockKubernetesClient) NodeV1() v111.NodeV1Interface

NodeV1 mocks base method.

func (*MockKubernetesClient) NodeV1alpha1 added in v1.19.0 

func (m *MockKubernetesClient) NodeV1alpha1() v1alpha15.NodeV1alpha1Interface

NodeV1alpha1 mocks base method.

func (*MockKubernetesClient) NodeV1beta1 added in v1.19.0 

func (m *MockKubernetesClient) NodeV1beta1() v1beta111.NodeV1beta1Interface

NodeV1beta1 mocks base method.

func (*MockKubernetesClient) PolicyV1 added in v1.19.0 

func (m *MockKubernetesClient) PolicyV1() v112.PolicyV1Interface

PolicyV1 mocks base method.

func (*MockKubernetesClient) PolicyV1beta1 added in v1.19.0 

func (m *MockKubernetesClient) PolicyV1beta1() v1beta112.PolicyV1beta1Interface

PolicyV1beta1 mocks base method.

func (*MockKubernetesClient) RbacV1 added in v1.19.0 

func (m *MockKubernetesClient) RbacV1() v113.RbacV1Interface

RbacV1 mocks base method.

func (*MockKubernetesClient) RbacV1alpha1 added in v1.19.0 

func (m *MockKubernetesClient) RbacV1alpha1() v1alpha16.RbacV1alpha1Interface

RbacV1alpha1 mocks base method.

func (*MockKubernetesClient) RbacV1beta1 added in v1.19.0 

func (m *MockKubernetesClient) RbacV1beta1() v1beta113.RbacV1beta1Interface

RbacV1beta1 mocks base method.

func (*MockKubernetesClient) ResourceV1alpha2 added in v1.19.0 

func (m *MockKubernetesClient) ResourceV1alpha2() v1alpha2.ResourceV1alpha2Interface

ResourceV1alpha2 mocks base method.

func (*MockKubernetesClient) SchedulingV1 added in v1.19.0 

func (m *MockKubernetesClient) SchedulingV1() v114.SchedulingV1Interface

SchedulingV1 mocks base method.

func (*MockKubernetesClient) SchedulingV1alpha1 added in v1.19.0 

func (m *MockKubernetesClient) SchedulingV1alpha1() v1alpha17.SchedulingV1alpha1Interface

SchedulingV1alpha1 mocks base method.

func (*MockKubernetesClient) SchedulingV1beta1 added in v1.19.0 

func (m *MockKubernetesClient) SchedulingV1beta1() v1beta114.SchedulingV1beta1Interface

SchedulingV1beta1 mocks base method.

func (*MockKubernetesClient) StorageV1 added in v1.19.0 

func (m *MockKubernetesClient) StorageV1() v115.StorageV1Interface

StorageV1 mocks base method.

func (*MockKubernetesClient) StorageV1alpha1 added in v1.19.0 

func (m *MockKubernetesClient) StorageV1alpha1() v1alpha18.StorageV1alpha1Interface

StorageV1alpha1 mocks base method.

func (*MockKubernetesClient) StorageV1beta1 added in v1.19.0 

func (m *MockKubernetesClient) StorageV1beta1() v1beta115.StorageV1beta1Interface

StorageV1beta1 mocks base method.

type MockKubernetesClientMockRecorder added in v1.19.0 

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

MockKubernetesClientMockRecorder is the mock recorder for MockKubernetesClient.

func (*MockKubernetesClientMockRecorder) AdmissionregistrationV1 added in v1.19.0 

func (mr *MockKubernetesClientMockRecorder) AdmissionregistrationV1() *gomock.Call

AdmissionregistrationV1 indicates an expected call of AdmissionregistrationV1.

func (*MockKubernetesClientMockRecorder) AdmissionregistrationV1alpha1 added in v1.19.0 

func (mr *MockKubernetesClientMockRecorder) AdmissionregistrationV1alpha1() *gomock.Call

AdmissionregistrationV1alpha1 indicates an expected call of AdmissionregistrationV1alpha1.

func (*MockKubernetesClientMockRecorder) AdmissionregistrationV1beta1 added in v1.19.0 

func (mr *MockKubernetesClientMockRecorder) AdmissionregistrationV1beta1() *gomock.Call

AdmissionregistrationV1beta1 indicates an expected call of AdmissionregistrationV1beta1.

func (*MockKubernetesClientMockRecorder) AppsV1 added in v1.19.0 

func (mr *MockKubernetesClientMockRecorder) AppsV1() *gomock.Call

AppsV1 indicates an expected call of AppsV1.

func (*MockKubernetesClientMockRecorder) AppsV1beta1 added in v1.19.0 

func (mr *MockKubernetesClientMockRecorder) AppsV1beta1() *gomock.Call

AppsV1beta1 indicates an expected call of AppsV1beta1.

func (*MockKubernetesClientMockRecorder) AppsV1beta2 added in v1.19.0 

func (mr *MockKubernetesClientMockRecorder) AppsV1beta2() *gomock.Call

AppsV1beta2 indicates an expected call of AppsV1beta2.

func (*MockKubernetesClientMockRecorder) AuthenticationV1 added in v1.19.0 

func (mr *MockKubernetesClientMockRecorder) AuthenticationV1() *gomock.Call

AuthenticationV1 indicates an expected call of AuthenticationV1.

func (*MockKubernetesClientMockRecorder) AuthenticationV1alpha1 added in v1.19.0 

func (mr *MockKubernetesClientMockRecorder) AuthenticationV1alpha1() *gomock.Call

AuthenticationV1alpha1 indicates an expected call of AuthenticationV1alpha1.

func (*MockKubernetesClientMockRecorder) AuthenticationV1beta1 added in v1.19.0 

func (mr *MockKubernetesClientMockRecorder) AuthenticationV1beta1() *gomock.Call

AuthenticationV1beta1 indicates an expected call of AuthenticationV1beta1.

func (*MockKubernetesClientMockRecorder) AuthorizationV1 added in v1.19.0 

func (mr *MockKubernetesClientMockRecorder) AuthorizationV1() *gomock.Call

AuthorizationV1 indicates an expected call of AuthorizationV1.

func (*MockKubernetesClientMockRecorder) AuthorizationV1beta1 added in v1.19.0 

func (mr *MockKubernetesClientMockRecorder) AuthorizationV1beta1() *gomock.Call

AuthorizationV1beta1 indicates an expected call of AuthorizationV1beta1.

func (*MockKubernetesClientMockRecorder) AutoscalingV1 added in v1.19.0 

func (mr *MockKubernetesClientMockRecorder) AutoscalingV1() *gomock.Call

AutoscalingV1 indicates an expected call of AutoscalingV1.

func (*MockKubernetesClientMockRecorder) AutoscalingV2 added in v1.19.0 

func (mr *MockKubernetesClientMockRecorder) AutoscalingV2() *gomock.Call

AutoscalingV2 indicates an expected call of AutoscalingV2.

func (*MockKubernetesClientMockRecorder) AutoscalingV2beta1 added in v1.19.0 

func (mr *MockKubernetesClientMockRecorder) AutoscalingV2beta1() *gomock.Call

AutoscalingV2beta1 indicates an expected call of AutoscalingV2beta1.

func (*MockKubernetesClientMockRecorder) AutoscalingV2beta2 added in v1.19.0 

func (mr *MockKubernetesClientMockRecorder) AutoscalingV2beta2() *gomock.Call

AutoscalingV2beta2 indicates an expected call of AutoscalingV2beta2.

func (*MockKubernetesClientMockRecorder) BatchV1 added in v1.19.0 

func (mr *MockKubernetesClientMockRecorder) BatchV1() *gomock.Call

BatchV1 indicates an expected call of BatchV1.

func (*MockKubernetesClientMockRecorder) BatchV1beta1 added in v1.19.0 

func (mr *MockKubernetesClientMockRecorder) BatchV1beta1() *gomock.Call

BatchV1beta1 indicates an expected call of BatchV1beta1.

func (*MockKubernetesClientMockRecorder) CertificatesV1 added in v1.19.0 

func (mr *MockKubernetesClientMockRecorder) CertificatesV1() *gomock.Call

CertificatesV1 indicates an expected call of CertificatesV1.

func (*MockKubernetesClientMockRecorder) CertificatesV1alpha1 added in v1.19.0 

func (mr *MockKubernetesClientMockRecorder) CertificatesV1alpha1() *gomock.Call

CertificatesV1alpha1 indicates an expected call of CertificatesV1alpha1.

func (*MockKubernetesClientMockRecorder) CertificatesV1beta1 added in v1.19.0 

func (mr *MockKubernetesClientMockRecorder) CertificatesV1beta1() *gomock.Call

CertificatesV1beta1 indicates an expected call of CertificatesV1beta1.

func (*MockKubernetesClientMockRecorder) CoordinationV1 added in v1.19.0 

func (mr *MockKubernetesClientMockRecorder) CoordinationV1() *gomock.Call

CoordinationV1 indicates an expected call of CoordinationV1.

func (*MockKubernetesClientMockRecorder) CoordinationV1beta1 added in v1.19.0 

func (mr *MockKubernetesClientMockRecorder) CoordinationV1beta1() *gomock.Call

CoordinationV1beta1 indicates an expected call of CoordinationV1beta1.

func (*MockKubernetesClientMockRecorder) CoreV1 added in v1.19.0 

func (mr *MockKubernetesClientMockRecorder) CoreV1() *gomock.Call

CoreV1 indicates an expected call of CoreV1.

func (*MockKubernetesClientMockRecorder) Discovery added in v1.19.0 

func (mr *MockKubernetesClientMockRecorder) Discovery() *gomock.Call

Discovery indicates an expected call of Discovery.

func (*MockKubernetesClientMockRecorder) DiscoveryV1 added in v1.19.0 

func (mr *MockKubernetesClientMockRecorder) DiscoveryV1() *gomock.Call

DiscoveryV1 indicates an expected call of DiscoveryV1.

func (*MockKubernetesClientMockRecorder) DiscoveryV1beta1 added in v1.19.0 

func (mr *MockKubernetesClientMockRecorder) DiscoveryV1beta1() *gomock.Call

DiscoveryV1beta1 indicates an expected call of DiscoveryV1beta1.

func (*MockKubernetesClientMockRecorder) EventsV1 added in v1.19.0 

func (mr *MockKubernetesClientMockRecorder) EventsV1() *gomock.Call

EventsV1 indicates an expected call of EventsV1.

func (*MockKubernetesClientMockRecorder) EventsV1beta1 added in v1.19.0 

func (mr *MockKubernetesClientMockRecorder) EventsV1beta1() *gomock.Call

EventsV1beta1 indicates an expected call of EventsV1beta1.

func (*MockKubernetesClientMockRecorder) ExtensionsV1beta1 added in v1.19.0 

func (mr *MockKubernetesClientMockRecorder) ExtensionsV1beta1() *gomock.Call

ExtensionsV1beta1 indicates an expected call of ExtensionsV1beta1.

func (*MockKubernetesClientMockRecorder) FlowcontrolV1alpha1 added in v1.19.0 

func (mr *MockKubernetesClientMockRecorder) FlowcontrolV1alpha1() *gomock.Call

FlowcontrolV1alpha1 indicates an expected call of FlowcontrolV1alpha1.

func (*MockKubernetesClientMockRecorder) FlowcontrolV1beta1 added in v1.19.0 

func (mr *MockKubernetesClientMockRecorder) FlowcontrolV1beta1() *gomock.Call

FlowcontrolV1beta1 indicates an expected call of FlowcontrolV1beta1.

func (*MockKubernetesClientMockRecorder) FlowcontrolV1beta2 added in v1.19.0 

func (mr *MockKubernetesClientMockRecorder) FlowcontrolV1beta2() *gomock.Call

FlowcontrolV1beta2 indicates an expected call of FlowcontrolV1beta2.

func (*MockKubernetesClientMockRecorder) FlowcontrolV1beta3 added in v1.19.0 

func (mr *MockKubernetesClientMockRecorder) FlowcontrolV1beta3() *gomock.Call

FlowcontrolV1beta3 indicates an expected call of FlowcontrolV1beta3.

func (*MockKubernetesClientMockRecorder) InternalV1alpha1 added in v1.19.0 

func (mr *MockKubernetesClientMockRecorder) InternalV1alpha1() *gomock.Call

InternalV1alpha1 indicates an expected call of InternalV1alpha1.

func (*MockKubernetesClientMockRecorder) NetworkingV1 added in v1.19.0 

func (mr *MockKubernetesClientMockRecorder) NetworkingV1() *gomock.Call

NetworkingV1 indicates an expected call of NetworkingV1.

func (*MockKubernetesClientMockRecorder) NetworkingV1alpha1 added in v1.19.0 

func (mr *MockKubernetesClientMockRecorder) NetworkingV1alpha1() *gomock.Call

NetworkingV1alpha1 indicates an expected call of NetworkingV1alpha1.

func (*MockKubernetesClientMockRecorder) NetworkingV1beta1 added in v1.19.0 

func (mr *MockKubernetesClientMockRecorder) NetworkingV1beta1() *gomock.Call

NetworkingV1beta1 indicates an expected call of NetworkingV1beta1.

func (*MockKubernetesClientMockRecorder) NodeV1 added in v1.19.0 

func (mr *MockKubernetesClientMockRecorder) NodeV1() *gomock.Call

NodeV1 indicates an expected call of NodeV1.

func (*MockKubernetesClientMockRecorder) NodeV1alpha1 added in v1.19.0 

func (mr *MockKubernetesClientMockRecorder) NodeV1alpha1() *gomock.Call

NodeV1alpha1 indicates an expected call of NodeV1alpha1.

func (*MockKubernetesClientMockRecorder) NodeV1beta1 added in v1.19.0 

func (mr *MockKubernetesClientMockRecorder) NodeV1beta1() *gomock.Call

NodeV1beta1 indicates an expected call of NodeV1beta1.

func (*MockKubernetesClientMockRecorder) PolicyV1 added in v1.19.0 

func (mr *MockKubernetesClientMockRecorder) PolicyV1() *gomock.Call

PolicyV1 indicates an expected call of PolicyV1.

func (*MockKubernetesClientMockRecorder) PolicyV1beta1 added in v1.19.0 

func (mr *MockKubernetesClientMockRecorder) PolicyV1beta1() *gomock.Call

PolicyV1beta1 indicates an expected call of PolicyV1beta1.

func (*MockKubernetesClientMockRecorder) RbacV1 added in v1.19.0 

func (mr *MockKubernetesClientMockRecorder) RbacV1() *gomock.Call

RbacV1 indicates an expected call of RbacV1.

func (*MockKubernetesClientMockRecorder) RbacV1alpha1 added in v1.19.0 

func (mr *MockKubernetesClientMockRecorder) RbacV1alpha1() *gomock.Call

RbacV1alpha1 indicates an expected call of RbacV1alpha1.

func (*MockKubernetesClientMockRecorder) RbacV1beta1 added in v1.19.0 

func (mr *MockKubernetesClientMockRecorder) RbacV1beta1() *gomock.Call

RbacV1beta1 indicates an expected call of RbacV1beta1.

func (*MockKubernetesClientMockRecorder) ResourceV1alpha2 added in v1.19.0 

func (mr *MockKubernetesClientMockRecorder) ResourceV1alpha2() *gomock.Call

ResourceV1alpha2 indicates an expected call of ResourceV1alpha2.

func (*MockKubernetesClientMockRecorder) SchedulingV1 added in v1.19.0 

func (mr *MockKubernetesClientMockRecorder) SchedulingV1() *gomock.Call

SchedulingV1 indicates an expected call of SchedulingV1.

func (*MockKubernetesClientMockRecorder) SchedulingV1alpha1 added in v1.19.0 

func (mr *MockKubernetesClientMockRecorder) SchedulingV1alpha1() *gomock.Call

SchedulingV1alpha1 indicates an expected call of SchedulingV1alpha1.

func (*MockKubernetesClientMockRecorder) SchedulingV1beta1 added in v1.19.0 

func (mr *MockKubernetesClientMockRecorder) SchedulingV1beta1() *gomock.Call

SchedulingV1beta1 indicates an expected call of SchedulingV1beta1.

func (*MockKubernetesClientMockRecorder) StorageV1 added in v1.19.0 

func (mr *MockKubernetesClientMockRecorder) StorageV1() *gomock.Call

StorageV1 indicates an expected call of StorageV1.

func (*MockKubernetesClientMockRecorder) StorageV1alpha1 added in v1.19.0 

func (mr *MockKubernetesClientMockRecorder) StorageV1alpha1() *gomock.Call

StorageV1alpha1 indicates an expected call of StorageV1alpha1.

func (*MockKubernetesClientMockRecorder) StorageV1beta1 added in v1.19.0 

func (mr *MockKubernetesClientMockRecorder) StorageV1beta1() *gomock.Call

StorageV1beta1 indicates an expected call of StorageV1beta1.

type MockMounter added in v1.4.0 

type MockMounter struct {
	mount_utils.Interface
	// contains filtered or unexported fields
}

MockMounter is a mock of Mounter interface.

func NewMockMounter added in v1.4.0 

func NewMockMounter(ctrl *gomock.Controller) *MockMounter

NewMockMounter creates a new mock instance.

func (*MockMounter) CanSafelySkipMountPointCheck added in v1.19.0 

func (m *MockMounter) CanSafelySkipMountPointCheck() bool

CanSafelySkipMountPointCheck mocks base method.

func (*MockMounter) EXPECT added in v1.4.0 

func (m *MockMounter) EXPECT() *MockMounterMockRecorder

EXPECT returns an object that allows the caller to indicate expected use.

func (*MockMounter) FormatAndMountSensitiveWithFormatOptions added in v1.15.0 

func (m *MockMounter) FormatAndMountSensitiveWithFormatOptions(source, target, fstype string, options, sensitiveOptions, formatOptions []string) error

FormatAndMountSensitiveWithFormatOptions mocks base method.

func (*MockMounter) GetDeviceNameFromMount added in v1.4.0 

func (m *MockMounter) GetDeviceNameFromMount(mountPath string) (string, int, error)

GetDeviceNameFromMount mocks base method.

func (*MockMounter) GetMountRefs added in v1.4.0 

func (m *MockMounter) GetMountRefs(pathname string) ([]string, error)

GetMountRefs mocks base method.

func (*MockMounter) IsCorruptedMnt added in v1.4.0 

func (m *MockMounter) IsCorruptedMnt(err error) bool

IsCorruptedMnt mocks base method.

func (*MockMounter) IsLikelyNotMountPoint added in v1.4.0 

func (m *MockMounter) IsLikelyNotMountPoint(file string) (bool, error)

IsLikelyNotMountPoint mocks base method.

func (*MockMounter) IsMountPoint added in v1.13.0 

func (m *MockMounter) IsMountPoint(file string) (bool, error)

IsMountPoint mocks base method.

func (*MockMounter) List added in v1.4.0 

func (m *MockMounter) List() ([]mount_utils.MountPoint, error)

List mocks base method.

func (*MockMounter) MakeDir added in v1.4.0 

func (m *MockMounter) MakeDir(path string) error

MakeDir mocks base method.

func (*MockMounter) MakeFile added in v1.4.0 

func (m *MockMounter) MakeFile(path string) error

MakeFile mocks base method.

func (*MockMounter) Mount added in v1.4.0 

func (m *MockMounter) Mount(source, target, fstype string, options []string) error

Mount mocks base method.

func (*MockMounter) MountSensitive added in v1.4.0 

func (m *MockMounter) MountSensitive(source, target, fstype string, options, sensitiveOptions []string) error

MountSensitive mocks base method.

func (*MockMounter) MountSensitiveWithoutSystemd added in v1.4.0 

func (m *MockMounter) MountSensitiveWithoutSystemd(source, target, fstype string, options, sensitiveOptions []string) error

MountSensitiveWithoutSystemd mocks base method.

func (*MockMounter) MountSensitiveWithoutSystemdWithMountFlags added in v1.5.3 

func (m *MockMounter) MountSensitiveWithoutSystemdWithMountFlags(source, target, fstype string, options, sensitiveOptions, mountFlags []string) error

MountSensitiveWithoutSystemdWithMountFlags mocks base method.

func (*MockMounter) NeedResize added in v1.4.0 

func (m *MockMounter) NeedResize(devicePath, deviceMountPath string) (bool, error)

NeedResize mocks base method.

func (*MockMounter) NewResizeFs added in v1.6.0 

func (m *MockMounter) NewResizeFs() (Resizefs, error)

NewResizeFs mocks base method.

func (*MockMounter) PathExists added in v1.4.0 

func (m *MockMounter) PathExists(path string) (bool, error)

PathExists mocks base method.

func (*MockMounter) Unmount added in v1.4.0 

func (m *MockMounter) Unmount(target string) error

Unmount mocks base method.

func (*MockMounter) Unpublish added in v1.6.0 

func (m *MockMounter) Unpublish(path string) error

Unpublish mocks base method.

func (*MockMounter) Unstage added in v1.6.0 

func (m *MockMounter) Unstage(path string) error

Unstage mocks base method.

type MockMounterMockRecorder added in v1.4.0 

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

MockMounterMockRecorder is the mock recorder for MockMounter.

func (*MockMounterMockRecorder) CanSafelySkipMountPointCheck added in v1.19.0 

func (mr *MockMounterMockRecorder) CanSafelySkipMountPointCheck() *gomock.Call

CanSafelySkipMountPointCheck indicates an expected call of CanSafelySkipMountPointCheck.

func (*MockMounterMockRecorder) FormatAndMountSensitiveWithFormatOptions added in v1.15.0 

func (mr *MockMounterMockRecorder) FormatAndMountSensitiveWithFormatOptions(source, target, fstype, options, sensitiveOptions, formatOptions interface{}) *gomock.Call

FormatAndMountSensitiveWithFormatOptions indicates an expected call of FormatAndMountSensitiveWithFormatOptions.

func (*MockMounterMockRecorder) GetDeviceNameFromMount added in v1.4.0 

func (mr *MockMounterMockRecorder) GetDeviceNameFromMount(mountPath interface{}) *gomock.Call

GetDeviceNameFromMount indicates an expected call of GetDeviceNameFromMount.

func (*MockMounterMockRecorder) GetMountRefs added in v1.4.0 

func (mr *MockMounterMockRecorder) GetMountRefs(pathname interface{}) *gomock.Call

GetMountRefs indicates an expected call of GetMountRefs.

func (*MockMounterMockRecorder) IsCorruptedMnt added in v1.4.0 

func (mr *MockMounterMockRecorder) IsCorruptedMnt(err interface{}) *gomock.Call

IsCorruptedMnt indicates an expected call of IsCorruptedMnt.

func (*MockMounterMockRecorder) IsLikelyNotMountPoint added in v1.4.0 

func (mr *MockMounterMockRecorder) IsLikelyNotMountPoint(file interface{}) *gomock.Call

IsLikelyNotMountPoint indicates an expected call of IsLikelyNotMountPoint.

func (*MockMounterMockRecorder) IsMountPoint added in v1.13.0 

func (mr *MockMounterMockRecorder) IsMountPoint(file interface{}) *gomock.Call

IsMountPoint indicates an expected call of IsMountPoint.

func (*MockMounterMockRecorder) List added in v1.4.0 

func (mr *MockMounterMockRecorder) List() *gomock.Call

List indicates an expected call of List.

func (*MockMounterMockRecorder) MakeDir added in v1.4.0 

func (mr *MockMounterMockRecorder) MakeDir(path interface{}) *gomock.Call

MakeDir indicates an expected call of MakeDir.

func (*MockMounterMockRecorder) MakeFile added in v1.4.0 

func (mr *MockMounterMockRecorder) MakeFile(path interface{}) *gomock.Call

MakeFile indicates an expected call of MakeFile.

func (*MockMounterMockRecorder) Mount added in v1.4.0 

func (mr *MockMounterMockRecorder) Mount(source, target, fstype, options interface{}) *gomock.Call

Mount indicates an expected call of Mount.

func (*MockMounterMockRecorder) MountSensitive added in v1.4.0 

func (mr *MockMounterMockRecorder) MountSensitive(source, target, fstype, options, sensitiveOptions interface{}) *gomock.Call

MountSensitive indicates an expected call of MountSensitive.

func (*MockMounterMockRecorder) MountSensitiveWithoutSystemd added in v1.4.0 

func (mr *MockMounterMockRecorder) MountSensitiveWithoutSystemd(source, target, fstype, options, sensitiveOptions interface{}) *gomock.Call

MountSensitiveWithoutSystemd indicates an expected call of MountSensitiveWithoutSystemd.

func (*MockMounterMockRecorder) MountSensitiveWithoutSystemdWithMountFlags added in v1.5.3 

func (mr *MockMounterMockRecorder) MountSensitiveWithoutSystemdWithMountFlags(source, target, fstype, options, sensitiveOptions, mountFlags interface{}) *gomock.Call

MountSensitiveWithoutSystemdWithMountFlags indicates an expected call of MountSensitiveWithoutSystemdWithMountFlags.

func (*MockMounterMockRecorder) NeedResize added in v1.4.0 

func (mr *MockMounterMockRecorder) NeedResize(devicePath, deviceMountPath interface{}) *gomock.Call

NeedResize indicates an expected call of NeedResize.

func (*MockMounterMockRecorder) NewResizeFs added in v1.6.0 

func (mr *MockMounterMockRecorder) NewResizeFs() *gomock.Call

NewResizeFs indicates an expected call of NewResizeFs.

func (*MockMounterMockRecorder) PathExists added in v1.4.0 

func (mr *MockMounterMockRecorder) PathExists(path interface{}) *gomock.Call

PathExists indicates an expected call of PathExists.

func (*MockMounterMockRecorder) Unmount added in v1.4.0 

func (mr *MockMounterMockRecorder) Unmount(target interface{}) *gomock.Call

Unmount indicates an expected call of Unmount.

func (*MockMounterMockRecorder) Unpublish added in v1.6.0 

func (mr *MockMounterMockRecorder) Unpublish(path interface{}) *gomock.Call

Unpublish indicates an expected call of Unpublish.

func (*MockMounterMockRecorder) Unstage added in v1.6.0 

func (mr *MockMounterMockRecorder) Unstage(path interface{}) *gomock.Call

Unstage indicates an expected call of Unstage.

type MockNodeInterface added in v1.19.0 

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

MockNodeInterface is a mock of NodeInterface interface.

func NewMockNodeInterface added in v1.19.0 

func NewMockNodeInterface(ctrl *gomock.Controller) *MockNodeInterface

NewMockNodeInterface creates a new mock instance.

func (*MockNodeInterface) Apply added in v1.19.0 

func (m *MockNodeInterface) Apply(arg0 context.Context, arg1 *v11.NodeApplyConfiguration, arg2 v10.ApplyOptions) (*v1.Node, error)

Apply mocks base method.

func (*MockNodeInterface) ApplyStatus added in v1.19.0 

func (m *MockNodeInterface) ApplyStatus(arg0 context.Context, arg1 *v11.NodeApplyConfiguration, arg2 v10.ApplyOptions) (*v1.Node, error)

ApplyStatus mocks base method.

func (*MockNodeInterface) Create added in v1.19.0 

func (m *MockNodeInterface) Create(arg0 context.Context, arg1 *v1.Node, arg2 v10.CreateOptions) (*v1.Node, error)

Create mocks base method.

func (*MockNodeInterface) Delete added in v1.19.0 

func (m *MockNodeInterface) Delete(arg0 context.Context, arg1 string, arg2 v10.DeleteOptions) error

Delete mocks base method.

func (*MockNodeInterface) DeleteCollection added in v1.19.0 

func (m *MockNodeInterface) DeleteCollection(arg0 context.Context, arg1 v10.DeleteOptions, arg2 v10.ListOptions) error

DeleteCollection mocks base method.

func (*MockNodeInterface) EXPECT added in v1.19.0 

func (m *MockNodeInterface) EXPECT() *MockNodeInterfaceMockRecorder

EXPECT returns an object that allows the caller to indicate expected use.

func (*MockNodeInterface) Get added in v1.19.0 

func (m *MockNodeInterface) Get(arg0 context.Context, arg1 string, arg2 v10.GetOptions) (*v1.Node, error)

Get mocks base method.

func (*MockNodeInterface) List added in v1.19.0 

func (m *MockNodeInterface) List(arg0 context.Context, arg1 v10.ListOptions) (*v1.NodeList, error)

List mocks base method.

func (*MockNodeInterface) Patch added in v1.19.0 

func (m *MockNodeInterface) Patch(arg0 context.Context, arg1 string, arg2 types.PatchType, arg3 []byte, arg4 v10.PatchOptions, arg5 ...string) (*v1.Node, error)

Patch mocks base method.

func (*MockNodeInterface) PatchStatus added in v1.19.0 

func (m *MockNodeInterface) PatchStatus(arg0 context.Context, arg1 string, arg2 []byte) (*v1.Node, error)

PatchStatus mocks base method.

func (*MockNodeInterface) Update added in v1.19.0 

func (m *MockNodeInterface) Update(arg0 context.Context, arg1 *v1.Node, arg2 v10.UpdateOptions) (*v1.Node, error)

Update mocks base method.

func (*MockNodeInterface) UpdateStatus added in v1.19.0 

func (m *MockNodeInterface) UpdateStatus(arg0 context.Context, arg1 *v1.Node, arg2 v10.UpdateOptions) (*v1.Node, error)

UpdateStatus mocks base method.

func (*MockNodeInterface) Watch added in v1.19.0 

func (m *MockNodeInterface) Watch(arg0 context.Context, arg1 v10.ListOptions) (watch.Interface, error)

Watch mocks base method.

type MockNodeInterfaceMockRecorder added in v1.19.0 

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

MockNodeInterfaceMockRecorder is the mock recorder for MockNodeInterface.

func (*MockNodeInterfaceMockRecorder) Apply added in v1.19.0 

func (mr *MockNodeInterfaceMockRecorder) Apply(arg0, arg1, arg2 interface{}) *gomock.Call

Apply indicates an expected call of Apply.

func (*MockNodeInterfaceMockRecorder) ApplyStatus added in v1.19.0 

func (mr *MockNodeInterfaceMockRecorder) ApplyStatus(arg0, arg1, arg2 interface{}) *gomock.Call

ApplyStatus indicates an expected call of ApplyStatus.

func (*MockNodeInterfaceMockRecorder) Create added in v1.19.0 

func (mr *MockNodeInterfaceMockRecorder) Create(arg0, arg1, arg2 interface{}) *gomock.Call

Create indicates an expected call of Create.

func (*MockNodeInterfaceMockRecorder) Delete added in v1.19.0 

func (mr *MockNodeInterfaceMockRecorder) Delete(arg0, arg1, arg2 interface{}) *gomock.Call

Delete indicates an expected call of Delete.

func (*MockNodeInterfaceMockRecorder) DeleteCollection added in v1.19.0 

func (mr *MockNodeInterfaceMockRecorder) DeleteCollection(arg0, arg1, arg2 interface{}) *gomock.Call

DeleteCollection indicates an expected call of DeleteCollection.

func (*MockNodeInterfaceMockRecorder) Get added in v1.19.0 

func (mr *MockNodeInterfaceMockRecorder) Get(arg0, arg1, arg2 interface{}) *gomock.Call

Get indicates an expected call of Get.

func (*MockNodeInterfaceMockRecorder) List added in v1.19.0 

func (mr *MockNodeInterfaceMockRecorder) List(arg0, arg1 interface{}) *gomock.Call

List indicates an expected call of List.

func (*MockNodeInterfaceMockRecorder) Patch added in v1.19.0 

func (mr *MockNodeInterfaceMockRecorder) Patch(arg0, arg1, arg2, arg3, arg4 interface{}, arg5 ...interface{}) *gomock.Call

Patch indicates an expected call of Patch.

func (*MockNodeInterfaceMockRecorder) PatchStatus added in v1.19.0 

func (mr *MockNodeInterfaceMockRecorder) PatchStatus(arg0, arg1, arg2 interface{}) *gomock.Call

PatchStatus indicates an expected call of PatchStatus.

func (*MockNodeInterfaceMockRecorder) Update added in v1.19.0 

func (mr *MockNodeInterfaceMockRecorder) Update(arg0, arg1, arg2 interface{}) *gomock.Call

Update indicates an expected call of Update.

func (*MockNodeInterfaceMockRecorder) UpdateStatus added in v1.19.0 

func (mr *MockNodeInterfaceMockRecorder) UpdateStatus(arg0, arg1, arg2 interface{}) *gomock.Call

UpdateStatus indicates an expected call of UpdateStatus.

func (*MockNodeInterfaceMockRecorder) Watch added in v1.19.0 

func (mr *MockNodeInterfaceMockRecorder) Watch(arg0, arg1 interface{}) *gomock.Call

Watch indicates an expected call of Watch.

type MockResizefs added in v1.6.0 

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

MockResizefs is a mock of Resizefs interface.

func NewMockResizefs added in v1.6.0 

func NewMockResizefs(ctrl *gomock.Controller) *MockResizefs

NewMockResizefs creates a new mock instance.

func (*MockResizefs) EXPECT added in v1.6.0 

func (m *MockResizefs) EXPECT() *MockResizefsMockRecorder

EXPECT returns an object that allows the caller to indicate expected use.

func (*MockResizefs) Resize added in v1.6.0 

func (m *MockResizefs) Resize(devicePath, deviceMountPath string) (bool, error)

Resize mocks base method.

type MockResizefsMockRecorder added in v1.6.0 

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

MockResizefsMockRecorder is the mock recorder for MockResizefs.

func (*MockResizefsMockRecorder) Resize added in v1.6.0 

func (mr *MockResizefsMockRecorder) Resize(devicePath, deviceMountPath interface{}) *gomock.Call

Resize indicates an expected call of Resize.

type MockStorageV1Interface added in v1.23.0 

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

MockStorageV1Interface is a mock of StorageV1Interface interface.

func NewMockStorageV1Interface added in v1.23.0 

func NewMockStorageV1Interface(ctrl *gomock.Controller) *MockStorageV1Interface

NewMockStorageV1Interface creates a new mock instance.

func (*MockStorageV1Interface) CSIDrivers added in v1.23.0 

func (m *MockStorageV1Interface) CSIDrivers() v12.CSIDriverInterface

CSIDrivers mocks base method.

func (*MockStorageV1Interface) CSINodes added in v1.23.0 

func (m *MockStorageV1Interface) CSINodes() v12.CSINodeInterface

CSINodes mocks base method.

func (*MockStorageV1Interface) CSIStorageCapacities added in v1.23.0 

func (m *MockStorageV1Interface) CSIStorageCapacities(arg0 string) v12.CSIStorageCapacityInterface

CSIStorageCapacities mocks base method.

func (*MockStorageV1Interface) EXPECT added in v1.23.0 

func (m *MockStorageV1Interface) EXPECT() *MockStorageV1InterfaceMockRecorder

EXPECT returns an object that allows the caller to indicate expected use.

func (*MockStorageV1Interface) RESTClient added in v1.23.0 

func (m *MockStorageV1Interface) RESTClient() rest.Interface

RESTClient mocks base method.

func (*MockStorageV1Interface) StorageClasses added in v1.23.0 

func (m *MockStorageV1Interface) StorageClasses() v12.StorageClassInterface

StorageClasses mocks base method.

func (*MockStorageV1Interface) VolumeAttachments added in v1.23.0 

func (m *MockStorageV1Interface) VolumeAttachments() v12.VolumeAttachmentInterface

VolumeAttachments mocks base method.

type MockStorageV1InterfaceMockRecorder added in v1.23.0 

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

MockStorageV1InterfaceMockRecorder is the mock recorder for MockStorageV1Interface.

func (*MockStorageV1InterfaceMockRecorder) CSIDrivers added in v1.23.0 

func (mr *MockStorageV1InterfaceMockRecorder) CSIDrivers() *gomock.Call

CSIDrivers indicates an expected call of CSIDrivers.

func (*MockStorageV1InterfaceMockRecorder) CSINodes added in v1.23.0 

func (mr *MockStorageV1InterfaceMockRecorder) CSINodes() *gomock.Call

CSINodes indicates an expected call of CSINodes.

func (*MockStorageV1InterfaceMockRecorder) CSIStorageCapacities added in v1.23.0 

func (mr *MockStorageV1InterfaceMockRecorder) CSIStorageCapacities(arg0 interface{}) *gomock.Call

CSIStorageCapacities indicates an expected call of CSIStorageCapacities.

func (*MockStorageV1InterfaceMockRecorder) RESTClient added in v1.23.0 

func (mr *MockStorageV1InterfaceMockRecorder) RESTClient() *gomock.Call

RESTClient indicates an expected call of RESTClient.

func (*MockStorageV1InterfaceMockRecorder) StorageClasses added in v1.23.0 

func (mr *MockStorageV1InterfaceMockRecorder) StorageClasses() *gomock.Call

StorageClasses indicates an expected call of StorageClasses.

func (*MockStorageV1InterfaceMockRecorder) VolumeAttachments added in v1.23.0 

func (mr *MockStorageV1InterfaceMockRecorder) VolumeAttachments() *gomock.Call

VolumeAttachments indicates an expected call of VolumeAttachments.

type MockVolumeAttachmentInterface added in v1.23.0 

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

MockVolumeAttachmentInterface is a mock of VolumeAttachmentInterface interface.

func NewMockVolumeAttachmentInterface added in v1.23.0 

func NewMockVolumeAttachmentInterface(ctrl *gomock.Controller) *MockVolumeAttachmentInterface

NewMockVolumeAttachmentInterface creates a new mock instance.

func (*MockVolumeAttachmentInterface) Apply added in v1.23.0 

func (m *MockVolumeAttachmentInterface) Apply(arg0 context.Context, arg1 *v11.VolumeAttachmentApplyConfiguration, arg2 v10.ApplyOptions) (*v1.VolumeAttachment, error)

Apply mocks base method.

func (*MockVolumeAttachmentInterface) ApplyStatus added in v1.23.0 

func (m *MockVolumeAttachmentInterface) ApplyStatus(arg0 context.Context, arg1 *v11.VolumeAttachmentApplyConfiguration, arg2 v10.ApplyOptions) (*v1.VolumeAttachment, error)

ApplyStatus mocks base method.

func (*MockVolumeAttachmentInterface) Create added in v1.23.0 

func (m *MockVolumeAttachmentInterface) Create(arg0 context.Context, arg1 *v1.VolumeAttachment, arg2 v10.CreateOptions) (*v1.VolumeAttachment, error)

Create mocks base method.

func (*MockVolumeAttachmentInterface) Delete added in v1.23.0 

func (m *MockVolumeAttachmentInterface) Delete(arg0 context.Context, arg1 string, arg2 v10.DeleteOptions) error

Delete mocks base method.

func (*MockVolumeAttachmentInterface) DeleteCollection added in v1.23.0 

func (m *MockVolumeAttachmentInterface) DeleteCollection(arg0 context.Context, arg1 v10.DeleteOptions, arg2 v10.ListOptions) error

DeleteCollection mocks base method.

func (*MockVolumeAttachmentInterface) EXPECT added in v1.23.0 

func (m *MockVolumeAttachmentInterface) EXPECT() *MockVolumeAttachmentInterfaceMockRecorder

EXPECT returns an object that allows the caller to indicate expected use.

func (*MockVolumeAttachmentInterface) Get added in v1.23.0 

func (m *MockVolumeAttachmentInterface) Get(arg0 context.Context, arg1 string, arg2 v10.GetOptions) (*v1.VolumeAttachment, error)

Get mocks base method.

func (*MockVolumeAttachmentInterface) List added in v1.23.0 

func (m *MockVolumeAttachmentInterface) List(arg0 context.Context, arg1 v10.ListOptions) (*v1.VolumeAttachmentList, error)

List mocks base method.

func (*MockVolumeAttachmentInterface) Patch added in v1.23.0 

func (m *MockVolumeAttachmentInterface) Patch(arg0 context.Context, arg1 string, arg2 types.PatchType, arg3 []byte, arg4 v10.PatchOptions, arg5 ...string) (*v1.VolumeAttachment, error)

Patch mocks base method.

func (*MockVolumeAttachmentInterface) Update added in v1.23.0 

func (m *MockVolumeAttachmentInterface) Update(arg0 context.Context, arg1 *v1.VolumeAttachment, arg2 v10.UpdateOptions) (*v1.VolumeAttachment, error)

Update mocks base method.

func (*MockVolumeAttachmentInterface) UpdateStatus added in v1.23.0 

func (m *MockVolumeAttachmentInterface) UpdateStatus(arg0 context.Context, arg1 *v1.VolumeAttachment, arg2 v10.UpdateOptions) (*v1.VolumeAttachment, error)

UpdateStatus mocks base method.

func (*MockVolumeAttachmentInterface) Watch added in v1.23.0 

func (m *MockVolumeAttachmentInterface) Watch(arg0 context.Context, arg1 v10.ListOptions) (watch.Interface, error)

Watch mocks base method.

type MockVolumeAttachmentInterfaceMockRecorder added in v1.23.0 

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

MockVolumeAttachmentInterfaceMockRecorder is the mock recorder for MockVolumeAttachmentInterface.

func (*MockVolumeAttachmentInterfaceMockRecorder) Apply added in v1.23.0 

func (mr *MockVolumeAttachmentInterfaceMockRecorder) Apply(arg0, arg1, arg2 interface{}) *gomock.Call

Apply indicates an expected call of Apply.

func (*MockVolumeAttachmentInterfaceMockRecorder) ApplyStatus added in v1.23.0 

func (mr *MockVolumeAttachmentInterfaceMockRecorder) ApplyStatus(arg0, arg1, arg2 interface{}) *gomock.Call

ApplyStatus indicates an expected call of ApplyStatus.

func (*MockVolumeAttachmentInterfaceMockRecorder) Create added in v1.23.0 

func (mr *MockVolumeAttachmentInterfaceMockRecorder) Create(arg0, arg1, arg2 interface{}) *gomock.Call

Create indicates an expected call of Create.

func (*MockVolumeAttachmentInterfaceMockRecorder) Delete added in v1.23.0 

func (mr *MockVolumeAttachmentInterfaceMockRecorder) Delete(arg0, arg1, arg2 interface{}) *gomock.Call

Delete indicates an expected call of Delete.

func (*MockVolumeAttachmentInterfaceMockRecorder) DeleteCollection added in v1.23.0 

func (mr *MockVolumeAttachmentInterfaceMockRecorder) DeleteCollection(arg0, arg1, arg2 interface{}) *gomock.Call

DeleteCollection indicates an expected call of DeleteCollection.

func (*MockVolumeAttachmentInterfaceMockRecorder) Get added in v1.23.0 

func (mr *MockVolumeAttachmentInterfaceMockRecorder) Get(arg0, arg1, arg2 interface{}) *gomock.Call

Get indicates an expected call of Get.

func (*MockVolumeAttachmentInterfaceMockRecorder) List added in v1.23.0 

func (mr *MockVolumeAttachmentInterfaceMockRecorder) List(arg0, arg1 interface{}) *gomock.Call

List indicates an expected call of List.

func (*MockVolumeAttachmentInterfaceMockRecorder) Patch added in v1.23.0 

func (mr *MockVolumeAttachmentInterfaceMockRecorder) Patch(arg0, arg1, arg2, arg3, arg4 interface{}, arg5 ...interface{}) *gomock.Call

Patch indicates an expected call of Patch.

func (*MockVolumeAttachmentInterfaceMockRecorder) Update added in v1.23.0 

func (mr *MockVolumeAttachmentInterfaceMockRecorder) Update(arg0, arg1, arg2 interface{}) *gomock.Call

Update indicates an expected call of Update.

func (*MockVolumeAttachmentInterfaceMockRecorder) UpdateStatus added in v1.23.0 

func (mr *MockVolumeAttachmentInterfaceMockRecorder) UpdateStatus(arg0, arg1, arg2 interface{}) *gomock.Call

UpdateStatus indicates an expected call of UpdateStatus.

func (*MockVolumeAttachmentInterfaceMockRecorder) Watch added in v1.23.0 

func (mr *MockVolumeAttachmentInterfaceMockRecorder) Watch(arg0, arg1 interface{}) *gomock.Call

Watch indicates an expected call of Watch.

type Mode added in v0.5.0 

type Mode string

Mode is the operating mode of the CSI driver. 

const (
	// ControllerMode is the mode that only starts the controller service.
	ControllerMode Mode = "controller"
	// NodeMode is the mode that only starts the node service.
	NodeMode Mode = "node"
	// AllMode is the mode that only starts both the controller and the node service.
	AllMode Mode = "all"
)

type Mounter added in v0.4.0 

type Mounter interface {
	mountutils.Interface

	FormatAndMountSensitiveWithFormatOptions(source string, target string, fstype string, options []string, sensitiveOptions []string, formatOptions []string) error
	IsCorruptedMnt(err error) bool
	GetDeviceNameFromMount(mountPath string) (string, int, error)
	MakeFile(path string) error
	MakeDir(path string) error
	PathExists(path string) (bool, error)
	NeedResize(devicePath string, deviceMountPath string) (bool, error)
	Unpublish(path string) error
	Unstage(path string) error
	NewResizeFs() (Resizefs, error)
}

Mounter is the interface implemented by NodeMounter. A mix & match of functions defined in upstream libraries. (FormatAndMount from struct SafeFormatAndMount, PathExists from an old edition of mount.Interface). Define it explicitly so that it can be mocked and to insulate from oft-changing upstream interfaces/structs

type NodeMounter added in v0.4.0 

type NodeMounter struct {
	*mountutils.SafeFormatAndMount
}

NodeMounter implements Mounter. A superstruct of SafeFormatAndMount.

func (NodeMounter) GetDeviceNameFromMount added in v0.10.0 

func (m NodeMounter) GetDeviceNameFromMount(mountPath string) (string, int, error)

GetDeviceNameFromMount returns the volume ID for a mount path.

func (NodeMounter) IsCorruptedMnt added in v1.1.4 

func (m NodeMounter) IsCorruptedMnt(err error) bool

IsCorruptedMnt return true if err is about corrupted mount point

func (*NodeMounter) MakeDir added in v0.5.0 

func (m *NodeMounter) MakeDir(path string) error

This function is mirrored in ./sanity_test.go to make sure sanity test covered this block of code Please mirror the change to func MakeFile in ./sanity_test.go

func (*NodeMounter) MakeFile added in v0.5.0 

func (m *NodeMounter) MakeFile(path string) error

This function is mirrored in ./sanity_test.go to make sure sanity test covered this block of code Please mirror the change to func MakeFile in ./sanity_test.go

func (*NodeMounter) NeedResize added in v1.0.0 

func (m *NodeMounter) NeedResize(devicePath string, deviceMountPath string) (bool, error)

func (*NodeMounter) NewResizeFs added in v1.6.0 

func (m *NodeMounter) NewResizeFs() (Resizefs, error)

func (*NodeMounter) PathExists added in v0.10.0 

func (m *NodeMounter) PathExists(path string) (bool, error)

This function is mirrored in ./sanity_test.go to make sure sanity test covered this block of code Please mirror the change to func MakeFile in ./sanity_test.go

func (*NodeMounter) Unpublish added in v1.6.0 

func (m *NodeMounter) Unpublish(path string) error

func (*NodeMounter) Unstage added in v1.6.0 

func (m *NodeMounter) Unstage(path string) error

type Resizefs added in v1.6.0 

type Resizefs interface {
	Resize(devicePath, deviceMountPath string) (bool, error)
}

type VersionInfo added in v0.2.0 

type VersionInfo struct {
	DriverVersion string `json:"driverVersion"`
	GitCommit     string `json:"gitCommit"`
	BuildDate     string `json:"buildDate"`
	GoVersion     string `json:"goVersion"`
	Compiler      string `json:"compiler"`
	Platform      string `json:"platform"`
}

func GetVersion added in v0.2.0 

func GetVersion() VersionInfo

Source Files

View all Source files

Directories

Path Synopsis

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.