aws

Documentation

Index

• func CreateBucket(session *session.Session, bucketName, acl string) (*s3.CreateBucketOutput, error)
• func CreateBucketIfNotExists(session *session.Session, bucketName, acl string) (*s3.CreateBucketOutput, error)
• func GetParameter(session *session.Session, name string, withDecryption bool) (string, error)
• func GetPrivateKeyFromParameter(session *session.Session, name string) (*ecdsa.PrivateKey, error)
• func RestartTasksMatchingServiceName(session *session.Session, cluster, matchName string) error
• func UploadToBucket(session *session.Session, fileContent io.ReadSeeker, ...) (*s3manager.UploadOutput, error)
• func WaitUntilBucketExists(session *session.Session, bucketName string) error

Functions

func CreateBucket

func CreateBucket(session *session.Session, bucketName, acl string) (*s3.CreateBucketOutput, error)

CreateBucket to create a new bucket

func CreateBucketIfNotExists

func CreateBucketIfNotExists(session *session.Session, bucketName, acl string) (*s3.CreateBucketOutput, error)

createBucketIfNotExists to either create a bucket, or return nil, nil if the bucket already exists

func GetParameter

func GetParameter(session *session.Session, name string, withDecryption bool) (string, error)

GetParameter to fetch a value from AWS parameter store

func GetPrivateKeyFromParameter

func GetPrivateKeyFromParameter(session *session.Session, name string) (*ecdsa.PrivateKey, error)

GetPrivateKeyFromParameter to fetch and decode a private key from AWS parameter store

func RestartTasksMatchingServiceName

func RestartTasksMatchingServiceName(session *session.Session, cluster, matchName string) error

RestartTasksMatchingServiceName to restart tasks created by services containing `matchName` in their names using `StopTask`

func UploadToBucket

func UploadToBucket(session *session.Session, fileContent io.ReadSeeker, fileName, bucketName string) (*s3manager.UploadOutput, error)

UploadToBucket to put a file in a bucket

func WaitUntilBucketExists

func WaitUntilBucketExists(session *session.Session, bucketName string) error

WaitUntilBucketExists to return nil if a bucket exists, or hang for the timeout interval then error