Method watch

cli/command/container/stats.go:386–403

watch ranges over the passed in event chan and processes the events based on the handlers created for a given action. To stop watching, close the event chan.

(ctx context.Context, c <-chan events.Message)

// handlers created for a given action.
// To stop watching, close the event chan.
func (eh *eventHandler) watch(ctx context.Context, c <-chan events.Message) {
	for e := range c {
		h, exists := eh.handlers[e.Action]
		if !exists {
			continue
		}
		if e.Actor.ID == "" {
			log.G(ctx).WithField("event", e).Errorf("event handler: received %s event with empty ID", e.Action)
			continue
		}
		logger := log.G(ctx).WithFields(log.Fields{
			"event":     e.Action,
			"container": e.Actor.ID,
		})

		go h(log.WithLogger(ctx, logger), e)
	}
}