ec2

func (*Mock) AttachVolume ¶ added in v1.3.2

func (m *Mock) AttachVolume(_ context.Context, volumeID, instanceID, device string) error

AttachVolume attaches a volume to an instance.

func (*Mock) CancelSpotRequests ¶ added in v1.2.0

func (m *Mock) CancelSpotRequests(ctx context.Context, requestIDs []string) error

CancelSpotRequests cancels spot requests and terminates instances for one-time requests.

func (*Mock) CreateAutoScalingGroup ¶ added in v1.2.0

func (m *Mock) CreateAutoScalingGroup(
	ctx context.Context, cfg driver.AutoScalingGroupConfig,
) (*driver.AutoScalingGroup, error)

CreateAutoScalingGroup creates an auto-scaling group and launches desired instances.

func (*Mock) CreateImage ¶ added in v1.3.2

func (m *Mock) CreateImage(_ context.Context, cfg driver.ImageConfig) (*driver.ImageInfo, error)

CreateImage creates a machine image from an instance.

func (*Mock) CreateKeyPair ¶ added in v1.4.0

func (m *Mock) CreateKeyPair(_ context.Context, cfg driver.KeyPairConfig) (*driver.KeyPairInfo, error)

CreateKeyPair creates a new key pair.

func (*Mock) CreateLaunchTemplate ¶ added in v1.2.0

func (m *Mock) CreateLaunchTemplate(
	_ context.Context, cfg driver.LaunchTemplateConfig,
) (*driver.LaunchTemplate, error)

CreateLaunchTemplate creates a new launch template.

func (*Mock) CreateSnapshot ¶ added in v1.3.2

func (m *Mock) CreateSnapshot(_ context.Context, cfg driver.SnapshotConfig) (*driver.SnapshotInfo, error)

CreateSnapshot creates a snapshot from a volume.

func (*Mock) CreateVolume ¶ added in v1.3.2

func (m *Mock) CreateVolume(_ context.Context, cfg driver.VolumeConfig) (*driver.VolumeInfo, error)

CreateVolume creates a new EBS volume.

func (*Mock) DeleteAutoScalingGroup ¶ added in v1.2.0

func (m *Mock) DeleteAutoScalingGroup(ctx context.Context, name string, forceDelete bool) error

DeleteAutoScalingGroup deletes an ASG, optionally force-terminating its instances.

func (*Mock) DeleteKeyPair ¶ added in v1.4.0

func (m *Mock) DeleteKeyPair(_ context.Context, name string) error

DeleteKeyPair deletes a key pair by name.

func (*Mock) DeleteLaunchTemplate ¶ added in v1.2.0

func (m *Mock) DeleteLaunchTemplate(_ context.Context, name string) error

DeleteLaunchTemplate deletes a launch template by name.

func (*Mock) DeleteScalingPolicy ¶ added in v1.2.0

func (m *Mock) DeleteScalingPolicy(_ context.Context, asgName, policyName string) error

DeleteScalingPolicy removes a scaling policy from an ASG.

func (*Mock) DeleteSnapshot ¶ added in v1.3.2

func (m *Mock) DeleteSnapshot(_ context.Context, id string) error

DeleteSnapshot deletes a snapshot.

func (*Mock) DeleteVolume ¶ added in v1.3.2

func (m *Mock) DeleteVolume(_ context.Context, id string) error

DeleteVolume deletes an EBS volume.

func (*Mock) DeregisterImage ¶ added in v1.3.2

func (m *Mock) DeregisterImage(_ context.Context, id string) error

DeregisterImage deregisters a machine image.

func (*Mock) DescribeImages ¶ added in v1.3.2

func (m *Mock) DescribeImages(_ context.Context, ids []string) ([]driver.ImageInfo, error)

DescribeImages returns images matching the given IDs.

func (*Mock) DescribeInstances ¶

func (m *Mock) DescribeInstances(_ context.Context, instanceIDs []string, filters []driver.DescribeFilter) ([]driver.Instance, error)

func (*Mock) DescribeKeyPairs ¶ added in v1.4.0

func (m *Mock) DescribeKeyPairs(_ context.Context, names []string) ([]driver.KeyPairInfo, error)

DescribeKeyPairs returns key pairs matching the given names.

func (*Mock) DescribeSnapshots ¶ added in v1.3.2

func (m *Mock) DescribeSnapshots(_ context.Context, ids []string) ([]driver.SnapshotInfo, error)

