Function StartSyncFromCmd

pkg/devspace/services/sync/sync.go:17–61

StartSyncFromCmd starts a new sync from command

(ctx devspacecontext.Context, selector targetselector.TargetSelector, name string, syncConfig *latest.SyncConfig, noWatch bool)

// StartSyncFromCmd starts a new sync from command
func StartSyncFromCmd(ctx devspacecontext.Context, selector targetselector.TargetSelector, name string, syncConfig *latest.SyncConfig, noWatch bool) error {
	ctx, parent := ctx.WithNewTomb()
	options := &Options{
		Name:           name,
		SyncConfig:     syncConfig,
		Selector:       selector,
		RestartOnError: true,
		SyncLog:        ctx.Log(),

		Verbose: ctx.Log().GetLevel() == logrus.DebugLevel,
	}

	// Start the tomb
	<-parent.NotifyGo(func() error {
		// this is needed as otherwise the context
		// is cancelled alongside the tomb
		parent.Go(func() error {
			<-ctx.Context().Done()
			return nil
		})

		return NewController().Start(ctx, options, parent)
	})

	// Handle no watch
	if noWatch {
		select {
		case <-parent.Dead():
			return parent.Err()
		default:
			parent.Kill(nil)
			_ = parent.Wait()
			return nil
		}
	}

	// Handle interrupt
	select {
	case <-parent.Dead():
		return parent.Err()
	case <-ctx.Context().Done():
		_ = parent.Wait()
		return nil
	}
}

// StartSync starts the syncing functionality
func StartSync(ctx devspacecontext.Context, devPod *latest.DevPod, selector targetselector.TargetSelector, parent *tomb.Tomb) (retErr error) {