cloud

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: 26 Imported by: 4

Documentation

Overview

Package cloud is a generated GoMock package.

Package cloud is a generated GoMock package.

Index

Constants

View Source 
const (
	// VolumeTypeIO1 represents a provisioned IOPS SSD type of volume.
	VolumeTypeIO1 = "io1"
	// VolumeTypeIO2 represents a provisioned IOPS SSD type of volume.
	VolumeTypeIO2 = "io2"
	// VolumeTypeGP2 represents a general purpose SSD type of volume.
	VolumeTypeGP2 = "gp2"
	// VolumeTypeGP3 represents a general purpose SSD type of volume.
	VolumeTypeGP3 = "gp3"
	// VolumeTypeSC1 represents a cold HDD (sc1) type of volume.
	VolumeTypeSC1 = "sc1"
	// VolumeTypeST1 represents a throughput-optimized HDD type of volume.
	VolumeTypeST1 = "st1"
	// VolumeTypeSBG1 represents a capacity-optimized HDD type of volume. Only for SBE devices.
	VolumeTypeSBG1 = "sbg1"
	// VolumeTypeSBP1 represents a performance-optimized SSD type of volume. Only for SBE devices.
	VolumeTypeSBP1 = "sbp1"
	// VolumeTypeStandard represents a previous type of  volume.
	VolumeTypeStandard = "standard"
)

AWS volume types

View Source 
const (
	// MaxNumTagsPerResource represents the maximum number of tags per AWS resource.
	MaxNumTagsPerResource = 50
	// MinTagKeyLength represents the minimum key length for a tag.
	MinTagKeyLength = 1
	// MaxTagKeyLength represents the maximum key length for a tag.
	MaxTagKeyLength = 128
	// MaxTagValueLength represents the maximum value length for a tag.
	MaxTagValueLength = 256
)

AWS provisioning limits. Source: 

https://docs.aws.amazon.com/AWSEC2/latest/UserGuide/Using_Tags.html#tag-restrictions
View Source 
const (
	// VolumeNameTagKey is the key value that refers to the volume's name.
	VolumeNameTagKey = "CSIVolumeName"
	// SnapshotNameTagKey is the key value that refers to the snapshot's name.
	SnapshotNameTagKey = "CSIVolumeSnapshotName"
	// KubernetesTagKeyPrefix is the prefix of the key value that is reserved for Kubernetes.
	KubernetesTagKeyPrefix = "kubernetes.io"
	// AWSTagKeyPrefix is the prefix of the key value that is reserved for AWS.
	AWSTagKeyPrefix = "aws:"
	//AwsEbsDriverTagKey is the tag to identify if a volume/snapshot is managed by ebs csi driver
	AwsEbsDriverTagKey = "ebs.csi.aws.com/cluster"
)

Tags

View Source 
const (
	// DefaultVolumeSize represents the default volume size.
	DefaultVolumeSize int64 = 100 * util.GiB
)

Defaults

Variables

View Source 
var (
	// ErrMultiDisks is an error that is returned when multiple
	// disks are found with the same volume name.
	ErrMultiDisks = errors.New("Multiple disks with same name")

	// ErrDiskExistsDiffSize is an error that is returned if a disk with a given
	// name, but different size, is found.
	ErrDiskExistsDiffSize = errors.New("There is already a disk with same name and different size")

	// ErrNotFound is returned when a resource is not found.
	ErrNotFound = errors.New("Resource was not found")

	// ErrIdempotent is returned when another request with same idempotent token is in-flight.
	ErrIdempotentParameterMismatch = errors.New("Parameters on this idempotent request are inconsistent with parameters used in previous request(s)")

	// ErrAlreadyExists is returned when a resource is already existent.
	ErrAlreadyExists = errors.New("Resource already exists")

	// ErrMultiSnapshots is returned when multiple snapshots are found
	// with the same ID
	ErrMultiSnapshots = errors.New("Multiple snapshots with the same name found")

	// ErrInvalidMaxResults is returned when a MaxResults pagination parameter is between 1 and 4
	ErrInvalidMaxResults = errors.New("MaxResults parameter must be 0 or greater than or equal to 5")

	// VolumeNotBeingModified is returned if volume being described is not being modified
	VolumeNotBeingModified = fmt.Errorf("volume is not being modified")

	// ErrInvalidArgument is returned if parameters were rejected by cloud provider
	ErrInvalidArgument = errors.New("invalid argument")

	// ErrInvalidRequest is returned if parameters were rejected by driver
	ErrInvalidRequest = errors.New("invalid request")
)
View Source 
var (
	ValidVolumeTypes = []string{
		VolumeTypeIO1,
		VolumeTypeIO2,
		VolumeTypeGP2,
		VolumeTypeGP3,
		VolumeTypeSC1,
		VolumeTypeST1,
		VolumeTypeStandard,
	}
)

