Struct Manager

pub struct Manager { /* private fields */ }

Implements AWS EC2 manager.

Implementations

impl Manager

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

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_attached_volumes( &self, instance_id: Option<String>, device_path: Option<String>, ) -> Result<Vec<Volume>>

Describes all attached volumes by instance Id and device. If “instance_id” is empty, it fetches from the local EC2 instance’s metadata service. 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 get_volume( &self, instance_id: Option<String>, device_path: &str, ) -> Result<Volume>

Fetches the EBS volume by its attachment state. If “instance_id” is empty, it fetches from the local EC2 instance’s metadata service.

pub async fn poll_volume_attachment_state( &self, instance_id: Option<String>, device_path: &str, desired_attachment_state: VolumeAttachmentState, timeout: Duration, interval: Duration, ) -> Result<Volume>

Polls EBS volume attachment state. If “instance_id” is empty, it fetches from the local EC2 instance’s metadata service.

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 duplicate 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.