pangolin_mirror/newt
1
0
Fork 0
mirror of https://github.com/fosrl/newt.git synced 2026-03-02 16:56:42 +00:00
Code Issues Packages Projects Releases Wiki Activity

Watching socket and quiteting some events

Browse Source
This commit is contained in:
Owen
2025-09-21 11:32:47 -04:00
parent 60873f0a4f
commit f6e7bfe8ea
2 changed files with 10 additions and 10 deletions
Download Patch File Download Diff File Expand all files Collapse all files

12
docker/client.go
View File

@@ -368,18 +368,18 @@ func NewEventMonitor(socketPath string, enforceNetworkValidation bool, callback
// Start begins monitoring Docker events // Start begins monitoring Docker events
func (em *EventMonitor) Start() error { func (em *EventMonitor) Start() error {
logger.Info("Starting Docker event monitoring") logger.Debug("Starting Docker event monitoring")
// Filter for container events we care about // Filter for container events we care about
eventFilters := filters.NewArgs() eventFilters := filters.NewArgs()
eventFilters.Add("type", "container") eventFilters.Add("type", "container")
eventFilters.Add("event", "create") // eventFilters.Add("event", "create")
eventFilters.Add("event", "start") eventFilters.Add("event", "start")
eventFilters.Add("event", "stop") eventFilters.Add("event", "stop")
eventFilters.Add("event", "destroy") // eventFilters.Add("event", "destroy")
eventFilters.Add("event", "die") // eventFilters.Add("event", "die")
eventFilters.Add("event", "pause") // eventFilters.Add("event", "pause")
eventFilters.Add("event", "unpause") // eventFilters.Add("event", "unpause")
// Start listening for events // Start listening for events
eventCh, errCh := em.client.Events(em.ctx, events.ListOptions{ eventCh, errCh := em.client.Events(em.ctx, events.ListOptions{

8
main.go
View File

@@ -949,7 +949,7 @@ persistent_keepalive_interval=5`, fixKey(privateKey.String()), fixKey(wgData.Pub
if err != nil { if err != nil {
logger.Error("Failed to send Docker socket check response: %v", err) logger.Error("Failed to send Docker socket check response: %v", err)
} else { } else {
logger.Info("Docker socket check response sent: available=%t", isAvailable) logger.Debug("Docker socket check response sent: available=%t", isAvailable)
} }
}) })
@@ -1221,7 +1221,7 @@ persistent_keepalive_interval=5`, fixKey(privateKey.String()), fixKey(wgData.Pub
} }
if blueprintResult.Success { if blueprintResult.Success {
logger.Info("Blueprint applied successfully!") logger.Debug("Blueprint applied successfully!")
} else { } else {
logger.Warn("Blueprint application failed: %s", blueprintResult.Message) logger.Warn("Blueprint application failed: %s", blueprintResult.Message)
} }
@@ -1268,7 +1268,7 @@ persistent_keepalive_interval=5`, fixKey(privateKey.String()), fixKey(wgData.Pub
// Initialize Docker event monitoring if Docker socket is available and monitoring is enabled // Initialize Docker event monitoring if Docker socket is available and monitoring is enabled
if dockerSocket != "" { if dockerSocket != "" {
logger.Info("Initializing Docker event monitoring") logger.Debug("Initializing Docker event monitoring")
dockerEventMonitor, err = docker.NewEventMonitor(dockerSocket, dockerEnforceNetworkValidationBool, func(containers []docker.Container) { dockerEventMonitor, err = docker.NewEventMonitor(dockerSocket, dockerEnforceNetworkValidationBool, func(containers []docker.Container) {
// Send updated container list via websocket when Docker events occur // Send updated container list via websocket when Docker events occur
logger.Debug("Docker event detected, sending updated container list (%d containers)", len(containers)) logger.Debug("Docker event detected, sending updated container list (%d containers)", len(containers))
@@ -1289,7 +1289,7 @@ persistent_keepalive_interval=5`, fixKey(privateKey.String()), fixKey(wgData.Pub
if err != nil { if err != nil {
logger.Error("Failed to start Docker event monitoring: %v", err) logger.Error("Failed to start Docker event monitoring: %v", err)
} else { } else {
logger.Info("Docker event monitoring started successfully") logger.Debug("Docker event monitoring started successfully")
} }
} }
} }