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) {