Functions

func GetDedicatedLimitForInstanceType added in v1.22.0 

func GetDedicatedLimitForInstanceType(it string) int

func GetEBSLimitForInstanceType added in v1.6.0 

func GetEBSLimitForInstanceType(it string) (int, bool)

func GetMaxAttachments added in v1.6.0 

func GetMaxAttachments(nitro bool) int

func GetNVMeInstanceStoreVolumesForInstanceType added in v1.6.0 

func GetNVMeInstanceStoreVolumesForInstanceType(it string) int

func IsNitroInstanceType added in v1.6.0 

func IsNitroInstanceType(it string) bool

func RecordRequestsMiddleware added in v1.30.0 

func RecordRequestsMiddleware() func(*middleware.Stack) error

RecordRequestsHandler is added to the Complete chain; called after any request

Types

type Cloud 

type Cloud interface {
	CreateDisk(ctx context.Context, volumeName string, diskOptions *DiskOptions) (disk *Disk, err error)
	DeleteDisk(ctx context.Context, volumeID string) (success bool, err error)
	AttachDisk(ctx context.Context, volumeID string, nodeID string) (devicePath string, err error)
	DetachDisk(ctx context.Context, volumeID string, nodeID string) (err error)
	ResizeOrModifyDisk(ctx context.Context, volumeID string, newSizeBytes int64, options *ModifyDiskOptions) (newSize int32, err error)
	WaitForAttachmentState(ctx context.Context, volumeID, expectedState string, expectedInstance string, expectedDevice string, alreadyAssigned bool) (*types.VolumeAttachment, error)
	GetDiskByName(ctx context.Context, name string, capacityBytes int64) (disk *Disk, err error)
	GetDiskByID(ctx context.Context, volumeID string) (disk *Disk, err error)
	CreateSnapshot(ctx context.Context, volumeID string, snapshotOptions *SnapshotOptions) (snapshot *Snapshot, err error)
	DeleteSnapshot(ctx context.Context, snapshotID string) (success bool, err error)
	GetSnapshotByName(ctx context.Context, name string) (snapshot *Snapshot, err error)
	GetSnapshotByID(ctx context.Context, snapshotID string) (snapshot *Snapshot, err error)
	ListSnapshots(ctx context.Context, volumeID string, maxResults int32, nextToken string) (listSnapshotsResponse *ListSnapshotsResponse, err error)
	EnableFastSnapshotRestores(ctx context.Context, availabilityZones []string, snapshotID string) (*ec2.EnableFastSnapshotRestoresOutput, error)
	AvailabilityZones(ctx context.Context) (map[string]struct{}, error)
}

func NewCloud 

func NewCloud(region string, awsSdkDebugLog bool, userAgentExtra string, batching bool) (Cloud, error)

NewCloud returns a new instance of AWS cloud It panics if session is invalid

type Disk 

type Disk struct {
	VolumeID         string
	CapacityGiB      int32
	AvailabilityZone string
	SnapshotID       string
	OutpostArn       string
	Attachments      []string
}

Disk represents a EBS volume

type DiskOptions 

type DiskOptions struct {
	CapacityBytes          int64
	Tags                   map[string]string
	VolumeType             string
	IOPSPerGB              int32
	AllowIOPSPerGBIncrease bool
	IOPS                   int32
	Throughput             int32
	AvailabilityZone       string
	OutpostArn             string
	Encrypted              bool
	BlockExpress           bool
	MultiAttachEnabled     bool
	// KmsKeyID represents a fully qualified resource name to the key to use for encryption.
	// example: arn:aws:kms:us-east-1:012345678910:key/abcd1234-a123-456a-a12b-a123b4cd56ef
	KmsKeyID   string
	SnapshotID string
}

DiskOptions represents parameters to create an EBS volume

type EC2API added in v1.30.0 

