()
| 204 | |
| 205 | |
| 206 | def test_full_sync(): |
| 207 | print("test with oplog full_sync") |
| 208 | for i in range(len(src_oplog_test_url)): |
| 209 | id = 'oplog_%s' % i |
| 210 | src_url = src_oplog_test_url[i] |
| 211 | print("start run oplog full_sync test %s with url[%s]" % (id, src_url)) |
| 212 | # generate conf |
| 213 | conf = generate_conf('oplog', True, id, src_url, dst_test_url, test_dir, "") |
| 214 | # run |
| 215 | run_full_sync(conf, src_url, dst_test_url) |
| 216 | |
| 217 | print("finish run oplog full_sync test %s with url[%s]" % (id, src_url)) |
| 218 | |
| 219 | print("test with change_stream full_sync") |
| 220 | for i in range(len(src_changestream_test_url)): |
| 221 | id = 'change_stream_%s' % i |
| 222 | src_url = src_changestream_test_url[i] |
| 223 | print("start run change_stream full_sync test %s with url[%s]" % (id, src_url)) |
| 224 | # generate conf |
| 225 | conf = generate_conf('change_stream', True, id, src_url, dst_test_url, test_dir, "") |
| 226 | # run |
| 227 | run_full_sync(conf, src_url, dst_test_url) |
| 228 | |
| 229 | print("finish run change_stream full_sync test %s with url[%s]" % (id, src_url)) |
| 230 | |
| 231 | |
| 232 | def test_incr_sync(): |
no test coverage detected