driver

package
v1.30.0 Latest Latest
Warning

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

 Go to latest Published: Apr 22, 2024 License: Apache-2.0 Imports: 101 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"

	// FSTypeKey configures the file system type that will be formatted during volume creation.
	FSTypeKey = "csi.storage.k8s.io/fstype"

	// 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"

	// Ext4ClusterSizeKey enables the bigalloc option when formatting an ext4 volume
	Ext4BigAllocKey = "ext4bigalloc"

	// Ext4ClusterSizeKey configures the cluster size when formatting an ext4 volume with the bigalloc option enabled
	Ext4ClusterSizeKey = "ext4clustersize"

	// 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 (
	DefaultCSIEndpoint                       = "unix://tmp/csi.sock"
	DefaultModifyVolumeRequestHandlerTimeout = 2 * time.Second
)

constants for default command line flag 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 (
	SingleNodeWriter     = csi.VolumeCapability_AccessMode_SINGLE_NODE_WRITER
	MultiNodeMultiWriter = csi.VolumeCapability_AccessMode_MULTI_NODE_MULTI_WRITER
)

Supported access modes

View Source 
const (
	ModificationKeyVolumeType = "type"
	// Retained for backwards compatibility, but not recommended
	DeprecatedModificationKeyVolumeType = "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"
	WellKnownZoneTopologyKey = "topology.kubernetes.io/zone"
	// DEPRECATED Use the WellKnownZoneTopologyKey instead
	ZoneTopologyKey = "topology." + DriverName + "/zone"
	OSTopologyKey   = "kubernetes.io/os"
)
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 (
	// 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 (
	FileSystemConfigs = map[string]fileSystemConfig{
		FSTypeExt2: {
			NotSupportedParams: map[string]struct{}{
				Ext4BigAllocKey:    {},
				Ext4ClusterSizeKey: {},
			},
		},
		FSTypeExt3: {
			NotSupportedParams: map[string]struct{}{
				Ext4BigAllocKey:    {},
				Ext4ClusterSizeKey: {},
			},
		},
		FSTypeExt4: {
			NotSupportedParams: map[string]struct{}{},
		},
		FSTypeXfs: {
			NotSupportedParams: map[string]struct{}{
				BytesPerInodeKey:   {},
				NumberOfInodesKey:  {},
				Ext4BigAllocKey:    {},
				Ext4ClusterSizeKey: {},
			},
		},
		FSTypeNtfs: {
			NotSupportedParams: map[string]struct{}{
				BlockSizeKey:       {},
				InodeSizeKey:       {},
				BytesPerInodeKey:   {},
				NumberOfInodesKey:  {},
				Ext4BigAllocKey:    {},
				Ext4ClusterSizeKey: {},
			},
		},
	}
)
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 *Options) error

Types

type ControllerService added in v1.30.0 

type ControllerService struct {
	rpc.UnimplementedModifyServer
	// contains filtered or unexported fields
}

ControllerService represents the controller service of CSI driver

func NewControllerService added in v1.30.0 

func NewControllerService(c cloud.Cloud, o *Options) *ControllerService

NewControllerService creates a new controller service

func (*ControllerService) ControllerExpandVolume added in v1.30.0 

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

func (*ControllerService) ControllerGetCapabilities added in v1.30.0 

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

func (*ControllerService) ControllerGetVolume added in v1.30.0 

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

func (*ControllerService) ControllerModifyVolume added in v1.30.0 

func (d *ControllerService) ControllerModifyVolume(ctx context.Context, req *csi.ControllerModifyVolumeRequest) (*csi.ControllerModifyVolumeResponse, error)

func (*ControllerService) ControllerPublishVolume added in v1.30.0 

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

func (*ControllerService) ControllerUnpublishVolume added in v1.30.0 

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

func (*ControllerService) CreateSnapshot added in v1.30.0 

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

func (*ControllerService) CreateVolume added in v1.30.0 

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

func (*ControllerService) DeleteSnapshot added in v1.30.0 

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

func (*ControllerService) DeleteVolume added in v1.30.0 

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

func (*ControllerService) GetCSIDriverModificationCapability added in v1.30.0 

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

func (*ControllerService) GetCapacity added in v1.30.0 

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

func (*ControllerService) ListSnapshots added in v1.30.0 

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

func (*ControllerService) ListVolumes added in v1.30.0 

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

func (*ControllerService) ModifyVolumeProperties added in v1.30.0 

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

func (*ControllerService) ValidateVolumeCapabilities added in v1.30.0 

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