type EC2API interface {
	DescribeVolumes(ctx context.Context, params *ec2.DescribeVolumesInput, optFns ...func(*ec2.Options)) (*ec2.DescribeVolumesOutput, error)
	CreateVolume(ctx context.Context, params *ec2.CreateVolumeInput, optFns ...func(*ec2.Options)) (*ec2.CreateVolumeOutput, error)
	DeleteVolume(ctx context.Context, params *ec2.DeleteVolumeInput, optFns ...func(*ec2.Options)) (*ec2.DeleteVolumeOutput, error)
	AttachVolume(ctx context.Context, params *ec2.AttachVolumeInput, optFns ...func(*ec2.Options)) (*ec2.AttachVolumeOutput, error)
	DetachVolume(ctx context.Context, params *ec2.DetachVolumeInput, optFns ...func(*ec2.Options)) (*ec2.DetachVolumeOutput, error)
	DescribeInstances(ctx context.Context, params *ec2.DescribeInstancesInput, optFns ...func(*ec2.Options)) (*ec2.DescribeInstancesOutput, error)
	DescribeAvailabilityZones(ctx context.Context, params *ec2.DescribeAvailabilityZonesInput, optFns ...func(*ec2.Options)) (*ec2.DescribeAvailabilityZonesOutput, error)
	CreateSnapshot(ctx context.Context, params *ec2.CreateSnapshotInput, optFns ...func(*ec2.Options)) (*ec2.CreateSnapshotOutput, error)
	DeleteSnapshot(ctx context.Context, params *ec2.DeleteSnapshotInput, optFns ...func(*ec2.Options)) (*ec2.DeleteSnapshotOutput, error)
	DescribeSnapshots(ctx context.Context, params *ec2.DescribeSnapshotsInput, optFns ...func(*ec2.Options)) (*ec2.DescribeSnapshotsOutput, error)
	ModifyVolume(ctx context.Context, params *ec2.ModifyVolumeInput, optFns ...func(*ec2.Options)) (*ec2.ModifyVolumeOutput, error)
	DescribeVolumesModifications(ctx context.Context, params *ec2.DescribeVolumesModificationsInput, optFns ...func(*ec2.Options)) (*ec2.DescribeVolumesModificationsOutput, error)
	DescribeTags(ctx context.Context, params *ec2.DescribeTagsInput, optFns ...func(*ec2.Options)) (*ec2.DescribeTagsOutput, error)
	CreateTags(ctx context.Context, params *ec2.CreateTagsInput, optFns ...func(*ec2.Options)) (*ec2.CreateTagsOutput, error)
	EnableFastSnapshotRestores(ctx context.Context, params *ec2.EnableFastSnapshotRestoresInput, optFns ...func(*ec2.Options)) (*ec2.EnableFastSnapshotRestoresOutput, error)
}

type ListSnapshotsResponse added in v0.4.0 

type ListSnapshotsResponse struct {
	Snapshots []*Snapshot
	NextToken string
}

ListSnapshotsResponse is the container for our snapshots along with a pagination token to pass back to the caller

type MockCloud added in v1.4.0 

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

MockCloud is a mock of Cloud interface.

func NewMockCloud added in v1.4.0 

func NewMockCloud(ctrl *gomock.Controller) *MockCloud

NewMockCloud creates a new mock instance.

func (*MockCloud) AttachDisk added in v1.4.0 

func (m *MockCloud) AttachDisk(ctx context.Context, volumeID, nodeID string) (string, error)

AttachDisk mocks base method.

func (*MockCloud) AvailabilityZones added in v1.18.0 

func (m *MockCloud) AvailabilityZones(ctx context.Context) (map[string]struct{}, error)

AvailabilityZones mocks base method.

func (*MockCloud) CreateDisk added in v1.4.0 

func (m *MockCloud) CreateDisk(ctx context.Context, volumeName string, diskOptions *DiskOptions) (*Disk, error)

CreateDisk mocks base method.

func (*MockCloud) CreateSnapshot added in v1.4.0 

func (m *MockCloud) CreateSnapshot(ctx context.Context, volumeID string, snapshotOptions *SnapshotOptions) (*Snapshot, error)

CreateSnapshot mocks base method.

func (*MockCloud) DeleteDisk added in v1.4.0 

func (m *MockCloud) DeleteDisk(ctx context.Context, volumeID string) (bool, error)

DeleteDisk mocks base method.

func (*MockCloud) DeleteSnapshot added in v1.4.0 

