aidews

aidews is a helper (aide) for AWS. aws-sdk-go is fantastic, but this simplifies some of its uses.

Session

Session is the backbone helper of aidews and makes getting an aws-sdk-go session straight-forward

The region and role_arn parameters are optional. If neither are given the session returned is built with a blank config. If region is given, the config used to get the session includes the region. If role_arn given, we first STS, then get a session in that region using the credentials from the STS call. All Sessions are constructed using the SharedConfigEnable setting allowing the use of local credential resolution.

// Session with no additional configuration
sess := aidews.Session(nil, nil)

// Session with region set
region := "us-west-2"
sess := aidews.Session(&region, nil)

// Session with role set, this will get a session assumed into the role passed in
role := "arn:aws:iam::{{accounttId}}:role/role_name"
sess := aidews.Session(nil, &role)

apigateway

aidews apigateway package provides helpers for making signed requests to api gateways

// Create client
host, _ := url.Parse("apigatewayUrl") // url.Url for apigateway
role := "arn:aws:iam::{{accounttId}}:role/role_name" // role with access to execute api
region := "us-west-2" // region of gateway
client := apigateway.New(host, &region, &role)

// Get
queryString :=  map[string][]string{
	"hokey":    []string{"pokey"},
}
resp, err := client.Get("do/the", queryString)

// Put
body := struct{
    turnYourself string
}{
    turnYourself: "around",
}
resp, err := client.Put("hokey/pokey", body)

// Post
body := struct{
    thatsWhat string
}{
    thatsWhat: "its all about",
}
resp, err := client.Post("hokey/pokey", body)

If you need to pass specific headers while invoking the APIs

// Create client
host, _ := url.Parse("apigatewayUrl") // url.Url for apigateway
role := "arn:aws:iam::{{accounttId}}:role/role_name" // role with access to execute api
region := "us-west-2" // region of gateway
headers := map[string]string { "content-type":"application/json"} //headers to be passed
client := apigateway.NewWithHeaders(host, region, &role, headers)

If your favorite HTTP verb is not present in our helpers, you may use the Do function

//Do
req, _ := http.NewRequest("DELETE", "we/all/fall/down", nil)
resp, err := client.Do(req)

dynamodb

Package dynamodb provides a DynamoDB wrapper object.

QueryPages queries the table and unmarshals each page of results to provided function. Caller should provide an item of some type that will be populated and each item will be returned to the provided pager function. Provided pager function should take a single interface{} and assert the type of the item (e.g. Item), and a boolean which will indicate whether this is the last item. Provided pager function should return false if it wants to stop processing. Example:

items := Item
pager := func(out interface{}, last bool) bool {
  if out.(Item).Found { return false }
  return !last
}
if err := QueryPages(queryInput, item, pager); err != nil {
 return err
}

ScanPages scans the table and unmarshals each page of results to provided function. Caller should provide an item of some type that will be populated and each item will be returned to the provided pager function. Provided pager function should take a single interface{} and assert the type of the item (e.g. Item), and a boolean which will indicate whether this is the last item. Provided pager function should return false if it wants to stop processing. Example:

items := Item
pager := func(out interface{}, last bool) bool {
  if out.(Item).Found { return false }
  return !last
}
if err := ScanPages(queryInput, item, pager); err != nil {
 return err
}

s3

Package s3 provides a S3 wrapper object.

ListObjectsV2Input returns an expression that can be used to add the input params supported in V2 of s3 api

Example:

svc := s3.New(bucketName, &region, &roleARN)

var listObjectsInput = svc.ListObjectsV2Input()
listObjectsInput.Bucket = aws.String(bucketName)
listObjectsInput.Prefix = &prefix
listObjectsInput.StartAfter = &startAfter
listObjectsInput.MaxKeys = &pageSize

ListObjectsKeysV2Pages returns the paginated response by listing the the specified number of keys from the 'Content' object array. The lastPage output indicated whether s3 reached last page in fetching the objects

Example:

keys, lastPage, err := svc.ListObjectsKeysV2Pages(listObjectsInput)