type Driver 

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

func NewDriver 

func NewDriver(c cloud.Cloud, o *Options, m mounter.Mounter, md metadata.MetadataService, k kubernetes.Interface) (*Driver, 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) 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()

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 MockCSINodeInterface added in v1.29.0 

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

MockCSINodeInterface is a mock of CSINodeInterface interface.

func NewMockCSINodeInterface added in v1.29.0 

func NewMockCSINodeInterface(ctrl *gomock.Controller) *MockCSINodeInterface

NewMockCSINodeInterface creates a new mock instance.

func (*MockCSINodeInterface) Apply added in v1.29.0 

func (m *MockCSINodeInterface) Apply(arg0 context.Context, arg1 *v11.CSINodeApplyConfiguration, arg2 v10.ApplyOptions) (*v1.CSINode, error)

Apply mocks base method.

func (*MockCSINodeInterface) Create added in v1.29.0 

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

Create mocks base method.

func (*MockCSINodeInterface) Delete added in v1.29.0 

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

Delete mocks base method.

func (*MockCSINodeInterface) DeleteCollection added in v1.29.0 

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

DeleteCollection mocks base method.

func (*MockCSINodeInterface) EXPECT added in v1.29.0 

func (m *MockCSINodeInterface) EXPECT() *MockCSINodeInterfaceMockRecorder

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

func (*MockCSINodeInterface) Get added in v1.29.0 

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

Get mocks base method.

func (*MockCSINodeInterface) List added in v1.29.0 

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

List mocks base method.

func (*MockCSINodeInterface) Patch added in v1.29.0 

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

Patch mocks base method.

func (*MockCSINodeInterface) Update added in v1.29.0 

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

Update mocks base method.

func (*MockCSINodeInterface) Watch added in v1.29.0 

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

Watch mocks base method.

type MockCSINodeInterfaceMockRecorder added in v1.29.0 

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

MockCSINodeInterfaceMockRecorder is the mock recorder for MockCSINodeInterface.

func (*MockCSINodeInterfaceMockRecorder) Apply added in v1.29.0 

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

Apply indicates an expected call of Apply.

func (*MockCSINodeInterfaceMockRecorder) Create added in v1.29.0 

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

Create indicates an expected call of Create.

func (*MockCSINodeInterfaceMockRecorder) Delete added in v1.29.0 

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

Delete indicates an expected call of Delete.

func (*MockCSINodeInterfaceMockRecorder) DeleteCollection added in v1.29.0 

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

DeleteCollection indicates an expected call of DeleteCollection.

func (*MockCSINodeInterfaceMockRecorder) Get added in v1.29.0 

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

Get indicates an expected call of Get.

func (*MockCSINodeInterfaceMockRecorder) List added in v1.29.0 

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

List indicates an expected call of List.

func (*MockCSINodeInterfaceMockRecorder) Patch added in v1.29.0 

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

Patch indicates an expected call of Patch.

func (*MockCSINodeInterfaceMockRecorder) Update added in v1.29.0 

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

Update indicates an expected call of Update.

func (*MockCSINodeInterfaceMockRecorder) Watch added in v1.29.0 

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

Watch indicates an expected call of Watch.

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 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) FlowcontrolV1 added in v1.26.0 

func (m *MockKubernetesClient) FlowcontrolV1() v110.FlowcontrolV1Interface

FlowcontrolV1 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() v111.NetworkingV1Interface

NetworkingV1 mocks base method.

func (*MockKubernetesClient) NetworkingV1alpha1 added in v1.19.0 

func (m *MockKubernetesClient) NetworkingV1alpha1() v1alpha13.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() v112.NodeV1Interface

NodeV1 mocks base method.

func (*MockKubernetesClient) NodeV1alpha1 added in v1.19.0 

func (m *MockKubernetesClient) NodeV1alpha1() v1alpha14.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() v113.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() v114.RbacV1Interface

RbacV1 mocks base method.

func (*MockKubernetesClient) RbacV1alpha1 added in v1.19.0 

func (m *MockKubernetesClient) RbacV1alpha1() v1alpha15.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() v115.SchedulingV1Interface

SchedulingV1 mocks base method.

func (*MockKubernetesClient) SchedulingV1alpha1 added in v1.19.0 

func (m *MockKubernetesClient) SchedulingV1alpha1() v1alpha16.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() v116.StorageV1Interface

StorageV1 mocks base method.

func (*MockKubernetesClient) StorageV1alpha1 added in v1.19.0 

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

StorageV1alpha1 mocks base method.

