Skip to content

Commit fd5d17f

Browse files
committed
make tokeinzer size configurable
1 parent 2b9ee36 commit fd5d17f

2 files changed

Lines changed: 3 additions & 1 deletion

File tree

pkg/config/setup/config.go

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -1735,6 +1735,7 @@ func logsagent(config pkgconfigmodel.Setup) {
17351735
// Dynamic sampling configuration
17361736
config.BindEnvAndSetDefault("logs_config.dynamic_sampling_enabled", false)
17371737
config.BindEnvAndSetDefault("logs_config.dynamic_sampling.skip_json_logs", false)
1738+
config.BindEnvAndSetDefault("logs_config.dynamic_sampling.tokenizer_size", 10240)
17381739
config.BindEnvAndSetDefault("logs_config.dynamic_sampling.rate_ceiling", 1.0)
17391740
config.BindEnvAndSetDefault("logs_config.dynamic_sampling.fast_half_life_seconds", 2)
17401741
config.BindEnvAndSetDefault("logs_config.dynamic_sampling.slow_half_life_seconds", 60)

pkg/logs/internal/decoder/auto_multiline_detection/sample_aggregator.go

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -32,9 +32,10 @@ type TokenizedMessage struct {
3232
}
3333

3434
func NewSampleAggregator(tailerInfo *status.InfoRegistry) *SampleAggregator {
35+
tokenizerSize := pkgconfigsetup.Datadog().GetInt("logs_config.dynamic_sampling.tokenizer_size")
3536

3637
s := &SampleAggregator{
37-
tokenizer: NewTokenizer(1024 * 10),
38+
tokenizer: NewTokenizer(tokenizerSize),
3839
sampler: NewSampler(DefaultConfig()),
3940
}
4041
s.sampler.Start()

0 commit comments

Comments
 (0)