mirror of
https://github.com/m1k1o/neko-rooms.git
synced 2026-11-02 22:51:34 -06:00
events logs.
This commit is contained in:
@@ -81,6 +81,7 @@ func (e *events) Start() {
|
|||||||
e.logger.Err(err).Msg("failed to list containers")
|
e.logger.Err(err).Msg("failed to list containers")
|
||||||
return
|
return
|
||||||
}
|
}
|
||||||
|
|
||||||
for _, container := range containers {
|
for _, container := range containers {
|
||||||
e.totalRooms.Inc()
|
e.totalRooms.Inc()
|
||||||
if container.State == "running" {
|
if container.State == "running" {
|
||||||
@@ -104,6 +105,9 @@ func (e *events) Start() {
|
|||||||
go func() {
|
go func() {
|
||||||
defer e.wg.Done()
|
defer e.wg.Done()
|
||||||
|
|
||||||
|
e.logger.Info().Msg("docker event listener started")
|
||||||
|
defer e.logger.Info().Msg("docker event listener stopped")
|
||||||
|
|
||||||
for {
|
for {
|
||||||
select {
|
select {
|
||||||
case <-e.ctx.Done():
|
case <-e.ctx.Done():
|
||||||
|
|||||||
Reference in New Issue
Block a user