func (m *MockCloud) DeleteSnapshot(ctx context.Context, snapshotID string) (bool, error)

DeleteSnapshot mocks base method.

func (*MockCloud) DetachDisk added in v1.4.0 

func (m *MockCloud) DetachDisk(ctx context.Context, volumeID, nodeID string) error

DetachDisk mocks base method.

func (*MockCloud) EXPECT added in v1.4.0 

func (m *MockCloud) EXPECT() *MockCloudMockRecorder

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

func (*MockCloud) EnableFastSnapshotRestores added in v1.18.0 

func (m *MockCloud) EnableFastSnapshotRestores(ctx context.Context, availabilityZones []string, snapshotID string) (*ec2.EnableFastSnapshotRestoresOutput, error)

EnableFastSnapshotRestores mocks base method.

func (*MockCloud) GetDiskByID added in v1.4.0 

func (m *MockCloud) GetDiskByID(ctx context.Context, volumeID string) (*Disk, error)

GetDiskByID mocks base method.

func (*MockCloud) GetDiskByName added in v1.4.0 

func (m *MockCloud) GetDiskByName(ctx context.Context, name string, capacityBytes int64) (*Disk, error)

GetDiskByName mocks base method.

func (*MockCloud) GetSnapshotByID added in v1.4.0 

func (m *MockCloud) GetSnapshotByID(ctx context.Context, snapshotID string) (*Snapshot, error)

GetSnapshotByID mocks base method.

func (*MockCloud) GetSnapshotByName added in v1.4.0 

func (m *MockCloud) GetSnapshotByName(ctx context.Context, name string) (*Snapshot, error)

GetSnapshotByName mocks base method.

func (*MockCloud) ListSnapshots added in v1.4.0 

func (m *MockCloud) ListSnapshots(ctx context.Context, volumeID string, maxResults int32, nextToken string) (*ListSnapshotsResponse, error)

ListSnapshots mocks base method.

func (*MockCloud) ResizeOrModifyDisk added in v1.22.0 

func (m *MockCloud) ResizeOrModifyDisk(ctx context.Context, volumeID string, newSizeBytes int64, options *ModifyDiskOptions) (int32, error)

ResizeOrModifyDisk mocks base method.

func (*MockCloud) WaitForAttachmentState added in v1.4.0 

func (m *MockCloud) WaitForAttachmentState(ctx context.Context, volumeID, expectedState, expectedInstance, expectedDevice string, alreadyAssigned bool) (*types.VolumeAttachment, error)

WaitForAttachmentState mocks base method.

type MockCloudMockRecorder added in v1.4.0 

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

MockCloudMockRecorder is the mock recorder for MockCloud.

func (*MockCloudMockRecorder) AttachDisk added in v1.4.0 

func (mr *MockCloudMockRecorder) AttachDisk(ctx, volumeID, nodeID interface{}) *gomock.Call

AttachDisk indicates an expected call of AttachDisk.

func (*MockCloudMockRecorder) AvailabilityZones added in v1.18.0 

func (mr *MockCloudMockRecorder) AvailabilityZones(ctx interface{}) *gomock.Call

AvailabilityZones indicates an expected call of AvailabilityZones.

func (*MockCloudMockRecorder) CreateDisk added in v1.4.0 

func (mr *MockCloudMockRecorder) CreateDisk(ctx, volumeName, diskOptions interface{}) *gomock.Call

CreateDisk indicates an expected call of CreateDisk.

func (*MockCloudMockRecorder) CreateSnapshot added in v1.4.0 

func (mr *MockCloudMockRecorder) CreateSnapshot(ctx, volumeID, snapshotOptions interface{}) *gomock.Call

CreateSnapshot indicates an expected call of CreateSnapshot.

func (*MockCloudMockRecorder) DeleteDisk added in v1.4.0 

func (mr *MockCloudMockRecorder) DeleteDisk(ctx, volumeID interface{}) *gomock.Call

DeleteDisk indicates an expected call of DeleteDisk.

func (*MockCloudMockRecorder) DeleteSnapshot added in v1.4.0 

func (mr *MockCloudMockRecorder) DeleteSnapshot(ctx, snapshotID interface{}) *gomock.Call

DeleteSnapshot indicates an expected call of DeleteSnapshot.

func (*MockCloudMockRecorder) DetachDisk added in v1.4.0 

