amazon

package
v2.0.0-rc.3+incompatible Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Dec 13, 2018 License: Apache-2.0 Imports: 27 Imported by: 4

Documentation

Index

Constants

View Source 
const DeleteClusterMachinesStepName = "aws_delete_cluster_machines"
View Source 
const DeleteInternetGatewayStepName = "aws_delete_internet_gateway"
View Source 
const DeleteKeyPairStepName = "aws_delete_key_pair"
View Source 
const DeleteNodeStepName = "aws_delete_node"
View Source 
const DeleteRouteTableStepName = "aws_delete_route_table"
View Source 
const DeleteSecurityGroupsStepName = "aws_delete_security_groups"
View Source 
const DeleteSubnetsStepName = "aws_delete_subnets"
View Source 
const DeleteVPCStepName = "aws_delete_vpc"
View Source 
const DisassociateRouteTableStepName = "aws_disassociate_route_table"
View Source 
const StepAssociateRouteTable = "associate_route_table"
View Source 
const StepCreateInternetGateway = "create_internet_gateway"
View Source 
const StepCreateRouteTable = "create_route_table"
View Source 
const StepCreateSecurityGroups = "create_security_groups_step"
View Source 
const StepCreateSubnets = "create_subnet_steps"
View Source 
const StepCreateVPC = "aws_create_vpc"
View Source 
const StepFindAMI = "find_amazon_machine_image"
View Source 
const StepImportKeyPair = "aws_import_keypair_step"
View Source 
const (
	StepNameCreateEC2Instance = "aws_create_instance"
)
View Source 
const (
	StepNameCreateInstanceProfiles = "aws_create_instance_profiles"
)

Variables

View Source 
var (
	ErrReadVPC        = errors.New("aws: can't read vpc info")
	ErrCreateVPC      = errors.New("aws: create vpc")
	ErrAuthorization  = errors.New("aws: authorization")
	ErrCreateSubnet   = errors.New("aws: create subnet")
	ErrCreateInstance = errors.New("aws: create instance")
	ErrImportKeyPair  = errors.New("aws: import keypair")
	ErrNoPublicIP     = errors.New("aws: no public IP assigned")
	ErrDeleteCluster  = errors.New("aws: delete cluster")
	ErrDeleteNode     = errors.New("aws: delete node")
)
View Source 
var (
	ErrEmptyResponse = errors.New("empty response")
)

Functions

func FindOutboundIP 

func FindOutboundIP(ctx context.Context, findExternalIP func() (string, error)) (string, error)

func GetEC2 

func GetEC2(cfg steps.AWSConfig) (ec2iface.EC2API, error)

func GetIAM 

func GetIAM(cfg steps.AWSConfig) (iamiface.IAMAPI, error)

func InitAssociateRouteTable 

func InitAssociateRouteTable(ec2fn GetEC2Fn)

InitAssociateRouteTable adds the step to the registry

func InitCreateInstanceProfiles 

func InitCreateInstanceProfiles(iamfn GetIAMFn)

func InitCreateInternetGateway 

func InitCreateInternetGateway(ec2fn GetEC2Fn)

InitCreateMachine adds the step to the registry

func InitCreateMachine 

func InitCreateMachine(ec2fn GetEC2Fn)

InitCreateMachine adds the step to the registry

func InitCreateRouteTable 

func InitCreateRouteTable(ec2fn GetEC2Fn)

InitCreateRouteTable adds the step to the registry

func InitCreateSecurityGroups 

func InitCreateSecurityGroups(fn GetEC2Fn)

func InitCreateSubnet 

func InitCreateSubnet(fn GetEC2Fn, accSvc *account.Service)

func InitCreateVPC 

func InitCreateVPC(fn GetEC2Fn)

func InitDeleteClusterMachines 

func InitDeleteClusterMachines(fn GetEC2Fn)

func InitDeleteInternetGateWay 

func InitDeleteInternetGateWay(fn GetEC2Fn)

func InitDeleteKeyPair 

func InitDeleteKeyPair(fn GetEC2Fn)

func InitDeleteNode 

func InitDeleteNode(fn GetEC2Fn)

func InitDeleteRouteTable 

func InitDeleteRouteTable(fn GetEC2Fn)

func InitDeleteSecurityGroup 

func InitDeleteSecurityGroup(fn GetEC2Fn)

func InitDeleteSubnets 

func InitDeleteSubnets(fn GetEC2Fn)

func InitDeleteVPC 

func InitDeleteVPC(fn GetEC2Fn)

