From 2f8034ae126a36ded04a56f8cf49565a431643b4 Mon Sep 17 00:00:00 2001
From: derfenix <derfenix@gmail.com>
Date: Thu, 30 May 2024 19:49:06 +0300
Subject: [PATCH] Improve packets generation

---
 README.md                  | 1 +
 application/application.go | 2 +-
 application/config.go      | 5 +++--
 3 files changed, 5 insertions(+), 3 deletions(-)

diff --git a/README.md b/README.md
index 26827cf..bc041a6 100644
--- a/README.md
+++ b/README.md
@@ -20,3 +20,4 @@
 * **PACKET_INPUT_INTERVAL** — интервал генерации пакетов
 * **OUTPUT_INTERVAL** — интеревал для вывода результатов
 * **WORKERS_COUNT** — количество воркеров
+* **PACKET_MAX_VALUES** — максимальное значение чисел в пакете
diff --git a/application/application.go b/application/application.go
index cda82dd..44fded9 100644
--- a/application/application.go
+++ b/application/application.go
@@ -40,7 +40,7 @@ func NewApplication(ctx context.Context) (Application, error) {
 
 	acc := accumulator.NewAccumulator(pool.Out())
 
-	src := randomsource.NewService(in, cfg.PacketInputInterval, 100)
+	src := randomsource.NewService(in, cfg.PacketInputInterval, cfg.PacketMaxValues)
 
 	pub := stdoutpub.NewService()
 
diff --git a/application/config.go b/application/config.go
index b5952c4..cf08296 100644
--- a/application/config.go
+++ b/application/config.go
@@ -9,9 +9,10 @@ import (
 )
 
 type Config struct {
-	PacketInputInterval time.Duration `env:"PACKET_INPUT_INTERVAL,default=500ms"`
+	PacketInputInterval time.Duration `env:"PACKET_INPUT_INTERVAL,default=200ms"`
 	WorkersCount        uint          `env:"WORKERS_COUNT,default=10"`
-	OutputInterval      time.Duration `env:"OUTPUT_INTERVAL,default=1s"`
+	OutputInterval      time.Duration `env:"OUTPUT_INTERVAL,default=2s"`
+	PacketMaxValues     int64         `env:"PACKET_MAX_VALUES,default=100"`
 }
 
 func NewConfig(ctx context.Context) (Config, error) {