Method startServices

pkg/devspace/devpod/devpod.go:501–558

(ctx devspacecontext.Context, devPod *latest.DevPod, selector targetselector.TargetSelector, opts Options, parent *tomb.Tomb)

}

func (d *devPod) startServices(ctx devspacecontext.Context, devPod *latest.DevPod, selector targetselector.TargetSelector, opts Options, parent *tomb.Tomb) error {
	pluginErr := hook.ExecuteHooks(ctx, map[string]interface{}{}, "devCommand:before:sync", "dev.beforeSync", "devCommand:before:portForwarding", "dev.beforePortForwarding")
	if pluginErr != nil {
		return pluginErr
	}

	// Start sync
	syncDone := parent.NotifyGo(func() error {
		if opts.DisableSync {
			return nil
		}

		// add prefix
		ctx := ctx.WithLogger(ctx.Log().WithPrefixColor("sync  ", "yellow+b"))
		err := sync.StartSync(ctx, devPod, selector, parent)
		return err
	})

	// Start Port Forwarding
	portForwardingDone := parent.NotifyGo(func() error {
		if opts.DisablePortForwarding {
			return nil
		}

		ctx := ctx.WithLogger(ctx.Log().WithPrefixColor("ports ", "yellow+b"))
		return portforwarding.StartPortForwarding(ctx, devPod, selector, parent)
	})

	// wait for both to finish
	<-syncDone
	<-portForwardingDone

	// Start SSH
	sshDone := parent.NotifyGo(func() error {
		// add ssh prefix
		ctx := ctx.WithLogger(ctx.Log().WithPrefixColor("ssh   ", "yellow+b"))
		return ssh.StartSSH(ctx, devPod, selector, parent)
	})

	// Start Reverse Commands
	reverseCommandsDone := parent.NotifyGo(func() error {
		// add proxy prefix
		ctx := ctx.WithLogger(ctx.Log().WithPrefixColor("proxy ", "yellow+b"))
		return proxycommands.StartProxyCommands(ctx, devPod, selector, parent)
	})

	// wait for ssh and reverse commands
	<-sshDone
	<-reverseCommandsDone

	// execute hooks
	pluginErr = hook.ExecuteHooks(ctx, map[string]interface{}{}, "devCommand:after:sync", "dev.afterSync", "devCommand:after:portForwarding", "dev.afterPortForwarding")
	if pluginErr != nil {
		return pluginErr
	}

	return nil
}