Method Start

common/sync/task/sync.go:100–137

Start makes a first sync and setup watchers

(ctx context.Context, withWatches bool)

// Start makes a first sync and setup watchers
func (s *Sync) Start(ctx context.Context, withWatches bool) {

	// Init processor
	s.processor = proc.NewConnectedProcessor(ctx, s.cmd)
	if s.SkipTargetChecks {
		s.processor.SkipTargetChecks = true
	}
	s.patchChan = s.processor.PatchChan
	if s.patchListener != nil {
		s.processor.PatchListener = s.patchListener
	}
	s.processor.Ignores = s.Ignores
	s.processor.Start()

	// Init EchoFilter
	if s.Direction == model.DirectionBi {
		s.echoFilter = filters.NewEchoFilter()
		s.processor.SetLocksChan(s.echoFilter.GetLocksChan())
		s.echoFilter.Start()
	}

	if withWatches {
		s.startWatchers(ctx)
	} else if s.watchConn != nil {
		go func() {
			<-time.After(2 * time.Second)
			s.watchConn <- &model.EndpointStatus{
				WatchConnection: model.WatchConnected,
				EndpointInfo:    s.Source.GetEndpointInfo(),
			}
			s.watchConn <- &model.EndpointStatus{
				WatchConnection: model.WatchConnected,
				EndpointInfo:    s.Target.GetEndpointInfo(),
			}
		}()
	}

}

// Pause should pause the sync
func (s *Sync) Pause(ctx context.Context) {