Method startSync

pkg/devspace/services/sync/controller.go:270–295

(ctx devspacecontext.Context, options *Options, onInitUploadDone chan struct{}, onInitDownloadDone chan struct{}, onDone chan struct{}, onError chan error)

}

func (c *controller) startSync(ctx devspacecontext.Context, options *Options, onInitUploadDone chan struct{}, onInitDownloadDone chan struct{}, onDone chan struct{}, onError chan error) (*sync.Sync, *selector.SelectedPodContainer, error) {
	syncConfig := options.SyncConfig

	container, err := options.Selector.SelectSingleContainer(ctx.Context(), ctx.KubeClient(), ctx.Log())
	if err != nil {
		return nil, nil, errors.Wrap(err, "error selecting container")
	}

	ctx.Log().Debug("Starting sync...")
	syncClient, err := c.initClient(ctx, container.Pod, options.Arch, container.Container.Name, syncConfig, options.Starter, options.Verbose, options.SyncLog)
	if err != nil {
		return nil, nil, errors.Wrap(err, "start sync")
	}

	err = syncClient.Start(onInitUploadDone, onInitDownloadDone, onDone, onError)
	if err != nil {
		return nil, nil, errors.Errorf("Sync error: %v", err)
	}

	localPath, remotePath, err := ParseSyncPath(syncConfig.Path)
	if err == nil {
		ctx.Log().Donef("Sync started on: %s", ansi.Color(fmt.Sprintf("%s <-> %s", localPath, remotePath), "white+b"))
	}

	return syncClient, container, nil
}

func ParseSyncPath(path string) (localPath string, remotePath string, err error) {
	if path == "" {