File tree Expand file tree Collapse file tree 2 files changed +5
-4
lines changed Expand file tree Collapse file tree 2 files changed +5
-4
lines changed Original file line number Diff line number Diff line change 6
6
"testing"
7
7
8
8
"github.com/aws/aws-sdk-go/aws"
9
+ "github.com/aws/aws-sdk-go/aws/session"
9
10
"github.com/aws/aws-sdk-go/service/dynamodb"
10
11
"github.com/aws/aws-sdk-go/service/dynamodb/dynamodbattribute"
11
12
. "github.com/remind101/pkg/dynamodb_client"
@@ -57,7 +58,7 @@ func newFreshDynamoClient() *DynamoClient {
57
58
Scope : "client-test" ,
58
59
TableDescriptions : AllTableDescriptions ,
59
60
}
60
- c := NewDynamoDBClient (params )
61
+ c := NewDynamoDBClient (session . New (), params )
61
62
c .DeleteTables ()
62
63
c .CreateTables ()
63
64
return c
Original file line number Diff line number Diff line change 6
6
7
7
"github.com/aws/aws-sdk-go/aws"
8
8
"github.com/aws/aws-sdk-go/aws/awserr"
9
- "github.com/aws/aws-sdk-go/aws/session "
9
+ "github.com/aws/aws-sdk-go/aws/client "
10
10
"github.com/aws/aws-sdk-go/service/dynamodb"
11
11
"github.com/aws/aws-sdk-go/service/dynamodb/dynamodbiface"
12
12
"github.com/remind101/pkg/logger"
@@ -26,15 +26,15 @@ type DynamoConnectionParams struct {
26
26
ServiceName string // Name to use in apm
27
27
}
28
28
29
- func NewDynamoDBClient (params DynamoConnectionParams ) * DynamoClient {
29
+ func NewDynamoDBClient (c client. ConfigProvider , params DynamoConnectionParams ) * DynamoClient {
30
30
if params .RegionName == "" {
31
31
params .RegionName = "us-east-1"
32
32
}
33
33
config := aws.Config {
34
34
Region : aws .String (params .RegionName ),
35
35
Endpoint : aws .String (params .LocalDynamoURL ),
36
36
}
37
- svc := dynamodb .New (session . New () , & config )
37
+ svc := dynamodb .New (c , & config )
38
38
//svc.Handlers.Retry.PushFrontNamed(CheckThrottleHandler)
39
39
40
40
return & DynamoClient {
You can’t perform that action at this time.
0 commit comments