func InitDisassociateRouteTable 

func InitDisassociateRouteTable(fn GetEC2Fn)

func InitFindAMI 

func InitFindAMI(fn GetEC2Fn)

func InitImportKeyPair 

func InitImportKeyPair(fn GetEC2Fn)

InitImportKeyPair add the step to the registry

Types

type AssociateRouteTableStep 

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

func NewAssociateRouteTableStep 

func NewAssociateRouteTableStep(ec2fn GetEC2Fn) *AssociateRouteTableStep

func (*AssociateRouteTableStep) Depends 

func (*AssociateRouteTableStep) Depends() []string

func (*AssociateRouteTableStep) Description 

func (*AssociateRouteTableStep) Description() string

func (*AssociateRouteTableStep) Name 

func (*AssociateRouteTableStep) Name() string

func (*AssociateRouteTableStep) Rollback 

func (s *AssociateRouteTableStep) Rollback(ctx context.Context, w io.Writer, cfg *steps.Config) error

func (*AssociateRouteTableStep) Run 

func (s *AssociateRouteTableStep) Run(ctx context.Context, w io.Writer, cfg *steps.Config) error

type Associater 

type Associater interface {
	AssociateRouteTable(*ec2.AssociateRouteTableInput) (*ec2.AssociateRouteTableOutput, error)
}

type CreateInternetGatewayStep 

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

func NewCreateInternetGatewayStep 

func NewCreateInternetGatewayStep(ec2fn GetEC2Fn) *CreateInternetGatewayStep

func (*CreateInternetGatewayStep) Depends 

func (*CreateInternetGatewayStep) Depends() []string

func (*CreateInternetGatewayStep) Description 

func (*CreateInternetGatewayStep) Description() string

func (*CreateInternetGatewayStep) Name 

func (*CreateInternetGatewayStep) Name() string

func (*CreateInternetGatewayStep) Rollback 

func (s *CreateInternetGatewayStep) Rollback(ctx context.Context, w io.Writer, cfg *steps.Config) error

func (*CreateInternetGatewayStep) Run 

func (s *CreateInternetGatewayStep) Run(ctx context.Context, w io.Writer, cfg *steps.Config) error

type CreateRouteTableStep 

type CreateRouteTableStep struct {
	GetEC2 GetEC2Fn
	// contains filtered or unexported fields
}

func NewCreateRouteTableStep 

func NewCreateRouteTableStep(ec2fn GetEC2Fn) *CreateRouteTableStep

func (*CreateRouteTableStep) Depends 

func (*CreateRouteTableStep) Depends() []string

func (*CreateRouteTableStep) Description 

func (*CreateRouteTableStep) Description() string

func (*CreateRouteTableStep) Name 

func (*CreateRouteTableStep) Name() string

func (*CreateRouteTableStep) Rollback 

func (s *CreateRouteTableStep) Rollback(ctx context.Context, w io.Writer, cfg *steps.Config) error

func (*CreateRouteTableStep) Run 

func (s *CreateRouteTableStep) Run(ctx context.Context, w io.Writer, cfg *steps.Config) error

type CreateSecurityGroupsStep 

type CreateSecurityGroupsStep struct {
	GetEC2 GetEC2Fn
}

func NewCreateSecurityGroupsStep 

func NewCreateSecurityGroupsStep(fn GetEC2Fn) *CreateSecurityGroupsStep

func (*CreateSecurityGroupsStep) Depends 

func (*CreateSecurityGroupsStep) Depends() []string

func (*CreateSecurityGroupsStep) Description 

func (*CreateSecurityGroupsStep) Description() string

func (*CreateSecurityGroupsStep) Name 

func (*CreateSecurityGroupsStep) Name() string

func (*CreateSecurityGroupsStep) Rollback 

func (*CreateSecurityGroupsStep) Rollback(context.Context, io.Writer, *steps.Config) error

func (*CreateSecurityGroupsStep) Run 

func (s *CreateSecurityGroupsStep) Run(ctx context.Context, w io.Writer, cfg *steps.Config) error

type CreateSubnetsStep 

type CreateSubnetsStep struct {
	GetEC2 GetEC2Fn
	// contains filtered or unexported fields
}

func NewCreateSubnetStep 

func NewCreateSubnetStep(fn GetEC2Fn, accSvc *account.Service) *CreateSubnetsStep

func (*CreateSubnetsStep) Depends 

func (*CreateSubnetsStep) Depends() []string

func (*CreateSubnetsStep) Description 

func (*CreateSubnetsStep) Description() string

