aws

Documentation

Index

• Variables
• func InGithubAction() bool
• func LambdaLogGroup(lambdaName string) string
• func TestProfile() string
• type AWS
  • func New() (*AWS, error)
  • func NewForTests(t testingI) *AWS
  • func NewFromProfile(profile string) (*AWS, error)
  • func NewWithCredentials(accessKeyID, secretAccessKey, sessionToken, region string) (*AWS, error)
  • func NewWithEndpointCredentials(endpoint, region string, token func() string) (*AWS, error)
  • func (a *AWS) APIGAtewayCloudwatchRole() (string, error)
  • func (a *AWS) AccountID() string
  • func (a *AWS) CloudFormation() *CloudFormation
  • func (a *AWS) CreateRole(name, assumeRolePolicy, policy string) (string, error)
  • func (a *AWS) Credentials() (aws.Credentials, error)
  • func (a *AWS) DeleteDynamodbTablesByTags(tags []TagFilter) error
  • func (a *AWS) FetchLogs(group string, filter string, start *int64) (chan LogEvent, error)
  • func (a *AWS) GetResourcesByTypeAndTag(resourceTypes []string, resourceTags []TagFilter) ([]string, error)
  • func (a *AWS) GetSSMParameter(path string) (string, error)
  • func (a *AWS) InvokeLambdaFunction(name string, req, rsp, clientContext interface{}) error
  • func (a *AWS) Lambda() *Lambda
  • func (a *AWS) LambdaExists(name string) (bool, error)
  • func (a *AWS) PublishToAPIGatewayConnection(domain, stage, connectionID string, data []byte) error
  • func (a *AWS) Region() string
  • func (a *AWS) Role(name string) (string, error)
  • func (a *AWS) RoleCredentials(name, role, policy string, durationSeconds int32) (*Credentials, error)
  • func (a *AWS) RoleExists(name string) (bool, error)
  • func (a *AWS) S3() *S3
  • func (a *AWS) SetAPIGatewayCloudwatchRole(arn string) error
  • func (a *AWS) TagLogGroup(name string, tags map[string]string) error
  • func (a *AWS) Try() error
  • func (a *AWS) UpdateLambdaFunctionCodeFromS3(function, bucket, key string) error
  • func (a *AWS) WaitLambdaFunctionUpdated(function string) error
• type CloudFormation
  • func (f *CloudFormation) CreateStack(name, templateBody string, resourceTags map[string]string) *StackWaiter
  • func (f *CloudFormation) DeleteStack(name string) *StackWaiter
  • func (f *CloudFormation) UpdateStack(name, templateBody string, resourceTags map[string]string) (*StackWaiter, error)
• type Credentials
• type Lambda
  • func (l *Lambda) Info(name string) (map[string]string, error)
  • func (l *Lambda) Invoke(name string, req, rsp interface{}, headers map[string]string) error
  • func (l *Lambda) SetMemory(name string, mem int) error
• type LogEvent
• type RoleNotExistsError
  • func (a *RoleNotExistsError) Error() string
• type S3
  • func (a *S3) CreateBucket(bucket string, tags map[string]string) error
  • func (a *S3) DeleteBucket(name string) error
  • func (a *S3) DeleteBucketPrefix(name, prefix string) error
  • func (s *S3) DeleteBucketsByTags(tags []TagFilter) error
  • func (a *S3) Put(bucket, key string, buf []byte) error
  • func (a *S3) PutLifecycleRuleForPrefixExpire(name, prefix string, days int) error
• type StackWaiter
  • func (w *StackWaiter) Events() <-chan types.StackEvent
  • func (w *StackWaiter) Wait() error
• type TagFilter

Variables

var (
	ErrNotFound = fmt.Errorf("not found")
)

Functions

func InGithubAction

func InGithubAction() bool

func LambdaLogGroup

func LambdaLogGroup(lambdaName string) string

func TestProfile

func TestProfile() string

Types

type AWS

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

func New

func New() (*AWS, error)

func NewForTests

func NewForTests(t testingI) *AWS

