comment

Author: hariso

source/logrepl/cdc.go

@@ -49,6 +49,10 @@ type CDCIterator struct {
 
 	// batchesCh is a channel shared between this iterator and a CDCHandler,
 	// to which the CDCHandler is sending batches of records.
+	// Using a shared queue here would be the fastest option. However,
+	// we also need to watch for a context that can get cancelled,
+	// and for the subscription that can end, so using a channel is
+	// the best option at the moment.
 	batchesCh chan []opencdc.Record
 
 	// recordsForNextRead contains records from the previous batch (returned by the CDCHandler),