aws

Documentation

Index

• type AWSClient
  • func NewAWSClient(ec2 *ec2.EC2) AWSClient
• type Client
  • func NewClient(awsClient AWSClient, vpcName string, options ...OptionFunc) Client
• type OptionFunc
  • func Clock(clock clock.Clock) OptionFunc
  • func Timeout(timeout time.Duration) OptionFunc
• type UpgradeOpsMan
  • func NewUpgradeOpsMan(client Client) *UpgradeOpsMan
  • func (s *UpgradeOpsMan) Upgrade(name, ami, instanceType, ip string) error

Types

type AWSClient

type AWSClient interface {
	List(instanceNameRegex, vpcName string) ([]*ec2.Instance, error)
	Stop(instanceID string) error
	Delete(instanceID string) error
	Create(ami, vmType, name, keyPairName, subnetID, securityGroupID string) (*ec2.Instance, error)
	AssociateElasticIP(instanceID, elasticIP string) error
}

func NewAWSClient

func NewAWSClient(ec2 *ec2.EC2) AWSClient

type Client

type Client interface {
	CreateVM(ami, instanceType, name, keyName, subnetID, securityGroupID string) (*ec2.Instance, error)
	DeleteVM(instanceID string) error
	GetVMInfo(name string) (*ec2.Instance, error)
	StopVM(instance ec2.Instance) error
	AssignPublicIP(instance ec2.Instance, ip string) error
	WaitForStartedVM(instanceName string) error
}

func NewClient

func NewClient(
	awsClient AWSClient,
	vpcName string,
	options ...OptionFunc,
) Client

type OptionFunc

type OptionFunc func(*client)

func Clock

func Clock(clock clock.Clock) OptionFunc

func Timeout

func Timeout(timeout time.Duration) OptionFunc

type UpgradeOpsMan

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

func NewUpgradeOpsMan

func NewUpgradeOpsMan(client Client) *UpgradeOpsMan

func (*UpgradeOpsMan) Upgrade

func (s *UpgradeOpsMan) Upgrade(name, ami, instanceType, ip string) error