pkg

Documentation

Index

• func DNSResolves(apiDNS string)
• func DownloadFromS3(svc s3iface.S3API, bucket string, key string, path string) error
• func DownloadMapFromS3(svc s3iface.S3API, bucket string, keyPath *map[string]string) error
• func ExistsOnS3(svc s3iface.S3API, bucket string, keyPath *map[string]string) (bool, error)
• func GetAutoscalingGroup(svc autoscalingiface.AutoScalingAPI, groupName string) (*autoscaling.Group, error)
• func GetAutoscalingGroupName(svc autoscalingiface.AutoScalingAPI, instanceID string) (string, error)
• func GetAutoscalingInstances(group *autoscaling.Group) []string
• func GetInstanceID(svc *ec2metadata.EC2Metadata) (string, error)
• func GetRegion(svc *ec2metadata.EC2Metadata) (string, error)
• func KubeUp(apiDNS string, apiPort int) bool
• func UploadMapToS3(svc s3iface.S3API, bucket string, keyPath *map[string]string) error
• func UploadToS3(svc s3iface.S3API, bucket string, key string, path string) error
• func WaitTillCapacityReached(group *autoscaling.Group, timeout time.Duration) error

Functions

func DNSResolves

func DNSResolves(apiDNS string)

DNSResolves checks if the domain resultion works

func DownloadFromS3

func DownloadFromS3(svc s3iface.S3API, bucket string, key string, path string) error

DownloadFromS3 gets the kube pki from s3

func DownloadMapFromS3

func DownloadMapFromS3(svc s3iface.S3API, bucket string, keyPath *map[string]string) error

DownloadMapFromS3 gets a map describing keys from s3 and downloads them to a path

func ExistsOnS3

func ExistsOnS3(svc s3iface.S3API, bucket string, keyPath *map[string]string) (bool, error)

ExistsOnS3 determines if the kube pki is on s3

func GetAutoscalingGroup

func GetAutoscalingGroup(svc autoscalingiface.AutoScalingAPI, groupName string) (*autoscaling.Group, error)

GetAutoscalingGroup gets the autoscaling group of the instance from the name of the autoscaling group

func GetAutoscalingGroupName

func GetAutoscalingGroupName(svc autoscalingiface.AutoScalingAPI, instanceID string) (string, error)

GetAutoscalingGroupName gets the autoscaling group name the instance is belonging to

func GetAutoscalingInstances

func GetAutoscalingInstances(group *autoscaling.Group) []string

GetAutoscalingInstances gets all instances in an autoscaling group

func GetInstanceID

func GetInstanceID(svc *ec2metadata.EC2Metadata) (string, error)

GetInstanceID returns the EC2 instance name

func GetRegion

func GetRegion(svc *ec2metadata.EC2Metadata) (string, error)

GetRegion returns the region the instance is running in

func KubeUp

func KubeUp(apiDNS string, apiPort int) bool

KubeUp checks if kubernetes is running

func UploadMapToS3

func UploadMapToS3(svc s3iface.S3API, bucket string, keyPath *map[string]string) error

UploadMapToS3 puts a map of files to S3

func UploadToS3

func UploadToS3(svc s3iface.S3API, bucket string, key string, path string) error

UploadToS3 puts a file to s3

func WaitTillCapacityReached

func WaitTillCapacityReached(group *autoscaling.Group, timeout time.Duration) error

WaitTillCapacityReached waits until the autoscaling group is up and running