luxolus/open-vault
2
0
Fork 0
Code Issues 1 Pull requests Releases Activity

Fix err shadowing (#11296)

Browse source
This commit is contained in:
Scott Miller 2021-04-07 11:25:23 -05:00 committed by GitHub
parent 7daf061216
commit 080c9ca6ba
No known key found for this signature in database
GPG key ID: 4AEE18F83AFDEB23
1 changed files with 6 additions and 5 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

11
physical/dynamodb/dynamodb.go
View file

@ -500,7 +500,7 @@ func (d *DynamoDBBackend) HAEnabled() bool {
func (d *DynamoDBBackend) batchWriteRequests(requests []*dynamodb.WriteRequest) error {
for len(requests) > 0 {
batchSize := int(math.Min(float64(len(requests)), 25))
batch := map[string][]*dynamodb.WriteRequest{ d.table: requests[:batchSize] }
batch := map[string][]*dynamodb.WriteRequest{d.table: requests[:batchSize]}
requests = requests[batchSize:]
var err error
@ -511,19 +511,20 @@ func (d *DynamoDBBackend) batchWriteRequests(requests []*dynamodb.WriteRequest)
boff.MaxElapsedTime = 600 * time.Second
for len(batch) > 0 {
output, err := d.client.BatchWriteItem(&dynamodb.BatchWriteItemInput{
var output *dynamodb.BatchWriteItemOutput
output, err = d.client.BatchWriteItem(&dynamodb.BatchWriteItemInput{
RequestItems: batch,
})
if err != nil{
if err != nil {
break
}
if len(output.UnprocessedItems) == 0 {
break
} else {
duration := boff.NextBackOff();
if (duration != backoff.Stop) {
duration := boff.NextBackOff()
if duration != backoff.Stop {
batch = output.UnprocessedItems
time.Sleep(duration)
} else {