aws

package
v0.0.12 Latest Latest
Warning

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

 Go to latest Published: Jul 3, 2020 License: Apache-2.0 Imports: 24 Imported by: 1

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func CheckConnection 

func CheckConnection(endpointURL string) error

func GetMetadata 

func GetMetadata(p string) (string, error)

This function grabs the ec2 metadata for the local machine that milpa is running on. However, if milpa is not running within AWS the standard AWS metadata query hangs for about 15s. I tried modifiying the AWS HTTP client timeout but that didn't work so we'll just use our own client.

func MakeFamilyPrefix 

func MakeFamilyPrefix(controllerID string) string

func SecurityContextToUserGroup 

func SecurityContextToUserGroup(sc *api.SecurityContext) *string

func SplitTaskDef 

func SplitTaskDef(taskDef, controllerID string) (string, int)

Types

type AwsEC2 

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

func NewEC2Client 

func NewEC2Client(config EC2ClientConfig) (*AwsEC2, error)

Parsing our server.json configuration should have put all confg into environment variables, load necessary config from there.

func (*AwsEC2) AddInstanceTags 

func (e *AwsEC2) AddInstanceTags(iid string, labels map[string]string) error

Tagging with user lables is a best effort, in other words, we allow this to generate errors but will try to continue with tagging if the user breaks some tag constraints.

func (*AwsEC2) AddRoute 

func (e *AwsEC2) AddRoute(destinationCIDR, instanceID string) error

func (*AwsEC2) AssignInstanceProfile 

func (e *AwsEC2) AssignInstanceProfile(node *api.Node, instanceProfile string) error

func (*AwsEC2) AttachSecurityGroups 

func (e *AwsEC2) AttachSecurityGroups(node *api.Node, groups []string) error

func (*AwsEC2) CloudStatusKeeper 

func (c *AwsEC2) CloudStatusKeeper() cloud.StatusKeeper

func (*AwsEC2) ConnectWithPublicIPs 

func (e *AwsEC2) ConnectWithPublicIPs() bool

func (*AwsEC2) ControllerInsideVPC 

func (e *AwsEC2) ControllerInsideVPC() bool

func (*AwsEC2) CreateSGName 

func (e *AwsEC2) CreateSGName(svcName string) string

func (*AwsEC2) CreateSecurityGroup 

func (e *AwsEC2) CreateSecurityGroup(sgName string, ports []cloud.InstancePort, sourceRanges []string) (*cloud.SecurityGroup, error)

func (*AwsEC2) DeleteSecurityGroup 

func (e *AwsEC2) DeleteSecurityGroup(groupID string) error

In non-default VPC, docs say you can only delete Groups by ID.

func (*AwsEC2) DeregisterTaskDefinition 

func (c *AwsEC2) DeregisterTaskDefinition(taskARN string) error

func (*AwsEC2) EnsureContainerInstanceCluster 

func (c *AwsEC2) EnsureContainerInstanceCluster() error

func (*AwsEC2) EnsureMilpaSecurityGroups 

func (c *AwsEC2) EnsureMilpaSecurityGroups(extraCIDRs, extraGroupIDs []string) error

func (*AwsEC2) EnsureSecurityGroup 

func (e *AwsEC2) EnsureSecurityGroup(sgName string, ports []cloud.InstancePort, sourceRanges []string) (*cloud.SecurityGroup, error)

