From 6dec2323635c46512c3ac2e585878eb930830bee Mon Sep 17 00:00:00 2001 From: ravikiran-s Date: Wed, 3 May 2023 13:56:49 +0530 Subject: [PATCH] nil checks --- clientlibrary/streams/dynamodb_adapter_client.go | 12 ++++++++---- 1 file changed, 8 insertions(+), 4 deletions(-) diff --git a/clientlibrary/streams/dynamodb_adapter_client.go b/clientlibrary/streams/dynamodb_adapter_client.go index 50036b5..73c89bf 100644 --- a/clientlibrary/streams/dynamodb_adapter_client.go +++ b/clientlibrary/streams/dynamodb_adapter_client.go @@ -57,8 +57,10 @@ func (d DynamodbStreamAdapterClient) ListShards(ctx context.Context, params *kin req, _ := json.Marshal(params) log.Info(fmt.Sprintf("ListShards >>> request %v", string(req))) var maxResults int32 = 100 - if *params.MaxResults >= 100 { - params.MaxResults = &maxResults + if params.MaxResults != nil { + if 100 >= *params.MaxResults { + params.MaxResults = &maxResults + } } dynamoOutput, err := d.internalClient.DescribeStream(ctx, &dynamodbstreams.DescribeStreamInput{ ExclusiveStartShardId: params.ExclusiveStartShardId, @@ -279,8 +281,10 @@ func (d DynamodbStreamAdapterClient) convertShardIteratorInput(kinesisInput *kin func (d DynamodbStreamAdapterClient) convertGetRecordsInput(params *kinesis.GetRecordsInput) *dynamodbstreams.GetRecordsInput { var dynamoMaxLimit int32 = 1000 - if *params.Limit >= 10000 { - params.Limit = &dynamoMaxLimit + if params.Limit != nil { + if *params.Limit >= 10000 { + params.Limit = &dynamoMaxLimit + } } dynamoInput := &dynamodbstreams.GetRecordsInput{ Limit: params.Limit,