We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 62c6f56 commit e63383bCopy full SHA for e63383b
1 file changed
aws/logs_monitoring_go/internal/forwarding/forwarding.go
@@ -75,7 +75,7 @@ func (f *Forwarder) Start(ctx context.Context, in <-chan model.LogEntry, storage
75
eg, ctx := errgroup.WithContext(ctx)
76
eg.SetLimit(1 + httpclient.MaxConcurrency)
77
78
- batches := make(chan json.RawMessage) // we should use a buffered channel here since we use a worker pool
+ batches := make(chan json.RawMessage)
79
eg.Go(func() error {
80
defer close(batches)
81
cfg := batching.NewConfig(maxLogSize, maxBatchSize, maxLogsPerBatch)
0 commit comments