Skip to content

Commit 6c4c718

Browse files
committed
only trigger filtered events (default: container)
use DOCKER_EVENT_FILTER for filter by event type (container/image/network/volume ...) or "all" for no filter
1 parent 9e6b17c commit 6c4c718

File tree

1 file changed

+7
-1
lines changed

1 file changed

+7
-1
lines changed

dockerhook.go

Lines changed: 7 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -128,8 +128,14 @@ func main() {
128128
events := make(chan *dockerapi.APIEvents)
129129
assert(docker.AddEventListener(events))
130130
log.Println("info: listening for Docker events...")
131+
filter := "container"
132+
if os.Getenv("DOCKER_EVENT_FILTER") == "" {
133+
filter = os.Getenv("DOCKER_EVENT_FILTER")
134+
}
131135
for msg := range events {
132-
go trigger(hook, msg.Status, msg.ID, docker)
136+
if msg.Type == filter || filter == "all" {
137+
go trigger(hook, msg.Status, msg.ID, docker)
138+
}
133139
}
134140

135141
log.Fatal("fatal: docker event loop closed") // todo: reconnect?

0 commit comments

Comments
 (0)