DescribeSnapshots returns snapshots matching the given IDs.

func (*Mock) DescribeSpotRequests ¶ added in v1.2.0

func (m *Mock) DescribeSpotRequests(
	_ context.Context, requestIDs []string,
) ([]driver.SpotInstanceRequest, error)

DescribeSpotRequests returns spot requests matching the given IDs.

func (*Mock) DescribeVolumes ¶ added in v1.3.2

func (m *Mock) DescribeVolumes(_ context.Context, ids []string) ([]driver.VolumeInfo, error)

DescribeVolumes returns volumes matching the given IDs.

func (*Mock) DetachVolume ¶ added in v1.3.2

func (m *Mock) DetachVolume(_ context.Context, volumeID string) error

DetachVolume detaches a volume from an instance.

func (*Mock) ExecuteScalingPolicy ¶ added in v1.2.0

func (m *Mock) ExecuteScalingPolicy(ctx context.Context, asgName, policyName string) error

ExecuteScalingPolicy executes a scaling policy on an ASG.

func (*Mock) GetAutoScalingGroup ¶ added in v1.2.0

func (m *Mock) GetAutoScalingGroup(_ context.Context, name string) (*driver.AutoScalingGroup, error)

GetAutoScalingGroup returns details of an ASG.

func (*Mock) GetLaunchTemplate ¶ added in v1.2.0

func (m *Mock) GetLaunchTemplate(_ context.Context, name string) (*driver.LaunchTemplate, error)

GetLaunchTemplate returns a launch template by name.

func (*Mock) ListAutoScalingGroups ¶ added in v1.2.0

func (m *Mock) ListAutoScalingGroups(_ context.Context) ([]driver.AutoScalingGroup, error)

ListAutoScalingGroups returns all ASGs.

func (*Mock) ListLaunchTemplates ¶ added in v1.2.0

func (m *Mock) ListLaunchTemplates(_ context.Context) ([]driver.LaunchTemplate, error)

ListLaunchTemplates returns all launch templates.

func (*Mock) ModifyInstance ¶

func (m *Mock) ModifyInstance(_ context.Context, instanceID string, input driver.ModifyInstanceInput) error

func (*Mock) PutScalingPolicy ¶ added in v1.2.0

func (m *Mock) PutScalingPolicy(_ context.Context, policy driver.ScalingPolicy) error

PutScalingPolicy attaches a scaling policy to an ASG.

func (*Mock) RebootInstances ¶

func (m *Mock) RebootInstances(ctx context.Context, instanceIDs []string) error

func (*Mock) RequestSpotInstances ¶ added in v1.2.0

func (m *Mock) RequestSpotInstances(
	ctx context.Context, cfg driver.SpotRequestConfig,
) ([]driver.SpotInstanceRequest, error)

RequestSpotInstances creates spot instance requests and immediately fulfills them.

func (*Mock) RunInstances ¶

func (m *Mock) RunInstances(ctx context.Context, cfg driver.InstanceConfig, count int) ([]driver.Instance, error)

func (*Mock) SetDesiredCapacity ¶ added in v1.2.0

func (m *Mock) SetDesiredCapacity(ctx context.Context, name string, desired int) error

SetDesiredCapacity sets the desired capacity of an ASG.

func (*Mock) SetInstanceVPC ¶ added in v1.5.0

func (m *Mock) SetInstanceVPC(instanceID, vpcID string) error

SetInstanceVPC sets the VPC ID on an existing instance. This is a test helper since RunInstances does not automatically resolve VPC from subnet.

func (*Mock) SetMonitoring ¶

func (m *Mock) SetMonitoring(mon mondriver.Monitoring)

SetMonitoring sets the monitoring backend for auto-metric generation.

func (*Mock) StartInstances ¶

func (m *Mock) StartInstances(ctx context.Context, instanceIDs []string) error

func (*Mock) StopInstances ¶

func (m *Mock) StopInstances(ctx context.Context, instanceIDs []string) error

func (*Mock) TerminateInstances ¶

func (m *Mock) TerminateInstances(ctx context.Context, instanceIDs []string) error

func (*Mock) UpdateAutoScalingGroup ¶ added in v1.2.0

func (m *Mock) UpdateAutoScalingGroup(
	ctx context.Context, name string, desired, minSize, maxSize int,
) error

UpdateAutoScalingGroup updates the capacity settings of an ASG.