Remove ptr.

artie-labs · Jul 14, 2024 · 6022c8c · 6022c8c
1 parent d7cd374
commit 6022c8c
Show file tree

Hide file tree

Showing 2 changed files with 3 additions and 3 deletions.
diff --git a/sources/dynamodb/shard.go b/sources/dynamodb/shard.go
@@ -23,7 +23,7 @@ func (s *StreamStore) ListenToChannel(ctx context.Context, writer writers.Writer
 	}
 }
 
-func (s *StreamStore) processShard(ctx context.Context, shard *types.Shard, writer writers.Writer) {
+func (s *StreamStore) processShard(ctx context.Context, shard types.Shard, writer writers.Writer) {
 	// Is there another go-routine processing this shard?
 	if s.storage.GetShardProcessing(*shard.ShardId) {
 		return

diff --git a/sources/dynamodb/stream.go b/sources/dynamodb/stream.go
@@ -21,7 +21,7 @@ type StreamStore struct {
 
 	streams   *dynamodbstreams.Client
 	storage   *offsets.OffsetStorage
-	shardChan chan *types.Shard
+	shardChan chan types.Shard
 }
 
 func (s *StreamStore) Close() error {
@@ -72,7 +72,7 @@ func (s *StreamStore) scanForNewShards(ctx context.Context) error {
 		}
 
 		for _, shard := range result.StreamDescription.Shards {
-			s.shardChan <- &shard
+			s.shardChan <- shard
 		}
 
 		if result.StreamDescription.LastEvaluatedShardId == nil {