starred/godoxy-yusing
1
0
Fork 0
mirror of https://github.com/yusing/godoxy.git synced 2026-04-25 01:38:30 +02:00
Code Issues 18 Packages Projects Releases 10 Wiki Activity

refactor(docker_watcher): rename docker_events to dockerEvents

Browse Source
This commit is contained in:
yusing
2025-09-13 23:50:13 +08:00
parent 1c080e067d
commit 58a2dc73dd
1 changed files with 13 additions and 12 deletions
Download Patch File Download Diff File Expand all files Collapse all files

25
internal/watcher/docker_watcher.go
View File

@@ -5,7 +5,7 @@ import (
"errors" "errors"
"time" "time"
docker_events "github.com/docker/docker/api/types/events" dockerEvents "github.com/docker/docker/api/types/events"
"github.com/docker/docker/api/types/filters" "github.com/docker/docker/api/types/filters"
"github.com/docker/docker/client" "github.com/docker/docker/client"
"github.com/rs/zerolog/log" "github.com/rs/zerolog/log"
@@ -16,19 +16,19 @@ import (
type ( type (
DockerWatcher string DockerWatcher string
DockerListOptions = docker_events.ListOptions DockerListOptions = dockerEvents.ListOptions
) )
// https://docs.docker.com/reference/api/engine/version/v1.47/#tag/System/operation/SystemPingHead // https://docs.docker.com/reference/api/engine/version/v1.47/#tag/System/operation/SystemPingHead
var ( var (
DockerFilterContainer = filters.Arg("type", string(docker_events.ContainerEventType)) DockerFilterContainer = filters.Arg("type", string(dockerEvents.ContainerEventType))
DockerFilterStart = filters.Arg("event", string(docker_events.ActionStart)) DockerFilterStart = filters.Arg("event", string(dockerEvents.ActionStart))
DockerFilterStop = filters.Arg("event", string(docker_events.ActionStop)) DockerFilterStop = filters.Arg("event", string(dockerEvents.ActionStop))
DockerFilterDie = filters.Arg("event", string(docker_events.ActionDie)) DockerFilterDie = filters.Arg("event", string(dockerEvents.ActionDie))
DockerFilterDestroy = filters.Arg("event", string(docker_events.ActionDestroy)) DockerFilterDestroy = filters.Arg("event", string(dockerEvents.ActionDestroy))
DockerFilterKill = filters.Arg("event", string(docker_events.ActionKill)) DockerFilterKill = filters.Arg("event", string(dockerEvents.ActionKill))
DockerFilterPause = filters.Arg("event", string(docker_events.ActionPause)) DockerFilterPause = filters.Arg("event", string(dockerEvents.ActionPause))
DockerFilterUnpause = filters.Arg("event", string(docker_events.ActionUnPause)) DockerFilterUnpause = filters.Arg("event", string(dockerEvents.ActionUnPause))
NewDockerFilter = filters.NewArgs NewDockerFilter = filters.NewArgs
@@ -102,6 +102,7 @@ func (w DockerWatcher) EventsWithOptions(ctx context.Context, options DockerList
retry := time.NewTicker(dockerWatcherRetryInterval) retry := time.NewTicker(dockerWatcherRetryInterval)
defer retry.Stop() defer retry.Stop()
ok := false ok := false
outer:
for !ok { for !ok {
select { select {
case <-ctx.Done(): case <-ctx.Done():
@@ -109,7 +110,7 @@ func (w DockerWatcher) EventsWithOptions(ctx context.Context, options DockerList
case <-retry.C: case <-retry.C:
if checkConnection(ctx, client) { if checkConnection(ctx, client) {
ok = true ok = true
break break outer
} }
} }
} }
@@ -134,7 +135,7 @@ func (w DockerWatcher) parseError(err error) gperr.Error {
return gperr.Wrap(err) return gperr.Wrap(err)
} }
func (w DockerWatcher) handleEvent(event docker_events.Message, ch chan<- Event) { func (w DockerWatcher) handleEvent(event dockerEvents.Message, ch chan<- Event) {
action, ok := events.DockerEventMap[event.Action] action, ok := events.DockerEventMap[event.Action]
if !ok { if !ok {
return return