code: func (s *StateSyncer) Run() {
  	if s.ClusterSize == nil {
  		panic("ClusterSize not set")
  	}
  	s.runFSM(fullSyncState, s.nextFSMState)
  }
docs: // Run is the long running method to perform state synchronization
  // between local and remote servers.