Method Events

pkg/compose/events.go:30–81

(ctx context.Context, projectName string, options api.EventsOptions)

)

func (s *composeService) Events(ctx context.Context, projectName string, options api.EventsOptions) error {
	projectName = strings.ToLower(projectName)
	res := s.apiClient().Events(ctx, client.EventsListOptions{
		Filters: projectFilter(projectName),
		Since:   options.Since,
		Until:   options.Until,
	})
	for {
		select {
		case event := <-res.Messages:
			// TODO: support other event types
			if event.Type != "container" {
				continue
			}

			if event.Actor.Attributes[api.OneoffLabel] == "True" {
				// ignore
				continue
			}
			service := event.Actor.Attributes[api.ServiceLabel]
			if len(options.Services) > 0 && !slices.Contains(options.Services, service) {
				continue
			}

			attributes := map[string]string{}
			for k, v := range event.Actor.Attributes {
				if strings.HasPrefix(k, "com.docker.compose.") {
					continue
				}
				attributes[k] = v
			}

			timestamp := time.Unix(event.Time, 0)
			if event.TimeNano != 0 {
				timestamp = time.Unix(0, event.TimeNano)
			}
			err := options.Consumer(api.Event{
				Timestamp:  timestamp,
				Service:    service,
				Container:  event.Actor.ID,
				Status:     string(event.Action),
				Attributes: attributes,
			})
			if err != nil {
				return err
			}

		case err := <-res.Err:
			return err
		}
	}
}