func (*MockKubernetesClient) StorageV1beta1 added in v1.19.0 

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

StorageV1beta1 mocks base method.

func (*MockKubernetesClient) StoragemigrationV1alpha1 added in v1.30.0 

func (m *MockKubernetesClient) StoragemigrationV1alpha1() v1alpha18.StoragemigrationV1alpha1Interface

StoragemigrationV1alpha1 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) FlowcontrolV1 added in v1.26.0 

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

FlowcontrolV1 indicates an expected call of FlowcontrolV1.

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.

func (*MockKubernetesClientMockRecorder) StoragemigrationV1alpha1 added in v1.30.0 

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

StoragemigrationV1alpha1 indicates an expected call of StoragemigrationV1alpha1.

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 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 NodeService added in v1.30.0 

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

NodeService represents the node service of CSI driver

func NewNodeService added in v1.30.0 

func NewNodeService(o *Options, md metadata.MetadataService, m mounter.Mounter, k kubernetes.Interface) *NodeService

NewNodeService creates a new node service

func (*NodeService) NodeExpandVolume added in v1.30.0 

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

func (*NodeService) NodeGetCapabilities added in v1.30.0 

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

func (*NodeService) NodeGetInfo added in v1.30.0 

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

func (*NodeService) NodeGetVolumeStats added in v1.30.0 

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

func (*NodeService) NodePublishVolume added in v1.30.0 

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

func (*NodeService) NodeStageVolume added in v1.30.0 

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

func (*NodeService) NodeUnpublishVolume added in v1.30.0 

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

func (*NodeService) NodeUnstageVolume added in v1.30.0 

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

type Options added in v1.30.0 

type Options struct {
	Mode Mode

	//Endpoint is the endpoint for the CSI driver server
	Endpoint string
	// HttpEndpoint is the TCP network address where the HTTP server for metrics will listen
	HttpEndpoint string
	// MetricsCertFile is the location of the certificate for serving the metrics server over HTTPS
	MetricsCertFile string
	// MetricsKeyFile is the location of the key for serving the metrics server over HTTPS
	MetricsKeyFile string
	// EnableOtelTracing is a flag to enable opentelemetry tracing for the driver
	EnableOtelTracing bool

	// ExtraTags is a map of tags that will be attached to each dynamically provisioned
	// resource.
	ExtraTags map[string]string
	// ExtraVolumeTags is a map of tags that will be attached to each dynamically provisioned
	// volume.
	// DEPRECATED: Use ExtraTags instead.
	ExtraVolumeTags map[string]string
	// ID of the kubernetes cluster.
	KubernetesClusterID string
	// flag to enable sdk debug log
	AwsSdkDebugLog bool
	// flag to warn on invalid tag, instead of returning an error
	WarnOnInvalidTag bool
	// flag to set user agent
	UserAgentExtra string
	// flag to enable batching of API calls
	Batching bool
	// flag to set the timeout for volume modification requests to be coalesced into a single
	// volume modification call to AWS.
	ModifyVolumeRequestHandlerTimeout time.Duration

	// VolumeAttachLimit specifies the value that shall be reported as "maximum number of attachable volumes"
	// in CSINode objects. It is similar to https://kubernetes.io/docs/concepts/storage/storage-limits/#custom-limits
	// which allowed administrators to specify custom volume limits by configuring the kube-scheduler. Also, each AWS
	// machine type has different volume limits. By default, the EBS CSI driver parses the machine type name and then
	// decides the volume limit. However, this is only a rough approximation and not good enough in most cases.
	// Specifying the volume attach limit via command line is the alternative until a more sophisticated solution presents
	// itself (dynamically discovering the maximum number of attachable volume per EC2 machine type, see also
	// https://github.com/kubernetes-sigs/aws-ebs-csi-driver/issues/347).
	VolumeAttachLimit int64
	// ReservedVolumeAttachments specifies number of volume attachments reserved for system use.
	// Typically 1 for the root disk, but may be larger when more system disks are attached to nodes.
	// This option is not used when --volume-attach-limit is specified.
	// When -1, the amount of reserved attachments is loaded from instance metadata that captured state at node boot
	// and may include not only system disks but also CSI volumes (and therefore it may be wrong).
	ReservedVolumeAttachments int
}

Options contains options and configuration settings for the driver.

func (*Options) AddFlags added in v1.30.0 

func (o *Options) AddFlags(f *flag.FlagSet)

func (*Options) Validate added in v1.30.0 

func (o *Options) Validate() 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.