mirrors/neko
2
0
Fork 0
mirror of https://github.com/m1k1o/neko.git synced 2025-10-26 11:11:59 +00:00
Code Issues Packages Projects Releases Wiki Activity

add some logs

Browse Source
This commit is contained in:
Sayan Samanta 2025-09-26 17:26:52 -07:00
parent fc6db6a83f
commit ae140ed7c1
1 changed files with 4 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
server/internal/plugins/scaletozero/manager.go
View File

@ -48,6 +48,7 @@ func (m *Manager) Start() error {
}
m.pending++
m.logger.Info().Msgf("connection started, disabling scale-to-zero (pending: %d)", m.pending)
m.ctrl.Disable(context.Background())
})
@ -57,7 +58,9 @@ func (m *Manager) Start() error {
if m.shutdown {
return
}
m.pending--
m.logger.Info().Msgf("connection started, disabling scale-to-zero (pending: %d)", m.pending)
m.ctrl.Enable(context.Background())
})
@ -69,6 +72,7 @@ func (m *Manager) Shutdown() error {
defer m.mu.Unlock()
m.shutdown = true
m.logger.Info().Msgf("shutdown started, re-enabling scale-to-zero (pending: %d)", m.pending)
for i := 0; i < m.pending; i++ {
m.ctrl.Enable(context.Background())
}