NewForTests creates new client for use in tests environment variable with aws profile must be declare testingI is here to brake dependency on testing package Usage:

 func TestMy(t *testing.T) {
 	cli := NewForTests(t)
 	if cli == nil {
			t.Skip("skip: cli not initialized")
  	}

Run tests:

MANTIL_TESTS_AWS_PROFILE=org5 go test -v

func NewFromProfile

func NewFromProfile(profile string) (*AWS, error)

func NewWithCredentials

func NewWithCredentials(accessKeyID, secretAccessKey, sessionToken, region string) (*AWS, error)

func NewWithEndpointCredentials

func NewWithEndpointCredentials(endpoint, region string, token func() string) (*AWS, error)

func (*AWS) APIGAtewayCloudwatchRole

func (a *AWS) APIGAtewayCloudwatchRole() (string, error)

func (*AWS) AccountID

func (a *AWS) AccountID() string

func (*AWS) CloudFormation

func (a *AWS) CloudFormation() *CloudFormation

func (*AWS) CreateRole

func (a *AWS) CreateRole(name, assumeRolePolicy, policy string) (string, error)

func (*AWS) Credentials

func (a *AWS) Credentials() (aws.Credentials, error)

func (*AWS) DeleteDynamodbTablesByTags

func (a *AWS) DeleteDynamodbTablesByTags(tags []TagFilter) error

func (*AWS) FetchLogs

func (a *AWS) FetchLogs(group string, filter string, start *int64) (chan LogEvent, error)

func (*AWS) GetResourcesByTypeAndTag

func (a *AWS) GetResourcesByTypeAndTag(resourceTypes []string, resourceTags []TagFilter) ([]string, error)

func (*AWS) GetSSMParameter

func (a *AWS) GetSSMParameter(path string) (string, error)

func (*AWS) InvokeLambdaFunction

func (a *AWS) InvokeLambdaFunction(name string, req, rsp, clientContext interface{}) error

func (*AWS) Lambda

func (a *AWS) Lambda() *Lambda

func (*AWS) LambdaExists

func (a *AWS) LambdaExists(name string) (bool, error)

func (*AWS) PublishToAPIGatewayConnection

func (a *AWS) PublishToAPIGatewayConnection(domain, stage, connectionID string, data []byte) error

func (*AWS) Region

func (a *AWS) Region() string

func (*AWS) Role

func (a *AWS) Role(name string) (string, error)

func (*AWS) RoleCredentials

func (a *AWS) RoleCredentials(name, role, policy string, durationSeconds int32) (*Credentials, error)

func (*AWS) RoleExists

func (a *AWS) RoleExists(name string) (bool, error)

func (*AWS) S3

func (a *AWS) S3() *S3

func (*AWS) SetAPIGatewayCloudwatchRole

func (a *AWS) SetAPIGatewayCloudwatchRole(arn string) error

func (*AWS) TagLogGroup

func (a *AWS) TagLogGroup(name string, tags map[string]string) error

func (*AWS) Try

func (a *AWS) Try() error

Try will return error if can't get AWS account id

func (*AWS) UpdateLambdaFunctionCodeFromS3

func (a *AWS) UpdateLambdaFunctionCodeFromS3(function, bucket, key string) error

func (*AWS) WaitLambdaFunctionUpdated

func (a *AWS) WaitLambdaFunctionUpdated(function string) error

type CloudFormation

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

func (*CloudFormation) CreateStack

func (f *CloudFormation) CreateStack(name, templateBody string, resourceTags map[string]string) *StackWaiter

func (*CloudFormation) DeleteStack

func (f *CloudFormation) DeleteStack(name string) *StackWaiter

func (*CloudFormation) UpdateStack

func (f *CloudFormation) UpdateStack(name, templateBody string, resourceTags map[string]string) (*StackWaiter, error)

type Credentials

type Credentials struct {
	AccessKeyID     string
	SecretAccessKey string
	SessionToken    string
	Expiration      *time.Time
}

type Lambda

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

func (*Lambda) Info

func (l *Lambda) Info(name string) (map[string]string, error)

func (*Lambda) Invoke

func (l *Lambda) Invoke(name string, req, rsp interface{}, headers map[string]string) error

func (*Lambda) SetMemory

func (l *Lambda) SetMemory(name string, mem int) error

type LogEvent

type LogEvent struct {
	Message   string
	Timestamp int64
}

type RoleNotExistsError

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

func (*RoleNotExistsError) Error

func (a *RoleNotExistsError) Error() string

type S3

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

func (*S3) CreateBucket

func (a *S3) CreateBucket(bucket string, tags map[string]string) error

func (*S3) DeleteBucket

func (a *S3) DeleteBucket(name string) error

func (*S3) DeleteBucketPrefix

func (a *S3) DeleteBucketPrefix(name, prefix string) error

func (*S3) DeleteBucketsByTags

func (s *S3) DeleteBucketsByTags(tags []TagFilter) error

func (*S3) Put

func (a *S3) Put(bucket, key string, buf []byte) error

func (*S3) PutLifecycleRuleForPrefixExpire

func (a *S3) PutLifecycleRuleForPrefixExpire(name, prefix string, days int) error

type StackWaiter

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

func (*StackWaiter) Events

func (w *StackWaiter) Events() <-chan types.StackEvent

func (*StackWaiter) Wait

func (w *StackWaiter) Wait() error

type TagFilter

type TagFilter struct {
	Key    string
	Values []string
}