Function runEvents

cli/command/system/events.go:59–90

(ctx context.Context, dockerCLI command.Cli, options *eventsOptions)

}

func runEvents(ctx context.Context, dockerCLI command.Cli, options *eventsOptions) error {
	tmpl, err := makeTemplate(options.format)
	if err != nil {
		return cli.StatusError{
			StatusCode: 64,
			Status:     "Error parsing format: " + err.Error(),
		}
	}
	ctx, cancel := context.WithCancel(ctx)
	eventRes := dockerCLI.Client().Events(ctx, client.EventsListOptions{
		Since:   options.since,
		Until:   options.until,
		Filters: options.filter.Value(),
	})
	defer cancel()

	out := dockerCLI.Out()

	for {
		select {
		case event := <-eventRes.Messages:
			if err := handleEvent(out, event, tmpl); err != nil {
				return err
			}
		case err := <-eventRes.Err:
			if err == io.EOF {
				return nil
			}
			return err
		}
	}
}

func handleEvent(out io.Writer, event events.Message, tmpl *template.Template) error {
	if tmpl == nil {