Skip to content

Commit

Permalink
fixup s3 mock paginator example
Browse files Browse the repository at this point in the history
  • Loading branch information
jasdel committed Dec 11, 2019
1 parent cfc4d85 commit 46d8b3f
Show file tree
Hide file tree
Showing 2 changed files with 19 additions and 5 deletions.
14 changes: 11 additions & 3 deletions example/service/s3/mockPaginator/mockPaginator.go
Expand Up @@ -5,6 +5,7 @@ package main
import (
"context"
"fmt"
"log"
"os"

"github.com/aws/aws-sdk-go-v2/aws/external"
Expand All @@ -24,12 +25,15 @@ func main() {

bucket := os.Args[1]
svc := s3.New(cfg)
keys := getKeys(svc, bucket)
keys, err := getKeys(svc, bucket)
if err != nil {
log.Fatalf("failed to get keys, %v", err)
}

fmt.Printf("keys for bucket %q,\n%v\n", bucket, keys)
}

func getKeys(svc s3iface.ClientAPI, bucket string) []string {
func getKeys(svc s3iface.ClientAPI, bucket string) ([]string, error) {
req := svc.ListObjectsRequest(&s3.ListObjectsInput{
Bucket: &bucket,
})
Expand All @@ -41,5 +45,9 @@ func getKeys(svc s3iface.ClientAPI, bucket string) []string {
keys = append(keys, *obj.Key)
}
}
return keys
if err := p.Err(); err != nil {
return nil, err
}

return keys, nil
}
10 changes: 8 additions & 2 deletions example/service/s3/mockPaginator/mockPaginator_test.go
Expand Up @@ -72,10 +72,16 @@ func TestListObjectsPagination(t *testing.T) {
},
}

svc.Client = s3.New(defaults.Config())
cfg := defaults.Config()
cfg.Region = "us-west-2"

svc.Client = s3.New(cfg)
svc.objects = objects

keys := getKeys(svc, "foo")
keys, err := getKeys(svc, "foo")
if err != nil {
t.Fatalf("expect no error, got %v", err)
}
expected := []string{"1", "2", "3"}

if e, a := 3, len(keys); e != a {
Expand Down

0 comments on commit 46d8b3f

Please sign in to comment.