func (mr *MockCloudMockRecorder) DetachDisk(ctx, volumeID, nodeID interface{}) *gomock.Call

DetachDisk indicates an expected call of DetachDisk.

func (*MockCloudMockRecorder) EnableFastSnapshotRestores added in v1.18.0 

func (mr *MockCloudMockRecorder) EnableFastSnapshotRestores(ctx, availabilityZones, snapshotID interface{}) *gomock.Call

EnableFastSnapshotRestores indicates an expected call of EnableFastSnapshotRestores.

func (*MockCloudMockRecorder) GetDiskByID added in v1.4.0 

func (mr *MockCloudMockRecorder) GetDiskByID(ctx, volumeID interface{}) *gomock.Call

GetDiskByID indicates an expected call of GetDiskByID.

func (*MockCloudMockRecorder) GetDiskByName added in v1.4.0 

func (mr *MockCloudMockRecorder) GetDiskByName(ctx, name, capacityBytes interface{}) *gomock.Call

GetDiskByName indicates an expected call of GetDiskByName.

func (*MockCloudMockRecorder) GetSnapshotByID added in v1.4.0 

func (mr *MockCloudMockRecorder) GetSnapshotByID(ctx, snapshotID interface{}) *gomock.Call

GetSnapshotByID indicates an expected call of GetSnapshotByID.

func (*MockCloudMockRecorder) GetSnapshotByName added in v1.4.0 

func (mr *MockCloudMockRecorder) GetSnapshotByName(ctx, name interface{}) *gomock.Call

GetSnapshotByName indicates an expected call of GetSnapshotByName.

func (*MockCloudMockRecorder) ListSnapshots added in v1.4.0 

func (mr *MockCloudMockRecorder) ListSnapshots(ctx, volumeID, maxResults, nextToken interface{}) *gomock.Call

ListSnapshots indicates an expected call of ListSnapshots.

func (*MockCloudMockRecorder) ResizeOrModifyDisk added in v1.22.0 

func (mr *MockCloudMockRecorder) ResizeOrModifyDisk(ctx, volumeID, newSizeBytes, options interface{}) *gomock.Call

ResizeOrModifyDisk indicates an expected call of ResizeOrModifyDisk.

func (*MockCloudMockRecorder) WaitForAttachmentState added in v1.4.0 

func (mr *MockCloudMockRecorder) WaitForAttachmentState(ctx, volumeID, expectedState, expectedInstance, expectedDevice, alreadyAssigned interface{}) *gomock.Call

WaitForAttachmentState indicates an expected call of WaitForAttachmentState.

type MockEC2API added in v1.19.0 

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

MockEC2API is a mock of EC2API interface.

func NewMockEC2API added in v1.19.0 

func NewMockEC2API(ctrl *gomock.Controller) *MockEC2API

NewMockEC2API creates a new mock instance.

func (*MockEC2API) AttachVolume added in v1.19.0 

func (m *MockEC2API) AttachVolume(ctx context.Context, params *ec2.AttachVolumeInput, optFns ...func(*ec2.Options)) (*ec2.AttachVolumeOutput, error)

AttachVolume mocks base method.

func (*MockEC2API) CreateSnapshot added in v1.19.0 

func (m *MockEC2API) CreateSnapshot(ctx context.Context, params *ec2.CreateSnapshotInput, optFns ...func(*ec2.Options)) (*ec2.CreateSnapshotOutput, error)

CreateSnapshot mocks base method.

func (*MockEC2API) CreateTags added in v1.19.0 

func (m *MockEC2API) CreateTags(ctx context.Context, params *ec2.CreateTagsInput, optFns ...func(*ec2.Options)) (*ec2.CreateTagsOutput, error)

CreateTags mocks base method.

func (*MockEC2API) CreateVolume added in v1.19.0 

func (m *MockEC2API) CreateVolume(ctx context.Context, params *ec2.CreateVolumeInput, optFns ...func(*ec2.Options)) (*ec2.CreateVolumeOutput, error)

CreateVolume mocks base method.

func (*MockEC2API) DeleteSnapshot added in v1.19.0 

func (m *MockEC2API) DeleteSnapshot(ctx context.Context, params *ec2.DeleteSnapshotInput, optFns ...func(*ec2.Options)) (*ec2.DeleteSnapshotOutput, error)

DeleteSnapshot mocks base method.