func (*CreateSubnetsStep) Name 

func (*CreateSubnetsStep) Name() string

func (*CreateSubnetsStep) Rollback 

func (*CreateSubnetsStep) Rollback(context.Context, io.Writer, *steps.Config) error

func (*CreateSubnetsStep) Run 

func (s *CreateSubnetsStep) Run(ctx context.Context, w io.Writer, cfg *steps.Config) error

type CreateVPCStep 

type CreateVPCStep struct {
	GetEC2 GetEC2Fn
}

CreateVPCStep represents creation of an virtual private cloud in AWS

func NewCreateVPCStep 

func NewCreateVPCStep(fn GetEC2Fn) *CreateVPCStep

func (*CreateVPCStep) Depends 

func (*CreateVPCStep) Depends() []string

func (*CreateVPCStep) Description 

func (*CreateVPCStep) Description() string

func (*CreateVPCStep) Name 

func (*CreateVPCStep) Name() string

func (*CreateVPCStep) Rollback 

func (*CreateVPCStep) Rollback(context.Context, io.Writer, *steps.Config) error

func (*CreateVPCStep) Run 

func (c *CreateVPCStep) Run(ctx context.Context, w io.Writer, cfg *steps.Config) error

type DeleteClusterMachines 

type DeleteClusterMachines struct {
	GetEC2 GetEC2Fn
}

func (*DeleteClusterMachines) Depends 

func (*DeleteClusterMachines) Depends() []string

func (*DeleteClusterMachines) Description 

func (*DeleteClusterMachines) Description() string

func (*DeleteClusterMachines) Name 

func (*DeleteClusterMachines) Name() string

func (*DeleteClusterMachines) Rollback 

func (*DeleteClusterMachines) Rollback(context.Context, io.Writer, *steps.Config) error

func (*DeleteClusterMachines) Run 

func (s *DeleteClusterMachines) Run(ctx context.Context, w io.Writer, cfg *steps.Config) error

type DeleteInternetGateway 

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

func NewDeleteInernetGateway 

func NewDeleteInernetGateway(fn GetEC2Fn) *DeleteInternetGateway

func (*DeleteInternetGateway) Depends 

func (*DeleteInternetGateway) Depends() []string

func (*DeleteInternetGateway) Description 

func (*DeleteInternetGateway) Description() string

func (*DeleteInternetGateway) Name 

func (*DeleteInternetGateway) Name() string

func (*DeleteInternetGateway) Rollback 

func (*DeleteInternetGateway) Rollback(context.Context, io.Writer, *steps.Config) error

func (*DeleteInternetGateway) Run 

func (s *DeleteInternetGateway) Run(ctx context.Context, w io.Writer, cfg *steps.Config) error

type DeleteKeyPair 

type DeleteKeyPair struct {
	GetEC2 GetEC2Fn
	// contains filtered or unexported fields
}

func NewDeleteKeyPairStep 

func NewDeleteKeyPairStep(fn GetEC2Fn) *DeleteKeyPair

func (*DeleteKeyPair) Depends 

func (*DeleteKeyPair) Depends() []string

func (*DeleteKeyPair) Description 

func (*DeleteKeyPair) Description() string

func (*DeleteKeyPair) Name 

func (*DeleteKeyPair) Name() string

func (*DeleteKeyPair) Rollback 

func (*DeleteKeyPair) Rollback(context.Context, io.Writer, *steps.Config) error

func (*DeleteKeyPair) Run 

func (s *DeleteKeyPair) Run(ctx context.Context, w io.Writer, cfg *steps.Config) error

type DeleteNodeStep 

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

func NewDeleteNode 

func NewDeleteNode(fn GetEC2Fn) *DeleteNodeStep

func (*DeleteNodeStep) Depends 

func (*DeleteNodeStep) Depends() []string

func (*DeleteNodeStep) Description 

func (*DeleteNodeStep) Description() string

func (*DeleteNodeStep) Name 

func (*DeleteNodeStep) Name() string

func (*DeleteNodeStep) Rollback 

func (*DeleteNodeStep) Rollback(context.Context, io.Writer, *steps.Config) error

func (*DeleteNodeStep) Run 

func (s *DeleteNodeStep) Run(ctx context.Context, w io.Writer, cfg *steps.Config) error

type DeleteRouteTable 

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

func NewDeleteRouteTableStep 

func NewDeleteRouteTableStep(fn GetEC2Fn) *DeleteRouteTable

func (*DeleteRouteTable) Depends 

func (*DeleteRouteTable) Depends() []string

