aws

Documentation

Index

• type EC2Session
  • func NewEC2Session(concurrency uint) (*EC2Session, error)
  • func (e *EC2Session) CreateSnapshots(backupInfo *config.EBSBasedBRMeta) (map[string]string, VolumeAZs, error)
  • func (e *EC2Session) CreateVolumes(meta *config.EBSBasedBRMeta, volumeType string, iops, throughput int64) (map[string]string, error)
  • func (e *EC2Session) DeleteSnapshots(snapIDMap map[string]string)
  • func (e *EC2Session) DeleteVolumes(volumeIDMap map[string]string)
  • func (e *EC2Session) HandleDescribeVolumesResponse(resp *ec2.DescribeVolumesOutput) (int64, []*string)
  • func (e *EC2Session) WaitSnapshotsCreated(snapIDMap map[string]string, progress glue.Progress) (int64, error)
  • func (e *EC2Session) WaitVolumesCreated(volumeIDMap map[string]string, progress glue.Progress) (int64, error)
• type VolumeAZs

Types

type EC2Session

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

func NewEC2Session

func NewEC2Session(concurrency uint) (*EC2Session, error)

func (*EC2Session) CreateSnapshots

func (e *EC2Session) CreateSnapshots(backupInfo *config.EBSBasedBRMeta) (map[string]string, VolumeAZs, error)

CreateSnapshots is the mainly steps to control the data volume snapshots. It will do the following works. 1. determine the order of volume snapshot. 2. send snapshot requests to aws.

func (*EC2Session) CreateVolumes

func (e *EC2Session) CreateVolumes(meta *config.EBSBasedBRMeta, volumeType string, iops, throughput int64) (map[string]string, error)

CreateVolumes create volumes from snapshots if err happens in the middle, return half-done result returned map: store id -> old volume id -> new volume id

func (*EC2Session) DeleteSnapshots

func (e *EC2Session) DeleteSnapshots(snapIDMap map[string]string)

func (*EC2Session) DeleteVolumes

func (e *EC2Session) DeleteVolumes(volumeIDMap map[string]string)

func (*EC2Session) HandleDescribeVolumesResponse

func (e *EC2Session) HandleDescribeVolumesResponse(resp *ec2.DescribeVolumesOutput) (int64, []*string)

func (*EC2Session) WaitSnapshotsCreated

func (e *EC2Session) WaitSnapshotsCreated(snapIDMap map[string]string, progress glue.Progress) (int64, error)

WaitSnapshotsCreated waits all snapshots finished. according to EBS snapshot will do real snapshot background. so we'll check whether all snapshots finished.

func (*EC2Session) WaitVolumesCreated

func (e *EC2Session) WaitVolumesCreated(volumeIDMap map[string]string, progress glue.Progress) (int64, error)

type VolumeAZs

type VolumeAZs map[string]string