func (*MockEC2API) DeleteVolume added in v1.19.0 

func (m *MockEC2API) DeleteVolume(ctx context.Context, params *ec2.DeleteVolumeInput, optFns ...func(*ec2.Options)) (*ec2.DeleteVolumeOutput, error)

DeleteVolume mocks base method.

func (*MockEC2API) DescribeAvailabilityZones added in v1.19.0 

func (m *MockEC2API) DescribeAvailabilityZones(ctx context.Context, params *ec2.DescribeAvailabilityZonesInput, optFns ...func(*ec2.Options)) (*ec2.DescribeAvailabilityZonesOutput, error)

DescribeAvailabilityZones mocks base method.

func (*MockEC2API) DescribeInstances added in v1.19.0 

func (m *MockEC2API) DescribeInstances(ctx context.Context, params *ec2.DescribeInstancesInput, optFns ...func(*ec2.Options)) (*ec2.DescribeInstancesOutput, error)

DescribeInstances mocks base method.

func (*MockEC2API) DescribeSnapshots added in v1.19.0 

func (m *MockEC2API) DescribeSnapshots(ctx context.Context, params *ec2.DescribeSnapshotsInput, optFns ...func(*ec2.Options)) (*ec2.DescribeSnapshotsOutput, error)

DescribeSnapshots mocks base method.

func (*MockEC2API) DescribeTags added in v1.19.0 

func (m *MockEC2API) DescribeTags(ctx context.Context, params *ec2.DescribeTagsInput, optFns ...func(*ec2.Options)) (*ec2.DescribeTagsOutput, error)

DescribeTags mocks base method.

func (*MockEC2API) DescribeVolumes added in v1.19.0 

func (m *MockEC2API) DescribeVolumes(ctx context.Context, params *ec2.DescribeVolumesInput, optFns ...func(*ec2.Options)) (*ec2.DescribeVolumesOutput, error)

DescribeVolumes mocks base method.

func (*MockEC2API) DescribeVolumesModifications added in v1.19.0 

func (m *MockEC2API) DescribeVolumesModifications(ctx context.Context, params *ec2.DescribeVolumesModificationsInput, optFns ...func(*ec2.Options)) (*ec2.DescribeVolumesModificationsOutput, error)

DescribeVolumesModifications mocks base method.

func (*MockEC2API) DetachVolume added in v1.19.0 

func (m *MockEC2API) DetachVolume(ctx context.Context, params *ec2.DetachVolumeInput, optFns ...func(*ec2.Options)) (*ec2.DetachVolumeOutput, error)

DetachVolume mocks base method.

func (*MockEC2API) EXPECT added in v1.19.0 

func (m *MockEC2API) EXPECT() *MockEC2APIMockRecorder

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

func (*MockEC2API) EnableFastSnapshotRestores added in v1.19.0 

func (m *MockEC2API) EnableFastSnapshotRestores(ctx context.Context, params *ec2.EnableFastSnapshotRestoresInput, optFns ...func(*ec2.Options)) (*ec2.EnableFastSnapshotRestoresOutput, error)

EnableFastSnapshotRestores mocks base method.

func (*MockEC2API) ModifyVolume added in v1.19.0 

func (m *MockEC2API) ModifyVolume(ctx context.Context, params *ec2.ModifyVolumeInput, optFns ...func(*ec2.Options)) (*ec2.ModifyVolumeOutput, error)

ModifyVolume mocks base method.

type MockEC2APIMockRecorder added in v1.19.0 

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

MockEC2APIMockRecorder is the mock recorder for MockEC2API.

func (*MockEC2APIMockRecorder) AttachVolume added in v1.19.0 

func (mr *MockEC2APIMockRecorder) AttachVolume(ctx, params interface{}, optFns ...interface{}) *gomock.Call

AttachVolume indicates an expected call of AttachVolume.

func (*MockEC2APIMockRecorder) CreateSnapshot added in v1.19.0 

func (mr *MockEC2APIMockRecorder) CreateSnapshot(ctx, params interface{}, optFns ...interface{}) *gomock.Call

CreateSnapshot indicates an expected call of CreateSnapshot.

func (*MockEC2APIMockRecorder) CreateTags added in v1.19.0 

func (mr *MockEC2APIMockRecorder) CreateTags(ctx, params interface{}, optFns ...interface{}) *gomock.Call

CreateTags indicates an expected call of CreateTags.