func (*DeleteRouteTable) Description 

func (*DeleteRouteTable) Description() string

func (*DeleteRouteTable) Name 

func (*DeleteRouteTable) Name() string

func (*DeleteRouteTable) Rollback 

func (*DeleteRouteTable) Rollback(context.Context, io.Writer, *steps.Config) error

func (*DeleteRouteTable) Run 

func (s *DeleteRouteTable) Run(ctx context.Context, w io.Writer, cfg *steps.Config) error

type DeleteSecurityGroup 

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

func NewDeleteSecurityGroupService 

func NewDeleteSecurityGroupService(fn GetEC2Fn) *DeleteSecurityGroup

func (*DeleteSecurityGroup) Depends 

func (*DeleteSecurityGroup) Depends() []string

func (*DeleteSecurityGroup) Description 

func (*DeleteSecurityGroup) Description() string

func (*DeleteSecurityGroup) Name 

func (*DeleteSecurityGroup) Name() string

func (*DeleteSecurityGroup) Rollback 

func (*DeleteSecurityGroup) Rollback(context.Context, io.Writer, *steps.Config) error

func (*DeleteSecurityGroup) Run 

func (s *DeleteSecurityGroup) Run(ctx context.Context, w io.Writer, cfg *steps.Config) error

type DeleteSubnets 

type DeleteSubnets struct {
	GetEC2 GetEC2Fn
	// contains filtered or unexported fields
}

func NewDeleteSubnets 

func NewDeleteSubnets(fn GetEC2Fn) *DeleteSubnets

func (*DeleteSubnets) Depends 

func (*DeleteSubnets) Depends() []string

func (*DeleteSubnets) Description 

func (*DeleteSubnets) Description() string

func (*DeleteSubnets) Name 

func (*DeleteSubnets) Name() string

func (*DeleteSubnets) Rollback 

func (*DeleteSubnets) Rollback(context.Context, io.Writer, *steps.Config) error

func (*DeleteSubnets) Run 

func (s *DeleteSubnets) Run(ctx context.Context, w io.Writer, cfg *steps.Config) error

type DeleteVPC 

type DeleteVPC struct {
	GetEC2 GetEC2Fn
	// contains filtered or unexported fields
}

func NewDeleteVPC 

func NewDeleteVPC(fn GetEC2Fn) *DeleteVPC

func (*DeleteVPC) Depends 

func (*DeleteVPC) Depends() []string

func (*DeleteVPC) Description 

func (*DeleteVPC) Description() string

func (*DeleteVPC) Name 

func (*DeleteVPC) Name() string

func (*DeleteVPC) Rollback 

func (*DeleteVPC) Rollback(context.Context, io.Writer, *steps.Config) error

func (*DeleteVPC) Run 

func (s *DeleteVPC) Run(ctx context.Context, w io.Writer, cfg *steps.Config) error

type DisassociateRouteTable 

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

func NewDisassociateRouteTableStep 

func NewDisassociateRouteTableStep(fn GetEC2Fn) *DisassociateRouteTable

func (*DisassociateRouteTable) Depends 

func (*DisassociateRouteTable) Depends() []string

func (*DisassociateRouteTable) Description 

func (*DisassociateRouteTable) Description() string

func (*DisassociateRouteTable) Name 

func (*DisassociateRouteTable) Name() string

func (*DisassociateRouteTable) Rollback 

func (*DisassociateRouteTable) Rollback(context.Context, io.Writer, *steps.Config) error

func (*DisassociateRouteTable) Run 

func (s *DisassociateRouteTable) Run(ctx context.Context, w io.Writer, cfg *steps.Config) error

type DisassociateService 

type DisassociateService interface {
	DisassociateRouteTable(*ec2.DisassociateRouteTableInput) (*ec2.DisassociateRouteTableOutput, error)
}

type FindAMIStep 

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

func NewFindAMIStep 

func NewFindAMIStep(fn GetEC2Fn) *FindAMIStep

func (*FindAMIStep) Depends 

func (*FindAMIStep) Depends() []string

func (*FindAMIStep) Description 

func (*FindAMIStep) Description() string

func (*FindAMIStep) FindAMI 

func (s *FindAMIStep) FindAMI(ctx context.Context, w io.Writer, finder ImageFinder) (string, error)

func (*FindAMIStep) Name 

func (*FindAMIStep) Name() string

func (*FindAMIStep) Rollback 

func (*FindAMIStep) Rollback(context.Context, io.Writer, *steps.Config) error

func (*FindAMIStep) Run 

