awsprovider

Oct 2, 2024

Changes in this version

+ func CreateSpotInstancesInRegion(ctx context.Context, region string, orchestrators []string, token string, ...) ([]string, error)

+ func GetAllStatuses() map[string]*models.DisplayStatus

+ func LoadAWSConfig(ctx context.Context, region string) (aws.Config, error)

+ func UpdateAllStatuses(status *models.DisplayStatus)

+ type AWSProvider struct

+ Config *aws.Config

+ EC2Client EC2Clienter

+ func NewAWSProvider(viper *viper.Viper) (*AWSProvider, error)

+ func (p *AWSProvider) CreateDeployment(ctx context.Context) error

+ func (p *AWSProvider) DestroyDeployment(ctx context.Context) error

+ func (p *AWSProvider) DestroyResources(ctx context.Context, vpcID string) error

+ func (p *AWSProvider) GetAllAWSRegions(ctx context.Context) ([]string, error)

+ func (p *AWSProvider) GetEC2Client() (EC2Clienter, error)

+ func (p *AWSProvider) GetLatestUbuntuImage(ctx context.Context, region string) (*types.Image, error)

+ func (p *AWSProvider) ListDeployments(ctx context.Context) ([]*types.Instance, error)

+ func (p *AWSProvider) SetEC2Client(client EC2Clienter)

+ type AWSProviderFunc func(ctx context.Context) (AWSProviderer, error)

+ var MockAWSProviderFunc AWSProviderFunc = func(ctx context.Context) (AWSProviderer, error) { ... }

+ var NewAWSProviderFunc AWSProviderFunc = func(ctx context.Context) (AWSProviderer, error) { ... }

+ type AWSProviderer interface

+ GetEC2Client func() (EC2Clienter, error)

+ GetLatestUbuntuImage func(context.Context, string) (*types.Image, error)

+ SetEC2Client func(EC2Clienter)

+ type ConfigInterfacer interface

+ GetString func(key string) string

+ type ConfigWrapper struct

+ func NewConfigWrapper(config aws.Config) *ConfigWrapper

+ func (cw *ConfigWrapper) GetString(key string) string

+ type EC2Clienter interface

+ CreateSubnet func(ctx context.Context, params *ec2.CreateSubnetInput, ...) (*ec2.CreateSubnetOutput, error)

+ CreateVpc func(ctx context.Context, params *ec2.CreateVpcInput, optFns ...func(*ec2.Options)) (*ec2.CreateVpcOutput, error)

+ DeleteSecurityGroup func(ctx context.Context, params *ec2.DeleteSecurityGroupInput, ...) (*ec2.DeleteSecurityGroupOutput, error)

+ DeleteSubnet func(ctx context.Context, params *ec2.DeleteSubnetInput, ...) (*ec2.DeleteSubnetOutput, error)

+ DeleteVpc func(ctx context.Context, params *ec2.DeleteVpcInput, optFns ...func(*ec2.Options)) (*ec2.DeleteVpcOutput, error)

+ DescribeImages func(ctx context.Context, params *ec2.DescribeImagesInput, ...) (*ec2.DescribeImagesOutput, error)

+ DescribeInstances func(ctx context.Context, params *ec2.DescribeInstancesInput, ...) (*ec2.DescribeInstancesOutput, error)

+ DescribeSecurityGroups func(ctx context.Context, params *ec2.DescribeSecurityGroupsInput, ...) (*ec2.DescribeSecurityGroupsOutput, error)

+ DescribeSubnets func(ctx context.Context, params *ec2.DescribeSubnetsInput, ...) (*ec2.DescribeSubnetsOutput, error)

+ DescribeVpcs func(ctx context.Context, params *ec2.DescribeVpcsInput, ...) (*ec2.DescribeVpcsOutput, error)

+ RunInstances func(ctx context.Context, params *ec2.RunInstancesInput, ...) (*ec2.RunInstancesOutput, error)