func (*MockEC2APIMockRecorder) CreateVolume added in v1.19.0 

func (mr *MockEC2APIMockRecorder) CreateVolume(ctx, params interface{}, optFns ...interface{}) *gomock.Call

CreateVolume indicates an expected call of CreateVolume.

func (*MockEC2APIMockRecorder) DeleteSnapshot added in v1.19.0 

func (mr *MockEC2APIMockRecorder) DeleteSnapshot(ctx, params interface{}, optFns ...interface{}) *gomock.Call

DeleteSnapshot indicates an expected call of DeleteSnapshot.

func (*MockEC2APIMockRecorder) DeleteVolume added in v1.19.0 

func (mr *MockEC2APIMockRecorder) DeleteVolume(ctx, params interface{}, optFns ...interface{}) *gomock.Call

DeleteVolume indicates an expected call of DeleteVolume.

func (*MockEC2APIMockRecorder) DescribeAvailabilityZones added in v1.19.0 

func (mr *MockEC2APIMockRecorder) DescribeAvailabilityZones(ctx, params interface{}, optFns ...interface{}) *gomock.Call

DescribeAvailabilityZones indicates an expected call of DescribeAvailabilityZones.

func (*MockEC2APIMockRecorder) DescribeInstances added in v1.19.0 

func (mr *MockEC2APIMockRecorder) DescribeInstances(ctx, params interface{}, optFns ...interface{}) *gomock.Call

DescribeInstances indicates an expected call of DescribeInstances.

func (*MockEC2APIMockRecorder) DescribeSnapshots added in v1.19.0 

func (mr *MockEC2APIMockRecorder) DescribeSnapshots(ctx, params interface{}, optFns ...interface{}) *gomock.Call

DescribeSnapshots indicates an expected call of DescribeSnapshots.

func (*MockEC2APIMockRecorder) DescribeTags added in v1.19.0 

func (mr *MockEC2APIMockRecorder) DescribeTags(ctx, params interface{}, optFns ...interface{}) *gomock.Call

DescribeTags indicates an expected call of DescribeTags.

func (*MockEC2APIMockRecorder) DescribeVolumes added in v1.19.0 

func (mr *MockEC2APIMockRecorder) DescribeVolumes(ctx, params interface{}, optFns ...interface{}) *gomock.Call

DescribeVolumes indicates an expected call of DescribeVolumes.

func (*MockEC2APIMockRecorder) DescribeVolumesModifications added in v1.19.0 

func (mr *MockEC2APIMockRecorder) DescribeVolumesModifications(ctx, params interface{}, optFns ...interface{}) *gomock.Call

DescribeVolumesModifications indicates an expected call of DescribeVolumesModifications.

func (*MockEC2APIMockRecorder) DetachVolume added in v1.19.0 

func (mr *MockEC2APIMockRecorder) DetachVolume(ctx, params interface{}, optFns ...interface{}) *gomock.Call

DetachVolume indicates an expected call of DetachVolume.

func (*MockEC2APIMockRecorder) EnableFastSnapshotRestores added in v1.19.0 

func (mr *MockEC2APIMockRecorder) EnableFastSnapshotRestores(ctx, params interface{}, optFns ...interface{}) *gomock.Call

EnableFastSnapshotRestores indicates an expected call of EnableFastSnapshotRestores.

func (*MockEC2APIMockRecorder) ModifyVolume added in v1.19.0 

func (mr *MockEC2APIMockRecorder) ModifyVolume(ctx, params interface{}, optFns ...interface{}) *gomock.Call

ModifyVolume indicates an expected call of ModifyVolume.

type ModifyDiskOptions added in v1.19.0 

type ModifyDiskOptions struct {
	VolumeType string
	IOPS       int32
	Throughput int32
}

ModifyDiskOptions represents parameters to modify an EBS volume

type Snapshot added in v0.3.0 

type Snapshot struct {
	SnapshotID     string
	SourceVolumeID string
	Size           int32
	CreationTime   time.Time
	ReadyToUse     bool
}

Snapshot represents an EBS volume snapshot

type SnapshotOptions added in v0.3.0 

type SnapshotOptions struct {
	Tags map[string]string
}

SnapshotOptions represents parameters to create an EBS volume

Source Files

View all Source files

Directories

Path Synopsis
Package metadata is a generated GoMock package.
 Package metadata is a generated GoMock package.

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.