Struct aws_manager::ec2::Manager

pub struct Manager { /* private fields */ }

Implements AWS EC2 manager.

Implementations

impl Manager

pub fn new(shared_config: &AwsSdkConfig) -> Self

pub fn client(&self) -> Client

pub async fn create_key_pair(&self, key_name: &str, key_path: &str) -> Result<()>

Creates an AWS EC2 key-pair and saves the private key to disk. It overwrites “key_path” file with the newly created key.

pub async fn delete_key_pair(&self, key_name: &str) -> Result<()>

Deletes the AWS EC2 key-pair.

pub async fn describe_volumes(
    &self,
    filters: Option<Vec<Filter>>
) -> Result<Vec<Volume>>

Describes the EBS volumes by filters. ref. https://docs.aws.amazon.com/AWSEC2/latest/APIReference/API_DescribeVolumes.html

pub async fn poll_volume_state(
    &self,
    ebs_volume_id: String,
    desired_state: VolumeState,
    timeout: Duration,
    interval: Duration
) -> Result<Option<Volume>>

Polls the EBS volume by its state.

pub async fn describe_local_volumes(
    &self,
    ebs_volume_id: Option<String>,
    ebs_device_name: String,
    local_ec2_instance_id: Option<String>
) -> Result<Vec<Volume>>

Describes the attached volume by the volume Id and EBS device name. The “local_ec2_instance_id” is only set to bypass extra EC2 metadata service API calls. The region used for API call is inherited from the EC2 client SDK.

e.g.,

aws ec2 describe-volumes
–region ${AWS::Region}
–filters
Name=attachment.instance-id,Values=$INSTANCE_ID
Name=attachment.device,Values=/dev/xvdb
–query Volumes[].Attachments[].State
–output text

ref. https://docs.aws.amazon.com/AWSEC2/latest/APIReference/API_DescribeVolumes.html ref. https://github.com/ava-labs/avalanche-ops/blob/fcbac87a219a8d3d6d3c38a1663fe1dafe78e04e/bin/avalancheup-aws/cfn-templates/asg_amd64_ubuntu.yaml#L397-L409

pub async fn poll_local_volume_by_attachment_state(
    &self,
    ebs_volume_id: Option<String>,
    ebs_device_name: String,
    desired_attachment_state: VolumeAttachmentState,
    timeout: Duration,
    interval: Duration
) -> Result<Volume>

Polls the EBS volume attachment state. For instance, the “device_name” can be either “/dev/xvdb” or “xvdb” (for the secondary volume).

pub async fn fetch_tags(&self, instance_id: Arc<String>) -> Result<Vec<Tag>>

Fetches all tags for the specified instance.

“If a single piece of data must be accessible from more than one task concurrently, then it must be shared using synchronization primitives such as Arc.” ref. https://tokio.rs/tokio/tutorial/spawning

pub async fn list_asg(&self, asg_name: &str) -> Result<Vec<Droplet>>

Lists instances by the Auto Scaling Groups name.

Trait Implementations

impl Clone for Manager

fn clone(&self) -> Manager

Returns a copy of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for Manager

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.