Method startService

pkg/compose/convergence.go:519–563

(ctx context.Context,
	project *types.Project, service types.ServiceConfig,
	containers Containers, listener api.ContainerEventListener,
	timeout time.Duration,
)

}

func (s *composeService) startService(ctx context.Context,
	project *types.Project, service types.ServiceConfig,
	containers Containers, listener api.ContainerEventListener,
	timeout time.Duration,
) error {
	if service.Deploy != nil && service.Deploy.Replicas != nil && *service.Deploy.Replicas == 0 {
		return nil
	}

	err := s.waitDependencies(ctx, project, service.Name, service.DependsOn, containers, timeout)
	if err != nil {
		return err
	}

	if len(containers) == 0 {
		if service.GetScale() == 0 {
			return nil
		}
		return fmt.Errorf("service %q has no container to start", service.Name)
	}

	serviceContainers := containers.filter(isService(service.Name), isNotOneOff)
	toStart := serviceContainers.filter(isNotRunning)
	if len(toStart) == 0 {
		return nil
	}

	// pre_start runs once per service, only when no replica is already running
	// (e.g. initial up, force-recreate, or spec change). per_replica: false is
	// the only currently supported mode. Pick the replica with the lowest
	// container-number so the choice is deterministic regardless of the order
	// the daemon returns containers in.
	if len(service.PreStart) > 0 && len(serviceContainers) == len(toStart) {
		if err := s.runPreStart(ctx, project, service, lowestNumberedContainer(toStart), listener); err != nil {
			return err
		}
	}

	for _, ctr := range toStart {
		if err := s.startServiceContainer(ctx, project, service, ctr, listener); err != nil {
			return err
		}
	}
	return nil
}

func (s *composeService) startServiceContainer(ctx context.Context, project *types.Project, service types.ServiceConfig, ctr container.Summary, listener api.ContainerEventListener) error {
	if err := s.injectSecrets(ctx, project, service, ctr.ID); err != nil {