Method runPlugin

pkg/compose/plugins.go:63–106

(ctx context.Context, project *types.Project, service types.ServiceConfig, command string)

var mux sync.Mutex

func (s *composeService) runPlugin(ctx context.Context, project *types.Project, service types.ServiceConfig, command string) error {
	provider := *service.Provider

	plugin, err := s.getPluginBinaryPath(provider.Type)
	if err != nil {
		return err
	}

	cmd, err := s.setupPluginCommand(ctx, project, service, plugin, command)
	if err != nil {
		return err
	}
	if cmd == nil {
		return nil
	}

	variables, err := s.executePlugin(cmd, command, service)
	if err != nil {
		return err
	}

	if command == "stop" {
		return nil
	}

	mux.Lock()
	defer mux.Unlock()
	for name, s := range project.Services {
		if _, ok := s.DependsOn[service.Name]; ok {
			prefix := strings.ToUpper(service.Name) + "_"
			for key, val := range variables.prefixed {
				s.Environment[prefix+key] = &val
			}
			for key, val := range variables.raw {
				if existing, ok := s.Environment[key]; ok && (existing == nil || *existing != val) {
					logrus.Warnf("provider %q overrides environment variable %q in service %q", service.Name, key, name)
				}
				s.Environment[key] = &val
			}
			project.Services[name] = s
		}
	}
	return nil
}

func (s *composeService) executePlugin(cmd *exec.Cmd, command string, service types.ServiceConfig) (pluginVariables, error) { //nolint:gocyclo
	var action string