Function runHook

pkg/devspace/hook/hook.go:138–176

(ctx devspacecontext.Context, hookConfig *latest.HookConfig, extraEnv map[string]string, event string)

}

func runHook(ctx devspacecontext.Context, hookConfig *latest.HookConfig, extraEnv map[string]string, event string) error {
	// Determine output writer
	var writer io.WriteCloser
	if hookConfig.Silent {
		writer = logpkg.WithNopCloser(&bytes.Buffer{})
	} else if ctx.Log() == logpkg.GetInstance() {
		writer = logpkg.WithNopCloser(stdout)
	} else {
		writer = ctx.Log().Writer(logrus.InfoLevel, false)
	}
	defer writer.Close()

	// Decide which hook type to use
	var hook Hook
	if hookConfig.Container != nil {
		if hookConfig.Upload != nil {
			hook = NewRemoteHook(NewUploadHook())
		} else if hookConfig.Download != nil {
			hook = NewRemoteHook(NewDownloadHook())
		} else if hookConfig.Logs != nil {
			// we use another waiting strategy here, because the pod might has finished already
			hook = NewRemoteHookWithWaitingStrategy(NewLogsHook(writer), targetselector.NewUntilNotWaitingStrategy(time.Second*2))
		} else if hookConfig.Wait != nil {
			hook = NewWaitHook()
		} else {
			hook = NewRemoteHook(NewRemoteCommandHook(writer, writer))
		}
	} else {
		hook = NewLocalCommandHook(writer, writer)
	}

	// Execute the hook
	err := executeHook(ctx, hookConfig, writer, extraEnv, hook, event)
	if err != nil {
		return err
	}

	return nil
}

func executeHook(ctx devspacecontext.Context, hookConfig *latest.HookConfig, hookWriter io.WriteCloser, extraEnv map[string]string, hook Hook, event string) error {
	hookLog := ctx.Log()