Fix formatting

dzbarsky · Jan 21, 2025 · 21e495b · 21e495b
1 parent 6196ce6
commit 21e495b
Show file tree

Hide file tree

Showing 3 changed files with 36 additions and 36 deletions.
diff --git a/services/kinesis/kinesis.go b/services/kinesis/kinesis.go
@@ -308,23 +308,23 @@ func (k *Kinesis) PutRecord(input PutRecordInput) (*PutRecordOutput, *awserrors.
 
 // https://docs.aws.amazon.com/kinesis/latest/APIReference/API_PutRecords.html
 func (k *Kinesis) PutRecords(input PutRecordsInput) (*PutRecordsOutput, *awserrors.Error) {
-    putRecordsOutput := &PutRecordsOutput{}
-    for _, record := range input.Records {
-        putRecordOutput, err := k.PutRecord(PutRecordInput{
-            StreamName: input.StreamName,
-            Data: record.Data,
-            PartitionKey: record.PartitionKey,
-            ExplicitHashKey: record.ExplicitHashKey,
-        })
-        if err != nil {
-            return nil, err
-        }
-        putRecordsOutput.Records = append(putRecordsOutput.Records, PutRecordsOutputRecord{
-            SequenceNumber: putRecordOutput.SequenceNumber,
-            ShardId: putRecordOutput.ShardId,
-        })
-    }
-    return putRecordsOutput, nil
+	putRecordsOutput := &PutRecordsOutput{}
+	for _, record := range input.Records {
+		putRecordOutput, err := k.PutRecord(PutRecordInput{
+			StreamName:      input.StreamName,
+			Data:            record.Data,
+			PartitionKey:    record.PartitionKey,
+			ExplicitHashKey: record.ExplicitHashKey,
+		})
+		if err != nil {
+			return nil, err
+		}
+		putRecordsOutput.Records = append(putRecordsOutput.Records, PutRecordsOutputRecord{
+			SequenceNumber: putRecordOutput.SequenceNumber,
+			ShardId:        putRecordOutput.ShardId,
+		})
+	}
+	return putRecordsOutput, nil
 }
 
 func (k *Kinesis) lockedGetShard(streamName, shardId string) (*Shard, *awserrors.Error) {

diff --git a/services/kinesis/kinesis_test.go b/services/kinesis/kinesis_test.go
@@ -170,19 +170,19 @@ func TestGetShardIterator(t *testing.T) {
 			t.Fatal(err)
 		}
 	}
-    putRecordsInput := PutRecordsInput{
-        StreamName: streamName,
-    }
-    for i := 2; i < 5; i++ {
-        putRecordsInput.Records = append(putRecordsInput.Records, PutRecordsRequestEntry{
-            PartitionKey: "key",
-            Data:         strconv.Itoa(i),
-        })
-    }
-    _, err := k.PutRecords(putRecordsInput)
-    if err != nil {
-        t.Fatal(err)
-    }
+	putRecordsInput := PutRecordsInput{
+		StreamName: streamName,
+	}
+	for i := 2; i < 5; i++ {
+		putRecordsInput.Records = append(putRecordsInput.Records, PutRecordsRequestEntry{
+			PartitionKey: "key",
+			Data:         strconv.Itoa(i),
+		})
+	}
+	_, err := k.PutRecords(putRecordsInput)
+	if err != nil {
+		t.Fatal(err)
+	}
 
 	shardsOutput, err := k.ListShards(ListShardsInput{
 		StreamName: streamName,

diff --git a/services/kinesis/types.go b/services/kinesis/types.go
@@ -31,15 +31,15 @@ type PutRecordOutput struct {
 }
 
 type PutRecordsInputRecord struct {
-	PartitionKey string
-	Data         string
+	PartitionKey    string
+	Data            string
 	ExplicitHashKey string
 }
 
 type PutRecordsInput struct {
-	StreamName   string
-	StreamARN    string
-    Records      []PutRecordsInputRecord
+	StreamName string
+	StreamARN  string
+	Records    []PutRecordsInputRecord
 }
 
 type PutRecordsOutputRecord struct {
@@ -48,7 +48,7 @@ type PutRecordsOutputRecord struct {
 }
 
 type PutRecordsOutput struct {
-    Records        []PutRecordsOutputRecord
+	Records []PutRecordsOutputRecord
 }
 
 type GetShardIteratorInput struct {