package main

import (
	"context"
	"fmt"
	"github.com/docker/docker/api/types"
	"github.com/docker/docker/client"
	"io"
)

func main() {

	cli, err := client.NewEnvClient()
	if err != nil {
		panic(err)
	}

	messages, errs := cli.Events(context.Background(), types.EventsOptions{})

EventLoop:
	for {
		select {
		case err := <-errs:
			if err != nil && err != io.EOF {
				panic(err)
			}
			if err != nil && err == io.EOF {
				fmt.Printf("lost connection with Docker. exiting\n")
				break EventLoop
			}
		case message := <-messages:
			fmt.Printf("%+v\n\n", message)
		}
	}

}