Skip to content
This repository was archived by the owner on Dec 11, 2023. It is now read-only.

Commit 9e9e98f

Browse files
author
odacremolbap
committed
Use Uber lib to match CPU count with the scoby process
1 parent 3ab4790 commit 9e9e98f

File tree

3 files changed

+9
-0
lines changed

3 files changed

+9
-0
lines changed

go.mod

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -6,6 +6,7 @@ require (
66
github.com/alecthomas/kong v0.7.1
77
github.com/stretchr/testify v1.8.2
88
github.com/triggermesh/scoby v0.0.0-20230410193949-ba37efdfa633
9+
go.uber.org/automaxprocs v1.4.0
910
go.uber.org/zap v1.24.0
1011
k8s.io/api v0.26.3
1112
k8s.io/apimachinery v0.26.3

go.sum

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -202,6 +202,8 @@ go.opencensus.io v0.22.4/go.mod h1:yxeiOL68Rb0Xd1ddK5vPZ/oVn4vY4Ynel7k9FzqtOIw=
202202
go.uber.org/atomic v1.7.0/go.mod h1:fEN4uk6kAWBTFdckzkM89CLk9XfWZrxpCo0nPH17wJc=
203203
go.uber.org/atomic v1.9.0 h1:ECmE8Bn/WFTYwEW/bpKD3M8VtR/zQVbavAoalC1PYyE=
204204
go.uber.org/atomic v1.9.0/go.mod h1:fEN4uk6kAWBTFdckzkM89CLk9XfWZrxpCo0nPH17wJc=
205+
go.uber.org/automaxprocs v1.4.0 h1:CpDZl6aOlLhReez+8S3eEotD7Jx0Os++lemPlMULQP0=
206+
go.uber.org/automaxprocs v1.4.0/go.mod h1:/mTEdr7LvHhs0v7mjdxDreTz1OG5zdZGqgOnhWiR/+Q=
205207
go.uber.org/goleak v1.2.0 h1:xqgm/S+aQvhWFTtR0XK3Jvg7z8kGV8P4X14IzwN3Eqk=
206208
go.uber.org/goleak v1.2.0/go.mod h1:XJYK+MuIchqpmGmUSAzotztawfKvYLUIgg7guXrwVUo=
207209
go.uber.org/multierr v1.8.0 h1:dg6GjLku4EH+249NNmoIciG9N/jURbDG+pFlTkhzIC8=

pkg/common/cmd/globals.go

Lines changed: 6 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -11,6 +11,7 @@ import (
1111
"strings"
1212
"time"
1313

14+
"go.uber.org/automaxprocs/maxprocs"
1415
"go.uber.org/zap"
1516

1617
corev1 "k8s.io/api/core/v1"
@@ -88,6 +89,11 @@ func (g *Globals) Initialize() error {
8889
defaultConfigApplied := false
8990
var err error
9091

92+
undo, err := maxprocs.Set()
93+
if err != nil {
94+
return fmt.Errorf("could not match available CPUs to processes %w", err)
95+
}
96+
9197
kc, kdc, err := kubernetes.NewClients(g.Kubeconfig)
9298
if err != nil {
9399
return err

0 commit comments

Comments
 (0)