Notice this calls findSecurityGroup twice, not the most efficient... Currently this is only used to set up the milpa security group. If it's used more, we'll need to do something else (possibly return the changes from UpdateSecurityGroup and see if we need to re-fetch the SG.

func (*AwsEC2) FindSecurityGroup 

func (e *AwsEC2) FindSecurityGroup(sgName string) (*cloud.SecurityGroup, error)

func (*AwsEC2) GetAttributes 

func (m *AwsEC2) GetAttributes() cloud.CloudAttributes

func (*AwsEC2) GetAvailabilityZones 

func (az *AwsEC2) GetAvailabilityZones() ([]string, error)

func (*AwsEC2) GetBootSecurityGroupIDs 

func (c *AwsEC2) GetBootSecurityGroupIDs() []string

func (*AwsEC2) GetContainerInstancesStatuses 

func (c *AwsEC2) GetContainerInstancesStatuses(taskARNs []string) (map[string][]api.UnitStatus, error)

func (*AwsEC2) GetDNSInfo 

func (e *AwsEC2) GetDNSInfo() ([]string, []string, error)

func (*AwsEC2) GetImage added in v0.0.3 

func (e *AwsEC2) GetImage(spec cloud.BootImageSpec) (cloud.Image, error)

func (*AwsEC2) GetRegistryAuth 

func (e *AwsEC2) GetRegistryAuth() (string, string, error)

func (*AwsEC2) GetSubnets 

func (e *AwsEC2) GetSubnets() ([]cloud.SubnetAttributes, error)

func (*AwsEC2) GetVPCCIDRs 

func (c *AwsEC2) GetVPCCIDRs() []string

func (*AwsEC2) IsAvailable 

func (az *AwsEC2) IsAvailable() (bool, error)

func (*AwsEC2) ListContainerInstances 

func (c *AwsEC2) ListContainerInstances() ([]cloud.ContainerInstance, error)

func (*AwsEC2) ListContainerInstancesFilterID 

func (c *AwsEC2) ListContainerInstancesFilterID(taskARNs []string) ([]cloud.ContainerInstance, error)

func (*AwsEC2) ListInstances 

func (e *AwsEC2) ListInstances() ([]cloud.CloudInstance, error)

func (*AwsEC2) ListInstancesFilterID 

func (e *AwsEC2) ListInstancesFilterID(ids []string) ([]cloud.CloudInstance, error)

func (*AwsEC2) ListTaskDefinitions 

func (c *AwsEC2) ListTaskDefinitions() ([]string, error)

func (*AwsEC2) ModifySourceDestinationCheck 

func (e *AwsEC2) ModifySourceDestinationCheck(instanceID string, isEnabled bool) error

func (*AwsEC2) RemoveRoute 

func (e *AwsEC2) RemoveRoute(destinationCIDR, instanceID string) error

func (*AwsEC2) ResizeVolume 

func (e *AwsEC2) ResizeVolume(node *api.Node, size int64) (error, bool)

func (*AwsEC2) SetBootSecurityGroupIDs 

func (c *AwsEC2) SetBootSecurityGroupIDs(ids []string)

func (*AwsEC2) SetSustainedCPU 

func (e *AwsEC2) SetSustainedCPU(node *api.Node, enabled bool) error

func (*AwsEC2) StartContainerInstance 

func (c *AwsEC2) StartContainerInstance(pod *api.Pod) (string, error)

func (*AwsEC2) StartNode 

func (e *AwsEC2) StartNode(node *api.Node, image cloud.Image, metadata string) (*cloud.StartNodeResult, error)

func (*AwsEC2) StartSpotNode 

func (e *AwsEC2) StartSpotNode(node *api.Node, image cloud.Image, metadata string) (*cloud.StartNodeResult, error)

This isn't terribly different from Start node but there are some minor differences. We'll capture errors correctly here and there

func (*AwsEC2) StopContainerInstance 

func (c *AwsEC2) StopContainerInstance(containerInstanceID string) error

func (*AwsEC2) StopInstance 

func (e *AwsEC2) StopInstance(instanceID string) error

func (*AwsEC2) UpdateSecurityGroup 

func (e *AwsEC2) UpdateSecurityGroup(cloudSG cloud.SecurityGroup, specPorts []cloud.InstancePort, sourceRanges []string) error

go through and figure out what rules need to be deleted and what rules need to be added in order to make our security group match the spec the user has asked for. We do the merge instead of deleting everything and re-adding because we don't want to delete existing rules that aren't changing sincec services might depend on those rules. We have to be careful because AWS doesn't allow duplicate rules to exist (but does allow overlapping rules)

func (*AwsEC2) WaitForContainerInstanceRunning 

func (c *AwsEC2) WaitForContainerInstanceRunning(pod *api.Pod) (*api.Pod, error)

func (*AwsEC2) WaitForRunning 

func (e *AwsEC2) WaitForRunning(node *api.Node) ([]api.NetworkAddress, error)

type EC2ClientConfig added in v0.0.6 

type EC2ClientConfig struct {
	ControllerID   string
	Nametag        string
	VPCID          string
	SubnetID       string
	ECSClusterName string
	PrivateIPOnly  bool
	EndpointURL    string
}

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.