Getting container events from Docker SDK

docker-container-events.go

package main

import (
	"context"
	"fmt"
	"log"

	"github.com/docker/docker/api/types"
	"github.com/docker/docker/api/types/events"
	"github.com/docker/docker/api/types/filters"
	"github.com/docker/docker/client"
)

func main() {
	ctx := context.Background()
	cli, err := client.NewClientWithOpts()
	if err != nil {
		log.Fatal(err)
	}
	msgCh, errCh := cli.Events(ctx, types.EventsOptions{
		Filters: filters.NewArgs(filters.KeyValuePair{"type", events.ContainerEventType}),
	})

	for {
		select {
		case err := <-errCh:
			fmt.Println(err)
		case msg := <-msgCh:
			fmt.Println(msg.From, msg.Status)
			switch msg.From {
			case "image1", "image2":
				if msg.Status == "die" {
					log.Fatal(msg.From, "has died")
				}
			}
		}
	}
}