+ TerminateInstances func(ctx context.Context, params *ec2.TerminateInstancesInput, ...) (*ec2.TerminateInstancesOutput, error)

+ func NewEC2Client(ctx context.Context) (EC2Clienter, error)

+ type MockAWSProvider struct

+ Config aws.Config

+ EC2Client EC2Clienter

+ func (m *MockAWSProvider) GetEC2Client() (EC2Clienter, error)

+ func (m *MockAWSProvider) GetLatestUbuntuImage(ctx context.Context, region string) (*types.Image, error)

+ func (m *MockAWSProvider) SetEC2Client(client EC2Clienter)

+ type MockEC2Client struct

+ func (m *MockEC2Client) AuthorizeSecurityGroupIngress(ctx context.Context, params *ec2.AuthorizeSecurityGroupIngressInput, ...) (*ec2.AuthorizeSecurityGroupIngressOutput, error)

+ func (m *MockEC2Client) CreateSecurityGroup(ctx context.Context, params *ec2.CreateSecurityGroupInput, ...) (*ec2.CreateSecurityGroupOutput, error)

+ func (m *MockEC2Client) CreateSubnet(ctx context.Context, params *ec2.CreateSubnetInput, ...) (*ec2.CreateSubnetOutput, error)

+ func (m *MockEC2Client) CreateVpc(ctx context.Context, params *ec2.CreateVpcInput, optFns ...func(*ec2.Options)) (*ec2.CreateVpcOutput, error)

+ func (m *MockEC2Client) DeleteSecurityGroup(ctx context.Context, params *ec2.DeleteSecurityGroupInput, ...) (*ec2.DeleteSecurityGroupOutput, error)

+ func (m *MockEC2Client) DeleteSubnet(ctx context.Context, params *ec2.DeleteSubnetInput, ...) (*ec2.DeleteSubnetOutput, error)

+ func (m *MockEC2Client) DeleteVpc(ctx context.Context, params *ec2.DeleteVpcInput, optFns ...func(*ec2.Options)) (*ec2.DeleteVpcOutput, error)

+ func (m *MockEC2Client) DescribeImages(ctx context.Context, params *ec2.DescribeImagesInput, ...) (*ec2.DescribeImagesOutput, error)

+ func (m *MockEC2Client) DescribeInstances(ctx context.Context, params *ec2.DescribeInstancesInput, ...) (*ec2.DescribeInstancesOutput, error)

+ func (m *MockEC2Client) DescribeSecurityGroups(ctx context.Context, params *ec2.DescribeSecurityGroupsInput, ...) (*ec2.DescribeSecurityGroupsOutput, error)

+ func (m *MockEC2Client) DescribeSubnets(ctx context.Context, params *ec2.DescribeSubnetsInput, ...) (*ec2.DescribeSubnetsOutput, error)

+ func (m *MockEC2Client) DescribeVpcs(ctx context.Context, params *ec2.DescribeVpcsInput, ...) (*ec2.DescribeVpcsOutput, error)

+ func (m *MockEC2Client) GetLatestUbuntuImage(ctx context.Context, region string) (*types.Image, error)

+ func (m *MockEC2Client) RunInstances(ctx context.Context, params *ec2.RunInstancesInput, ...) (*ec2.RunInstancesOutput, error)

+ func (m *MockEC2Client) TerminateInstances(ctx context.Context, params *ec2.TerminateInstancesInput, ...) (*ec2.TerminateInstancesOutput, error)

+ type ResourceInfo struct

+ ID string

+ InstanceID string

+ PrivateIP string

+ PublicIP string

+ Region string

+ Status string

+ Type string

+ Zone string

+ type SpotInstanceConfig struct

+ InstanceType string

+ KeyPairName string

+ VPCCIDRBlock string

+ VPCTagKey string

+ VPCTagValue string

+ type Status struct

+ ID string