Skip to content

Commit

Permalink
Merge pull request #29 from tech-engine/dev
Browse files Browse the repository at this point in the history
chore: remove default from env variable names
  • Loading branch information
tech-engine authored Sep 11, 2024
2 parents 7f401ee + 7fce5a5 commit 6f08200
Show file tree
Hide file tree
Showing 3 changed files with 5 additions and 5 deletions.
2 changes: 1 addition & 1 deletion cmd/gos/client.go
Original file line number Diff line number Diff line change
Expand Up @@ -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)
Expand Down
2 changes: 1 addition & 1 deletion pkg/executor_adapters/http_native/adapter.go
Original file line number Diff line number Diff line change
Expand Up @@ -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)
Expand Down
6 changes: 3 additions & 3 deletions pkg/scheduler/options.go
Original file line number Diff line number Diff line change
Expand Up @@ -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)
Expand All @@ -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)
Expand All @@ -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)
Expand Down

0 comments on commit 6f08200

Please sign in to comment.