Method Ps

pkg/compose/ps.go:32–134

nolint:gocyclo

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

//nolint:gocyclo
func (s *composeService) Ps(ctx context.Context, projectName string, options api.PsOptions) ([]api.ContainerSummary, error) {
	projectName = strings.ToLower(projectName)
	oneOff := oneOffExclude
	if options.All {
		oneOff = oneOffInclude
	}
	containers, err := s.getContainers(ctx, projectName, oneOff, options.All, options.Services...)
	if err != nil {
		return nil, err
	}

	if len(options.Services) != 0 {
		containers = containers.filter(isService(options.Services...))
	}
	summary := make([]api.ContainerSummary, len(containers))
	eg, ctx := errgroup.WithContext(ctx)
	for i, ctr := range containers {
		eg.Go(func() error {
			publishers := make([]api.PortPublisher, len(ctr.Ports))
			sort.Slice(ctr.Ports, func(i, j int) bool {
				return ctr.Ports[i].PrivatePort < ctr.Ports[j].PrivatePort
			})
			for i, p := range ctr.Ports {
				var url string
				if p.IP.IsValid() {
					url = p.IP.String()
				}
				publishers[i] = api.PortPublisher{
					URL:           url, // TODO(thaJeztah); change this to a netip.Addr ??
					TargetPort:    int(p.PrivatePort),
					PublishedPort: int(p.PublicPort),
					Protocol:      p.Type,
				}
			}

			inspect, err := s.apiClient().ContainerInspect(ctx, ctr.ID, client.ContainerInspectOptions{})
			if err != nil {
				return err
			}

			var (
				health   container.HealthStatus
				exitCode int
			)
			if inspect.Container.State != nil {
				switch inspect.Container.State.Status {
				case container.StateRunning:
					if inspect.Container.State.Health != nil {
						health = inspect.Container.State.Health.Status
					}
				case container.StateExited, container.StateDead:
					exitCode = inspect.Container.State.ExitCode
				}
			}

			var (
				local  int
				mounts []string