.travis.yml

@@ -27,10 +27,10 @@ before_script:
   - LINT_PKGS=$(go list ./... | grep -Ev 'aws-lambda-go/lambda')
 
 script:
-  - diff -u <(echo -n) <(gofmt -d ./)                              # Fail if a .go file hasn't been formatted with gofmt
-  - goverage -v -covermode=atomic -coverprofile=coverage.txt $PKGS # Run all tests with coverage
-  - go vet -v ./...                                                # static analyisis
-  - golint $LINT_PKGS                                              # lint - ignore failures for now
+  - diff -u <(echo -n) <(gofmt -d ./)                                    # Fail if a .go file hasn't been formatted with gofmt
+  - goverage -v -race -covermode=atomic -coverprofile=coverage.txt $PKGS # Run all tests with coverage
+  - go vet -v ./...                                                      # static analyisis
+  - golint $LINT_PKGS                                                    # lint - ignore failures for now
 
 after_success:
   - bash <(curl -s https://codecov.io/bash)

events/README.md

@@ -14,6 +14,10 @@ This package provides input types for Lambda functions that process AWS events.
 
 [CloudFormation Events](../cfn/README.md)
 
+[CloudWatch Events](README_CloudWatch_Events.md)
+
+[CloudWatch Logs](README_CloudWatch_Logs.md)
+
 [Chime Bot Events](README_Chime_Bots.md)
 
 [Code Commit Events](README_CodeCommit.md)

events/README_CloudWatch_Events.md

@@ -0,0 +1,17 @@
+
+# Sample Function
+
+The following is a Lambda function that receives Amazon CloudWatch event record data as input and writes event detail to Lambda's CloudWatch Logs. Note that by default anything written to Console will be logged as CloudWatch Logs events.
+
+```go
+import (
+	"context"
+	"fmt"
+
+	"github.com/aws/aws-lambda-go/events"
+)
+
+func handler(ctx context.Context, event events.CloudWatchEvent) {
+	fmt.Printf("Detail = %s\n", event.Detail)
+}
+```

events/README_CloudWatch_Logs.md

@@ -0,0 +1,20 @@
+
+# Sample Function
+
+The following is a Lambda function that receives Amazon CloudWatch Logs event record data as input and writes message part to Lambda's CloudWatch Logs. Note that by default anything written to Console will be logged as CloudWatch Logs events.
+
+```go
+import (
+	"context"
+	"fmt"
+
+	"github.com/aws/aws-lambda-go/events"
+)
+
+func handler(ctx context.Context, logsEvent events.CloudwatchLogsEvent) {
+	data, _ := logsEvent.AWSLogs.Parse()
+	for _, logEvent := range data.LogEvents {
+		fmt.Printf("Message = %s\n", logEvent.Message)
+  	}
+}
+```

events/README_Cognito_UserPools_PreTokenGen.md

@@ -16,7 +16,7 @@ import (
 
 func handler(event events.CognitoEventUserPoolsPreTokenGen) (events.CognitoEventUserPoolsPreTokenGen, error) {
     fmt.Printf("PreTokenGen of user: %s\n", event.UserName)
-    event.Response.ClaimOverrideDetails.ClaimsToSupress = []string{"family_name"}
+    event.Response.ClaimsOverrideDetails.ClaimsToSuppress = []string{"family_name"}
     return event, nil
 }
 

events/apigw.go

@@ -49,6 +49,7 @@ type APIGatewayRequestIdentity struct {
 	CognitoIdentityID             string `json:"cognitoIdentityId"`
 	Caller                        string `json:"caller"`
 	APIKey                        string `json:"apiKey"`
+	APIKeyID                      string `json:"apiKeyId"`
 	AccessKey                     string `json:"accessKey"`
 	SourceIP                      string `json:"sourceIp"`
 	CognitoAuthenticationType     string `json:"cognitoAuthenticationType"`
@@ -167,6 +168,7 @@ type APIGatewayCustomAuthorizerPolicy struct {
 	Statement []IAMPolicyStatement
 }
 
+// IAMPolicyStatement represents one statement from IAM policy with action, effect and resource
 type IAMPolicyStatement struct {
 	Action   []string
 	Effect   string

events/attributevalue.go

@@ -75,7 +75,12 @@ func (av DynamoDBAttributeValue) Number() string {
 // of an int64 of the appropriate sign.
 // Method panics if the attribute is not of type Number.
 func (av DynamoDBAttributeValue) Integer() (int64, error) {
-	s, err := strconv.ParseFloat(av.Number(), 64)
+	number := av.Number()
+	value, err := strconv.ParseInt(number, 10, 64)
+	if err == nil {
+		return value, nil
+	}
+	s, err := strconv.ParseFloat(number, 64)
 	return int64(s), err
 }
 

events/attributevalue_test.go

@@ -211,6 +211,7 @@ func TestAccessWithWrongTypePanics(t *testing.T) {
 	}
 
 	for _, testCase := range testCases {
+		testCase := testCase
 		var av DynamoDBAttributeValue
 		err := json.Unmarshal([]byte(testCase.input), &av)
 		assert.Nil(t, err)

events/chime_bot_test.go

@@ -4,10 +4,10 @@ package events
 import (
 	"encoding/json"
 	"testing"
+	"time"
 
 	"github.com/aws/aws-lambda-go/events/test"
 	"github.com/stretchr/testify/assert"
-	"time"
 )
 
 func TestChimeBotEventMarshaling(t *testing.T) {
@@ -116,6 +116,7 @@ func TestChimeBotEventMarshaling(t *testing.T) {
 	}
 
 	for name, test := range tests {
+		test := test
 		t.Run(name, func(t *testing.T) {
 			var testEvent ChimeBotEvent
 			if err := json.Unmarshal([]byte(test.inputJSON), &testEvent); err != nil {

events/cloudwatch_logs.go

@@ -47,7 +47,7 @@ type CloudwatchLogsData struct {
 	LogEvents           []CloudwatchLogsLogEvent `json:"logEvents"`
 }
 
-// LogEvent represents a log entry from cloudwatch logs
+// CloudwatchLogsLogEvent represents a log entry from cloudwatch logs
 type CloudwatchLogsLogEvent struct {
 	ID        string `json:"id"`
 	Timestamp int64  `json:"timestamp"`

events/cloudwatch_logs_test.go

@@ -25,6 +25,7 @@ func TestCloudwatchLogs(t *testing.T) {
 			},
 		},
 	} {
+		test := test
 		t.Run(test.name, func(t *testing.T) {
 			inputJson := tst.ReadJSONFromFile(t, test.eventJson)
 
@@ -71,6 +72,7 @@ func TestCloudwatchLogsParse(t *testing.T) {
 			},
 		},
 	} {
+		test := test
 		t.Run(test.name, func(t *testing.T) {
 			inputJson := tst.ReadJSONFromFile(t, test.eventJson)
 

events/code_commit.go

@@ -43,7 +43,7 @@ func (t *CodeCommitEventTime) UnmarshalJSON(data []byte) error {
 	return err
 }
 
-// represents a CodeCommit record
+// CodeCommitRecord represents a CodeCommit record
 type CodeCommitRecord struct {
 	EventID              string               `json:"eventId"`
 	EventVersion         string               `json:"eventVersion"`

events/code_commit_test.go

@@ -33,6 +33,7 @@ func TestCodeCommitReference(t *testing.T) {
 	}
 
 	for _, c := range cases {
+		c := c
 		t.Run(c.Name, func(t *testing.T) {
 			test.AssertJsonBytes(t, c.Input, &CodeCommitReference{})
 		})
@@ -69,6 +70,7 @@ func TestCodeCommitCodeCommit(t *testing.T) {
 	}
 
 	for _, c := range cases {
+		c := c
 		t.Run(c.Name, func(t *testing.T) {
 			test.AssertJsonBytes(t, c.Input, &CodeCommitCodeCommit{})
 		})
@@ -128,6 +130,7 @@ func TestCodeCommitRecord(t *testing.T) {
 	}
 
 	for _, c := range cases {
+		c := c
 		t.Run(c.Name, func(t *testing.T) {
 			test.AssertJsonBytes(t, c.Input, &CodeCommitRecord{})
 		})
@@ -150,6 +153,7 @@ func TestCodeCommitEvent(t *testing.T) {
 	}
 
 	for _, c := range cases {
+		c := c
 		t.Run(c.Name, func(t *testing.T) {
 			test.AssertJsonBytes(t, c.Input, &CodeCommitEvent{})
 		})

events/codebuild.go

@@ -11,6 +11,7 @@ const (
 	CodeBuildPhaseChangeDetailType = "CodeBuild Build Phase Change"
 )
 
+// CodeBuildPhaseStatus represents the status of code build phase (i.e. failed, in progress)
 type CodeBuildPhaseStatus string
 
 const (
@@ -23,10 +24,12 @@ const (
 	CodeBuildPhaseStatusTimedOut                        = "TIMED_OUT"
 )
 
+// CodeBuildPhaseType represents the type of the code build phase (i.e. submitted, install)
 type CodeBuildPhaseType string
 
 const (
 	CodeBuildPhaseTypeSubmitted       CodeBuildPhaseType = "SUBMITTED"
+	CodeBuildPhaseTypeQueued                             = "QUEUED"
 	CodeBuildPhaseTypeProvisioning                       = "PROVISIONING"
 	CodeBuildPhaseTypeDownloadSource                     = "DOWNLOAD_SOURCE"
 	CodeBuildPhaseTypeInstall                            = "INSTALL"
@@ -72,6 +75,7 @@ type CodeBuildEvent struct {
 	Detail CodeBuildEventDetail `json:"detail"`
 }
 
+// CodeBuildEventDetail represents the all details related to the code build event
 type CodeBuildEventDetail struct {
 	BuildStatus           CodeBuildPhaseStatus                `json:"build-status"`
 	ProjectName           string                              `json:"project-name"`
@@ -89,6 +93,7 @@ type CodeBuildEventDetail struct {
 	CompletedPhaseEnd      CodeBuildTime        `json:"completed-phase-end"`
 }
 
+//CodeBuildEventAdditionalInformation represents additional informations to the code build event
 type CodeBuildEventAdditionalInformation struct {
 	Artifact CodeBuildArtifact `json:"artifact"`
 
@@ -109,12 +114,14 @@ type CodeBuildEventAdditionalInformation struct {
 	Phases []CodeBuildPhase `json:"phases"`
 }
 
+// CodeBuildArtifact represents the artifact provided to build
 type CodeBuildArtifact struct {
 	MD5Sum    string `json:"md5sum"`
 	SHA256Sum string `json:"sha256sum"`
 	Location  string `json:"location"`
 }
 
+// CodeBuildEnvironment represents the environment for a build
 type CodeBuildEnvironment struct {
 	Image                string                         `json:"image"`
 	PrivilegedMode       bool                           `json:"privileged-mode"`
@@ -123,6 +130,7 @@ type CodeBuildEnvironment struct {
 	EnvironmentVariables []CodeBuildEnvironmentVariable `json:"environment-variables"`
 }
 
+// CodeBuildEnvironmentVariable encapsulate environment variables for the code build
 type CodeBuildEnvironmentVariable struct {
 	// Name is the name of the environment variable.
 	Name string `json:"name"`
@@ -134,17 +142,20 @@ type CodeBuildEnvironmentVariable struct {
 	Value string `json:"value"`
 }
 
+// CodeBuildSource represent the code source will be build
 type CodeBuildSource struct {
 	Location string `json:"location"`
 	Type     string `json:"type"`
 }
 
+// CodeBuildLogs gives the log details of a code build
 type CodeBuildLogs struct {
 	GroupName  string `json:"group-name"`
 	StreamName string `json:"stream-name"`
 	DeepLink   string `json:"deep-link"`
 }
 
+// CodeBuildPhase represents the phase of a build and its details
 type CodeBuildPhase struct {
 	PhaseContext []interface{} `json:"phase-context"`
 
@@ -159,14 +170,17 @@ type CodeBuildPhase struct {
 	PhaseStatus CodeBuildPhaseStatus `json:"phase-status"`
 }
 
+// CodeBuildTime represents the time of the build
 type CodeBuildTime time.Time
 
 const codeBuildTimeFormat = "Jan 2, 2006 3:04:05 PM"
 
+// MarshalJSON converts a given CodeBuildTime to json
 func (t CodeBuildTime) MarshalJSON() ([]byte, error) {
 	return json.Marshal(time.Time(t).Format(codeBuildTimeFormat))
 }
 
+// UnmarshalJSON converts a given json to a CodeBuildTime
 func (t *CodeBuildTime) UnmarshalJSON(data []byte) error {
 	var s string
 	if err := json.Unmarshal(data, &s); err != nil {

events/codebuild_test.go

@@ -2,10 +2,11 @@ package events
 
 import (
 	"encoding/json"
-	"github.com/stretchr/testify/require"
 	"io/ioutil"
 	"testing"
 	"time"
+
+	"github.com/stretchr/testify/require"
 )
 
 func TestUnmarshalCodeBuildEvent(t *testing.T) {
@@ -71,6 +72,14 @@ func TestUnmarshalCodeBuildEvent(t *testing.T) {
 								PhaseType:    CodeBuildPhaseTypeSubmitted,
 								PhaseStatus:  CodeBuildPhaseStatusSucceeded,
 							},
+							{
+								PhaseContext: []interface{}{},
+								StartTime:    CodeBuildTime(time.Date(2017, 9, 1, 16, 12, 29, 0, time.UTC)),
+								EndTime:      CodeBuildTime(time.Date(2019, 9, 13, 4, 12, 29, 0, time.UTC)),
+								Duration:     DurationSeconds(0),
+								PhaseType:    CodeBuildPhaseTypeQueued,
+								PhaseStatus:  CodeBuildPhaseStatusSucceeded,
+							},
 							{
 								PhaseContext: []interface{}{},
 								StartTime:    CodeBuildTime(time.Date(2017, 9, 1, 16, 12, 29, 0, time.UTC)),
@@ -200,6 +209,14 @@ func TestUnmarshalCodeBuildEvent(t *testing.T) {
 								PhaseType:    CodeBuildPhaseTypeSubmitted,
 								PhaseStatus:  CodeBuildPhaseStatusSucceeded,
 							},
+							{
+								PhaseContext: []interface{}{},
+								StartTime:    CodeBuildTime(time.Date(2017, 9, 1, 16, 12, 29, 0, time.UTC)),
+								EndTime:      CodeBuildTime(time.Date(2019, 9, 13, 4, 12, 29, 0, time.UTC)),
+								Duration:     DurationSeconds(0),
+								PhaseType:    CodeBuildPhaseTypeQueued,
+								PhaseStatus:  CodeBuildPhaseStatusSucceeded,
+							},
 							{
 								PhaseContext: []interface{}{},
 								StartTime:    CodeBuildTime(time.Date(2017, 9, 1, 16, 12, 29, 0, time.UTC)),

events/duration.go

@@ -8,6 +8,7 @@ import (
 
 type DurationSeconds time.Duration
 
+// UnmarshalJSON converts a given json to a DurationSeconds
 func (duration *DurationSeconds) UnmarshalJSON(data []byte) error {
 	var seconds float64
 	if err := json.Unmarshal(data, &seconds); err != nil {
@@ -18,13 +19,15 @@ func (duration *DurationSeconds) UnmarshalJSON(data []byte) error {
 	return nil
 }
 
+// MarshalJSON converts a given DurationSeconds to json
 func (duration DurationSeconds) MarshalJSON() ([]byte, error) {
 	seconds := time.Duration(duration).Seconds()
 	return json.Marshal(int64(math.Ceil(seconds)))
 }
 
 type DurationMinutes time.Duration
 
+// UnmarshalJSON converts a given json to a DurationMinutes
 func (duration *DurationMinutes) UnmarshalJSON(data []byte) error {
 	var minutes float64
 	if err := json.Unmarshal(data, &minutes); err != nil {
@@ -35,6 +38,7 @@ func (duration *DurationMinutes) UnmarshalJSON(data []byte) error {
 	return nil
 }
 
+// MarshalJSON converts a given DurationMinutes to json
 func (duration DurationMinutes) MarshalJSON() ([]byte, error) {
 	minutes := time.Duration(duration).Minutes()
 	return json.Marshal(int64(math.Ceil(minutes)))

events/dynamodb.go

@@ -63,7 +63,7 @@ type DynamoDBUserIdentity struct {
 	PrincipalID string `json:"principalId"`
 }
 
-// A description of a single data modification that was performed on an item
+// DynamoDBStreamRecord represents a description of a single data modification that was performed on an item
 // in a DynamoDB table.
 type DynamoDBStreamRecord struct {
 

events/s3.go

@@ -6,10 +6,12 @@ import (
 	"time"
 )
 
+// S3Event which wrap an array of S3EventRecord
 type S3Event struct {
 	Records []S3EventRecord `json:"Records"`
 }
 
+// S3EventRecord which wrap record data
 type S3EventRecord struct {
 	EventVersion      string              `json:"eventVersion"`
 	EventSource       string              `json:"eventSource"`