diff --git a/cmd/gos/client.go b/cmd/gos/client.go index ad539d9..d45ffc6 100644 --- a/cmd/gos/client.go +++ b/cmd/gos/client.go @@ -61,7 +61,7 @@ func defaultClientOpts() clientOpts { } } - value, ok = os.LookupEnv("MIDDLEWARE_DEFAULT_HTTP_TIMEOUT_MS") + value, ok = os.LookupEnv("MIDDLEWARE_HTTP_TIMEOUT_MS") if ok { timeoutMs, err := strconv.Atoi(value) diff --git a/pkg/executor_adapters/http_native/adapter.go b/pkg/executor_adapters/http_native/adapter.go index a89ae11..700e8ff 100644 --- a/pkg/executor_adapters/http_native/adapter.go +++ b/pkg/executor_adapters/http_native/adapter.go @@ -25,7 +25,7 @@ func NewHTTPClientAdapter(client *http.Client, poolSize uint64) *HTTPAdapter { if poolSize == 0 { poolSize = EX_ADAPTER_DEFAULT_REQ_RES_POOL_SIZE - value, ok := os.LookupEnv("SCHEDULER_DEFAULT_REQ_RES_POOL_SIZE") + value, ok := os.LookupEnv("SCHEDULER_REQ_RES_POOL_SIZE") if ok { parsedPoolSize, err := strconv.ParseUint(value, 10, 64) diff --git a/pkg/scheduler/options.go b/pkg/scheduler/options.go index 6e71c28..7cf80d5 100644 --- a/pkg/scheduler/options.go +++ b/pkg/scheduler/options.go @@ -17,7 +17,7 @@ type opts struct { func defaultOpts() opts { opts := opts{} opts.reqResPoolSize = SCHEDULER_DEFAULT_REQ_RES_POOL_SIZE - value, ok := os.LookupEnv("SCHEDULER_DEFAULT_REQ_RES_POOL_SIZE") + value, ok := os.LookupEnv("SCHEDULER_REQ_RES_POOL_SIZE") if ok { parsedPoolSize, err := strconv.ParseUint(value, 10, 64) @@ -27,7 +27,7 @@ func defaultOpts() opts { } opts.numWorkers = uint16(runtime.GOMAXPROCS(0)) * SCHEDULER_DEFAULT_NUM_WORKERS_MULTIPLIER - value, ok = os.LookupEnv("SCHEDULER_DEFAULT_NUM_WORKERS_MULTIPLIER") + value, ok = os.LookupEnv("SCHEDULER_NUM_WORKERS_MULTIPLIER") if ok { multiplier, err := strconv.ParseUint(value, 10, 16) @@ -37,7 +37,7 @@ func defaultOpts() opts { } opts.workQueueSize = SCHEDULER_DEFAULT_WORK_QUEUE_SIZE - value, ok = os.LookupEnv("SCHEDULER_DEFAULT_WORK_QUEUE_SIZE") + value, ok = os.LookupEnv("SCHEDULER_WORK_QUEUE_SIZE") if ok { workQueueSize, err := strconv.ParseUint(value, 10, 64)