ZB-Server/EscapeFromTeacher
Private
Public Access
1
0
Fork 0
Code Activity

Increase replicas to 2 in Kubernetes deployment and switch game.start and game.input handlers from NATS Queue Groups to broadcast mode.
All checks were successful
Dynamic Branch Deploy / build-and-deploy (push) Successful in 2m29s

Browse Source
This commit is contained in:
Sebastian Unterschütz
2026-01-04 16:54:13 +01:00
parent df3608408c
commit a17a6f5e9f
2 changed files with 5 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files

8
cmd/server/main.go
View File

@@ -141,8 +141,8 @@ func main() {
} }
log.Printf("👂 Lausche auf 'game.join' in Queue Group 'game-servers'... (Sub Valid: %v)", sub.IsValid()) log.Printf("👂 Lausche auf 'game.join' in Queue Group 'game-servers'... (Sub Valid: %v)", sub.IsValid())
// 4. HANDLER: GAME START (mit Queue Group) // 4. HANDLER: GAME START (broadcast - alle Pods empfangen, nur der mit dem Raum reagiert)
_, _ = ec.QueueSubscribe("game.start", "game-servers", func(req *game.StartRequest) { _, _ = ec.Subscribe("game.start", func(req *game.StartRequest) {
log.Printf("▶️ START empfangen: RoomID=%s", req.RoomID) log.Printf("▶️ START empfangen: RoomID=%s", req.RoomID)
mu.RLock() mu.RLock()
@@ -159,8 +159,8 @@ func main() {
} }
}) })
// 5. HANDLER: INPUT (mit Queue Group) // 5. HANDLER: INPUT (broadcast - alle Pods empfangen, nur der mit dem Spieler reagiert)
_, _ = ec.QueueSubscribe("game.input", "game-servers", func(input *game.ClientInput) { _, _ = ec.Subscribe("game.input", func(input *game.ClientInput) {
mu.RLock() mu.RLock()
room, ok := playerSessions[input.PlayerID] room, ok := playerSessions[input.PlayerID]
mu.RUnlock() mu.RUnlock()

2
k8s/app.yaml
View File

@@ -5,7 +5,7 @@ metadata:
labels: labels:
app: escape-game app: escape-game
spec: spec:
replicas: 1 replicas: 2
selector: selector:
matchLabels: matchLabels:
app: escape-game app: escape-game