Method Top

pkg/compose/top.go:29–68

(ctx context.Context, projectName string, services []string)

)

func (s *composeService) Top(ctx context.Context, projectName string, services []string) ([]api.ContainerProcSummary, error) {
	projectName = strings.ToLower(projectName)
	var containers Containers
	containers, err := s.getContainers(ctx, projectName, oneOffInclude, false)
	if err != nil {
		return nil, err
	}
	if len(services) > 0 {
		containers = containers.filter(isService(services...))
	}
	summary := make([]api.ContainerProcSummary, len(containers))
	eg, ctx := errgroup.WithContext(ctx)
	for i, ctr := range containers {
		eg.Go(func() error {
			topContent, err := s.apiClient().ContainerTop(ctx, ctr.ID, client.ContainerTopOptions{
				Arguments: []string{},
			})
			if err != nil {
				return err
			}
			name := getCanonicalContainerName(ctr)
			s := api.ContainerProcSummary{
				ID:        ctr.ID,
				Name:      name,
				Processes: topContent.Processes,
				Titles:    topContent.Titles,
				Service:   name,
			}
			if service, exists := ctr.Labels[api.ServiceLabel]; exists {
				s.Service = service
			}
			if replica, exists := ctr.Labels[api.ContainerNumberLabel]; exists {
				s.Replica = replica
			}
			summary[i] = s
			return nil
		})
	}
	return summary, eg.Wait()
}