Struct AwsClient

pub struct AwsClient {
    settings: Settings,
    clients: HashMap<String, Client>,
}

A AWS client.

Fields

settings: Settings

The settings of the testbed.

clients: HashMap<String, Client>

A list of clients, one per AWS region.

Implementations

impl AwsClient

const OS_IMAGE: &'static str = "Canonical, Ubuntu, 22.04 LTS, amd64 jammy image build on 2023-02-16"

pub async fn new(settings: Settings) -> Self

Make a new AWS client.

fn check_but_ignore_duplicates<T, E>( response: Result<T, SdkError<E, HttpResponse>>, ) -> CloudProviderResult<()>

where E: Debug + Error + Send + Sync + 'static,

Parse an AWS response and ignore errors if they mean a request is a duplicate.

fn make_instance(&self, region: String, aws_instance: &Instance) -> Instance

Convert an AWS instance into an orchestrator instance (used in the rest of the codebase).

async fn find_image_id(&self, client: &Client) -> CloudProviderResult<String>

Query the image id determining the os of the instances. NOTE: The image id changes depending on the region.

async fn create_security_group( &self, client: &Client, ) -> CloudProviderResult<()>

Create a new security group for the instance (if it doesn’t already exist).

fn nvme_mount_command(&self) -> Vec<String>

Return the command to mount the first (standard) NVMe drive.

async fn check_nvme_support(&self) -> CloudProviderResult<bool>

Check whether the instance type specified in the settings supports NVMe drives.

Trait Implementations

impl Display for AwsClient

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

Formats the value using the given formatter.

impl ServerProviderClient for AwsClient

const USERNAME: &'static str = "ubuntu"

The username used to connect to the instances.

fn list_instances<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = CloudProviderResult<Vec<Instance>>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

List all existing instances (regardless of their status).

fn start_instances<'a, 'life0, 'async_trait, I>( &'life0 self, instances: I, ) -> Pin<Box<dyn Future<Output = CloudProviderResult<()>> + Send + 'async_trait>>

where I: Iterator<Item = &'a Instance> + Send + 'async_trait, Self: 'async_trait, 'a: 'async_trait, 'life0: 'async_trait,

Start the specified instances.

fn stop_instances<'a, 'life0, 'async_trait, I>( &'life0 self, instances: I, ) -> Pin<Box<dyn Future<Output = CloudProviderResult<()>> + Send + 'async_trait>>

where I: Iterator<Item = &'a Instance> + Send + 'async_trait, Self: 'async_trait, 'a: 'async_trait, 'life0: 'async_trait,

Halt/Stop the specified instances. We may still be billed for stopped instances.

fn create_instance<'life0, 'async_trait, S>( &'life0 self, region: S, ) -> Pin<Box<dyn Future<Output = CloudProviderResult<Instance>> + Send + 'async_trait>>

where S: Into<String> + Serialize + Send + 'async_trait, Self: 'async_trait, 'life0: 'async_trait,

Create an instance in a specific region.

fn delete_instance<'life0, 'async_trait>( &'life0 self, instance: Instance, ) -> Pin<Box<dyn Future<Output = CloudProviderResult<()>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Delete a specific instance. Calling this function ensures we are no longer billed for the specified instance.

fn register_ssh_public_key<'life0, 'async_trait>( &'life0 self, public_key: String, ) -> Pin<Box<dyn Future<Output = CloudProviderResult<()>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Authorize the provided ssh public key to access machines.

fn instance_setup_commands<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = CloudProviderResult<Vec<String>>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Return provider-specific commands to setup the instance.