File tree Expand file tree Collapse file tree 1 file changed +3
-3
lines changed Expand file tree Collapse file tree 1 file changed +3
-3
lines changed Original file line number Diff line number Diff line change @@ -18,16 +18,16 @@ import (
18
18
19
19
// batchSender is a component that places requests into batches before passing them to the downstream senders.
20
20
// Batches are sent out with any of the following conditions:
21
- // - batch size reaches cfg.SendBatchSize
22
- // - cfg.Timeout is elapsed since the timestamp when the previous batch was sent out.
21
+ // - batch size reaches cfg.MinSizeItems
22
+ // - cfg.FlushTimeout is elapsed since the timestamp when the previous batch was sent out.
23
23
// - concurrencyLimit is reached.
24
24
type batchSender struct {
25
25
baseRequestSender
26
26
cfg exporterbatcher.Config
27
27
mergeFunc exporterbatcher.BatchMergeFunc [Request ]
28
28
mergeSplitFunc exporterbatcher.BatchMergeSplitFunc [Request ]
29
29
30
- // concurrencyLimit is the maximum number of goroutines that can be created by the batcher.
30
+ // concurrencyLimit is the maximum number of goroutines that can be blocked by the batcher.
31
31
// If this number is reached and all the goroutines are busy, the batch will be sent right away.
32
32
// Populated from the number of queue consumers if queue is enabled.
33
33
concurrencyLimit uint64
You can’t perform that action at this time.
0 commit comments