luciano/vmware-go-kcl-v2
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

length check fixes

Browse source
This commit is contained in:
ravikiran-s 2023-05-03 16:29:43 +05:30
parent 3c07ee37ac
commit ba3fde7e34
2 changed files with 7 additions and 6 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

1
clientlibrary/streams/dynamo_adapter_client_test.go Normal file
View file

@ -0,0 +1 @@
package streams

12
clientlibrary/streams/dynamodb_adapter_client.go
View file

@ -238,9 +238,9 @@ func (d DynamodbStreamAdapterClient) convertListStreamsOutput(dOutput *dynamodbs
// Set StreamNames field using StreamDescriptionList field from output // Set StreamNames field using StreamDescriptionList field from output
kinesisOutput.StreamNames = nil kinesisOutput.StreamNames = nil
if dOutput.Streams != nil { if dOutput.Streams != nil {
kinesisOutput.StreamNames = make([]string, len(dOutput.Streams)) kinesisOutput.StreamNames = make([]string, 0)
for i, stream := range dOutput.Streams { for _, stream := range dOutput.Streams {
kinesisOutput.StreamNames[i] = *stream.StreamArn kinesisOutput.StreamNames = append(kinesisOutput.StreamNames, *stream.StreamArn)
} }
} }
kinesisOutput.ResultMetadata = dOutput.ResultMetadata kinesisOutput.ResultMetadata = dOutput.ResultMetadata
@ -296,7 +296,7 @@ func (d DynamodbStreamAdapterClient) convertGetRecordsInput(params *kinesis.GetR
func (d DynamodbStreamAdapterClient) convertGetRecordsOutput(dynamoOutput *dynamodbstreams.GetRecordsOutput) *kinesis.GetRecordsOutput { func (d DynamodbStreamAdapterClient) convertGetRecordsOutput(dynamoOutput *dynamodbstreams.GetRecordsOutput) *kinesis.GetRecordsOutput {
kinesisOutput := kinesis.GetRecordsOutput{} kinesisOutput := kinesis.GetRecordsOutput{}
if dynamoOutput != nil && len(dynamoOutput.Records) != 0 { if dynamoOutput != nil && len(dynamoOutput.Records) != 0 {
kinesisOutput.Records = make([]ktypes.Record, len(dynamoOutput.Records)) kinesisOutput.Records = make([]ktypes.Record, 0)
kinesisOutput.ResultMetadata = dynamoOutput.ResultMetadata kinesisOutput.ResultMetadata = dynamoOutput.ResultMetadata
kinesisOutput.NextShardIterator = dynamoOutput.NextShardIterator kinesisOutput.NextShardIterator = dynamoOutput.NextShardIterator
} }
@ -320,7 +320,7 @@ func (d DynamodbStreamAdapterClient) convertListShardsOutput(output *dynamodbstr
} }
if output != nil { if output != nil {
if output.StreamDescription != nil && len(output.StreamDescription.Shards) != 0 { if output.StreamDescription != nil && len(output.StreamDescription.Shards) != 0 {
kinesisOutput.Shards = make([]ktypes.Shard, len(output.StreamDescription.Shards)) kinesisOutput.Shards = make([]ktypes.Shard, 0)
} }
for _, shard := range output.StreamDescription.Shards { for _, shard := range output.StreamDescription.Shards {
kinesisOutput.Shards = append(kinesisOutput.Shards, ktypes.Shard{ kinesisOutput.Shards = append(kinesisOutput.Shards, ktypes.Shard{
@ -349,7 +349,7 @@ func (d DynamodbStreamAdapterClient) convertDescribeStreamOutput(output *dynamod
StreamName: output.StreamDescription.StreamArn, StreamName: output.StreamDescription.StreamArn,
StreamStatus: ktypes.StreamStatus(output.StreamDescription.StreamStatus), StreamStatus: ktypes.StreamStatus(output.StreamDescription.StreamStatus),
StreamCreationTimestamp: output.StreamDescription.CreationRequestDateTime, StreamCreationTimestamp: output.StreamDescription.CreationRequestDateTime,
Shards: make([]ktypes.Shard, len(output.StreamDescription.Shards)), Shards: make([]ktypes.Shard, 0),
} }
} }
for _, shard := range output.StreamDescription.Shards { for _, shard := range output.StreamDescription.Shards {