func (s *FindAMIStep) Run(ctx context.Context, w io.Writer, cfg *steps.Config) error

type GetEC2Fn 

type GetEC2Fn func(steps.AWSConfig) (ec2iface.EC2API, error)

type GetIAMFn 

type GetIAMFn func(steps.AWSConfig) (iamiface.IAMAPI, error)

type IGWDeleter 

type IGWDeleter interface {
	DetachInternetGateway(*ec2.DetachInternetGatewayInput) (*ec2.DetachInternetGatewayOutput, error)
	DeleteInternetGateway(*ec2.DeleteInternetGatewayInput) (*ec2.DeleteInternetGatewayOutput, error)
}

type ImageFinder 

type ImageFinder interface {
	DescribeImagesWithContext(aws.Context, *ec2.DescribeImagesInput,
		...request.Option) (*ec2.DescribeImagesOutput, error)
}

type InternetGatewayCreater 

type InternetGatewayCreater interface {
	CreateInternetGateway(*ec2.CreateInternetGatewayInput) (*ec2.CreateInternetGatewayOutput, error)
	CreateTags(*ec2.CreateTagsInput) (*ec2.CreateTagsOutput, error)
	AttachInternetGateway(*ec2.AttachInternetGatewayInput) (*ec2.AttachInternetGatewayOutput, error)
}

type KeyPairStep 

type KeyPairStep struct {
	GetEC2 GetEC2Fn
	// contains filtered or unexported fields
}

KeyPairStep represents creation of keypair in aws since there is hard cap on keypairs per account supergiant will create one per cluster

func NewImportKeyPairStep 

func NewImportKeyPairStep(fn GetEC2Fn) *KeyPairStep

func (*KeyPairStep) Depends 

func (*KeyPairStep) Depends() []string

func (*KeyPairStep) Description 

func (*KeyPairStep) Description() string

func (*KeyPairStep) Name 

func (*KeyPairStep) Name() string

func (*KeyPairStep) Rollback 

func (s *KeyPairStep) Rollback(ctx context.Context, w io.Writer, cfg *steps.Config) error

func (*KeyPairStep) Run 

func (s *KeyPairStep) Run(ctx context.Context, w io.Writer, cfg *steps.Config) error

Verifies that a key exists,

type KeyService 

type KeyService interface {
	DeleteKeyPair(*ec2.DeleteKeyPairInput) (*ec2.DeleteKeyPairOutput, error)
}

type Service 

type Service interface {
	CreateRouteTable(*ec2.CreateRouteTableInput) (*ec2.CreateRouteTableOutput, error)
	CreateTags(*ec2.CreateTagsInput) (*ec2.CreateTagsOutput, error)
	CreateRoute(*ec2.CreateRouteInput) (*ec2.CreateRouteOutput, error)
}

type StepCreateInstance 

type StepCreateInstance struct {
	GetEC2 GetEC2Fn
}

func NewCreateInstance 

func NewCreateInstance(ec2fn GetEC2Fn) *StepCreateInstance

func (*StepCreateInstance) Depends 

func (*StepCreateInstance) Depends() []string

func (*StepCreateInstance) Description 

func (*StepCreateInstance) Description() string

func (*StepCreateInstance) Name 

func (*StepCreateInstance) Name() string

func (*StepCreateInstance) Rollback 

func (s *StepCreateInstance) Rollback(ctx context.Context, w io.Writer, cfg *steps.Config) error

func (*StepCreateInstance) Run 

func (s *StepCreateInstance) Run(ctx context.Context, w io.Writer, cfg *steps.Config) error

type StepCreateInstanceProfiles 

type StepCreateInstanceProfiles struct {
	GetIAM GetIAMFn
}

func NewCreateInstanceProfiles 

func NewCreateInstanceProfiles(iamfn GetIAMFn) *StepCreateInstanceProfiles

func (StepCreateInstanceProfiles) Depends 

func (StepCreateInstanceProfiles) Depends() []string

func (StepCreateInstanceProfiles) Description 

func (StepCreateInstanceProfiles) Description() string

func (StepCreateInstanceProfiles) Name 

func (StepCreateInstanceProfiles) Name() string

func (StepCreateInstanceProfiles) Rollback 

func (s StepCreateInstanceProfiles) Rollback(ctx context.Context, w io.Writer, cfg *steps.Config) error

func (StepCreateInstanceProfiles) Run 

func (s StepCreateInstanceProfiles) Run(ctx context.Context, w io.Writer, cfg *steps.Config) error

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.