openkruise
/
kruise-game
mirror of https://github.com/openkruise/kruise-game.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

feat: support user-defined number of controller workers (#247) 

Signed-off-by: ChrisLiu <chrisliu1995@163.com>
This commit is contained in:
ChrisLiu 2025-06-23 19:17:37 +08:00 committed by GitHub
parent fbcb3953c0
commit 0ff70733c6
No known key found for this signature in database
GPG Key ID: B5690EEEBB952194
2 changed files with 10 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
pkg/controllers/gameserver/gameserver_controller.go
View File

@ -18,6 +18,7 @@ package gameserver
import (
"context"
"flag"
"reflect"
"time"
@ -48,6 +49,10 @@ import (
utildiscovery "github.com/openkruise/kruise-game/pkg/util/discovery"
)
func init() {
flag.IntVar(&concurrentReconciles, "gameserver-workers", concurrentReconciles, "Max concurrent workers for GameServer controller.")
}
var (
controllerKind = gamekruiseiov1alpha1.SchemeGroupVersion.WithKind("GameServer")
// leave it to batch size

5
pkg/controllers/gameserverset/gameserverset_controller.go
View File

@ -18,6 +18,7 @@ package gameserverset
import (
"context"
"flag"
kruisev1alpha1 "github.com/openkruise/kruise-api/apps/v1alpha1"
kruiseV1beta1 "github.com/openkruise/kruise-api/apps/v1beta1"
@ -47,6 +48,10 @@ import (
utildiscovery "github.com/openkruise/kruise-game/pkg/util/discovery"
)
func init() {
flag.IntVar(&concurrentReconciles, "gameserverset-workers", concurrentReconciles, "Max concurrent workers for GameServerSet controller.")
}
var (
controllerKind = gamekruiseiov1alpha1.SchemeGroupVersion.WithKind("GameServerSet")
// leave it to batch size