@@ -10,9 +10,20 @@ exports[`sync - mongodb > compacting data - invalidate checkpoint 1`] = `
10
10
" checksum" : - 93886621 ,
11
11
" count" : 2 ,
12
12
" priority" : 3 ,
13
+ " subscriptions" : [
14
+ {
15
+ " default" : 0 ,
16
+ },
17
+ ],
13
18
},
14
19
],
15
20
" last_op_id" : " 2" ,
21
+ " streams" : [
22
+ {
23
+ " is_default" : true ,
24
+ " name" : " mybucket" ,
25
+ },
26
+ ],
16
27
" write_checkpoint" : undefined ,
17
28
},
18
29
} ,
@@ -46,6 +57,11 @@ exports[`sync - mongodb > compacting data - invalidate checkpoint 2`] = `
46
57
" checksum" : 499012468 ,
47
58
" count" : 4 ,
48
59
" priority" : 3 ,
60
+ " subscriptions" : [
61
+ {
62
+ " default" : 0 ,
63
+ },
64
+ ],
49
65
},
50
66
],
51
67
" write_checkpoint" : undefined ,
@@ -105,9 +121,20 @@ exports[`sync - mongodb > expiring token 1`] = `
105
121
" checksum" : 0 ,
106
122
" count" : 0 ,
107
123
" priority" : 3 ,
124
+ " subscriptions" : [
125
+ {
126
+ " default" : 0 ,
127
+ },
128
+ ],
108
129
},
109
130
],
110
131
" last_op_id" : " 0" ,
132
+ " streams" : [
133
+ {
134
+ " is_default" : true ,
135
+ " name" : " mybucket" ,
136
+ },
137
+ ],
111
138
" write_checkpoint" : undefined ,
112
139
},
113
140
} ,
@@ -137,9 +164,20 @@ exports[`sync - mongodb > sends checkpoint complete line for empty checkpoint 1`
137
164
" checksum" : - 1221282404 ,
138
165
" count" : 1 ,
139
166
" priority" : 3 ,
167
+ " subscriptions" : [
168
+ {
169
+ " default" : 0 ,
170
+ },
171
+ ],
140
172
},
141
173
],
142
174
" last_op_id" : " 1" ,
175
+ " streams" : [
176
+ {
177
+ " is_default" : true ,
178
+ " name" : " mybucket" ,
179
+ },
180
+ ],
143
181
" write_checkpoint" : undefined ,
144
182
},
145
183
} ,
@@ -193,15 +231,35 @@ exports[`sync - mongodb > sync buckets in order 1`] = `
193
231
" checksum" : 920318466 ,
194
232
" count" : 1 ,
195
233
" priority" : 2 ,
234
+ " subscriptions" : [
235
+ {
236
+ " default" : 0 ,
237
+ },
238
+ ],
196
239
},
197
240
{
198
241
" bucket" : " b1[]" ,
199
242
" checksum" : - 1382098757 ,
200
243
" count" : 1 ,
201
244
" priority" : 1 ,
245
+ " subscriptions" : [
246
+ {
247
+ " default" : 1 ,
248
+ },
249
+ ],
202
250
},
203
251
],
204
252
" last_op_id" : " 2" ,
253
+ " streams" : [
254
+ {
255
+ " is_default" : true ,
256
+ " name" : " b0" ,
257
+ },
258
+ {
259
+ " is_default" : true ,
260
+ " name" : " b1" ,
261
+ },
262
+ ],
205
263
" write_checkpoint" : undefined ,
206
264
},
207
265
} ,
@@ -267,9 +325,20 @@ exports[`sync - mongodb > sync global data 1`] = `
267
325
" checksum" : - 93886621 ,
268
326
" count" : 2 ,
269
327
" priority" : 3 ,
328
+ " subscriptions" : [
329
+ {
330
+ " default" : 0 ,
331
+ },
332
+ ],
270
333
},
271
334
],
272
335
" last_op_id" : " 2" ,
336
+ " streams" : [
337
+ {
338
+ " is_default" : true ,
339
+ " name" : " mybucket" ,
340
+ },
341
+ ],
273
342
" write_checkpoint" : undefined ,
274
343
},
275
344
} ,
@@ -319,21 +388,50 @@ exports[`sync - mongodb > sync interrupts low-priority buckets on new checkpoint
319
388
" checksum" : - 659831575 ,
320
389
" count" : 2000 ,
321
390
" priority" : 2 ,
391
+ " subscriptions" : [
392
+ {
393
+ " default" : 0 ,
394
+ },
395
+ ],
322
396
},
323
397
{
324
398
" bucket" : " b0b[]" ,
325
399
" checksum" : - 659831575 ,
326
400
" count" : 2000 ,
327
401
" priority" : 2 ,
402
+ " subscriptions" : [
403
+ {
404
+ " default" : 1 ,
405
+ },
406
+ ],
328
407
},
329
408
{
330
409
" bucket" : " b1[]" ,
331
410
" checksum" : - 1096116670 ,
332
411
" count" : 1 ,
333
412
" priority" : 1 ,
413
+ " subscriptions" : [
414
+ {
415
+ " default" : 2 ,
416
+ },
417
+ ],
334
418
},
335
419
],
336
420
" last_op_id" : " 4001" ,
421
+ " streams" : [
422
+ {
423
+ " is_default" : true ,
424
+ " name" : " b0a" ,
425
+ },
426
+ {
427
+ " is_default" : true ,
428
+ " name" : " b0b" ,
429
+ },
430
+ {
431
+ " is_default" : true ,
432
+ " name" : " b1" ,
433
+ },
434
+ ],
337
435
" write_checkpoint" : undefined ,
338
436
},
339
437
} ,
@@ -380,18 +478,33 @@ exports[`sync - mongodb > sync interrupts low-priority buckets on new checkpoint
380
478
" checksum" : 883076828 ,
381
479
" count" : 2001 ,
382
480
" priority" : 2 ,
481
+ " subscriptions" : [
482
+ {
483
+ " default" : 0 ,
484
+ },
485
+ ],
383
486
},
384
487
{
385
488
" bucket" : " b0b[]" ,
386
489
" checksum" : 883076828 ,
387
490
" count" : 2001 ,
388
491
" priority" : 2 ,
492
+ " subscriptions" : [
493
+ {
494
+ " default" : 1 ,
495
+ },
496
+ ],
389
497
},
390
498
{
391
499
" bucket" : " b1[]" ,
392
500
" checksum" : 1841937527 ,
393
501
" count" : 2 ,
394
502
" priority" : 1 ,
503
+ " subscriptions" : [
504
+ {
505
+ " default" : 2 ,
506
+ },
507
+ ],
395
508
},
396
509
],
397
510
" write_checkpoint" : undefined ,
@@ -466,9 +579,20 @@ exports[`sync - mongodb > sync legacy non-raw data 1`] = `
466
579
" checksum" : - 852817836 ,
467
580
" count" : 1 ,
468
581
" priority" : 3 ,
582
+ " subscriptions" : [
583
+ {
584
+ " default" : 0 ,
585
+ },
586
+ ],
469
587
},
470
588
],
471
589
" last_op_id" : " 1" ,
590
+ " streams" : [
591
+ {
592
+ " is_default" : true ,
593
+ " name" : " mybucket" ,
594
+ },
595
+ ],
472
596
" write_checkpoint" : undefined ,
473
597
},
474
598
} ,
@@ -514,9 +638,20 @@ exports[`sync - mongodb > sync updates to data query only 1`] = `
514
638
" checksum" : 0 ,
515
639
" count" : 0 ,
516
640
" priority" : 3 ,
641
+ " subscriptions" : [
642
+ {
643
+ " default" : 0 ,
644
+ },
645
+ ],
517
646
},
518
647
],
519
648
" last_op_id" : " 1" ,
649
+ " streams" : [
650
+ {
651
+ " is_default" : true ,
652
+ " name" : " by_user" ,
653
+ },
654
+ ],
520
655
" write_checkpoint" : undefined ,
521
656
},
522
657
} ,
@@ -540,6 +675,11 @@ exports[`sync - mongodb > sync updates to data query only 2`] = `
540
675
" checksum" : 1418351250 ,
541
676
" count" : 1 ,
542
677
" priority" : 3 ,
678
+ " subscriptions" : [
679
+ {
680
+ " default" : 0 ,
681
+ },
682
+ ],
543
683
},
544
684
],
545
685
" write_checkpoint" : undefined ,
@@ -582,9 +722,20 @@ exports[`sync - mongodb > sync updates to global data 1`] = `
582
722
" checksum" : 0 ,
583
723
" count" : 0 ,
584
724
" priority" : 3 ,
725
+ " subscriptions" : [
726
+ {
727
+ " default" : 0 ,
728
+ },
729
+ ],
585
730
},
586
731
],
587
732
" last_op_id" : " 0" ,
733
+ " streams" : [
734
+ {
735
+ " is_default" : true ,
736
+ " name" : " mybucket" ,
737
+ },
738
+ ],
588
739
" write_checkpoint" : undefined ,
589
740
},
590
741
} ,
@@ -608,6 +759,11 @@ exports[`sync - mongodb > sync updates to global data 2`] = `
608
759
" checksum" : 920318466 ,
609
760
" count" : 1 ,
610
761
" priority" : 3 ,
762
+ " subscriptions" : [
763
+ {
764
+ " default" : 0 ,
765
+ },
766
+ ],
611
767
},
612
768
],
613
769
" write_checkpoint" : undefined ,
@@ -652,6 +808,11 @@ exports[`sync - mongodb > sync updates to global data 3`] = `
652
808
" checksum" : - 93886621 ,
653
809
" count" : 2 ,
654
810
" priority" : 3 ,
811
+ " subscriptions" : [
812
+ {
813
+ " default" : 0 ,
814
+ },
815
+ ],
655
816
},
656
817
],
657
818
" write_checkpoint" : undefined ,
@@ -690,6 +851,12 @@ exports[`sync - mongodb > sync updates to parameter query + data 1`] = `
690
851
" checkpoint" : {
691
852
" buckets" : [],
692
853
" last_op_id" : " 0" ,
854
+ " streams" : [
855
+ {
856
+ " is_default" : true ,
857
+ " name" : " by_user" ,
858
+ },
859
+ ],
693
860
" write_checkpoint" : undefined ,
694
861
},
695
862
} ,
@@ -713,6 +880,11 @@ exports[`sync - mongodb > sync updates to parameter query + data 2`] = `
713
880
" checksum" : 1418351250 ,
714
881
" count" : 1 ,
715
882
" priority" : 3 ,
883
+ " subscriptions" : [
884
+ {
885
+ " default" : 0 ,
886
+ },
887
+ ],
716
888
},
717
889
],
718
890
" write_checkpoint" : undefined ,
@@ -751,6 +923,12 @@ exports[`sync - mongodb > sync updates to parameter query only 1`] = `
751
923
" checkpoint" : {
752
924
" buckets" : [],
753
925
" last_op_id" : " 0" ,
926
+ " streams" : [
927
+ {
928
+ " is_default" : true ,
929
+ " name" : " by_user" ,
930
+ },
931
+ ],
754
932
" write_checkpoint" : undefined ,
755
933
},
756
934
} ,
@@ -774,6 +952,11 @@ exports[`sync - mongodb > sync updates to parameter query only 2`] = `
774
952
" checksum" : 0 ,
775
953
" count" : 0 ,
776
954
" priority" : 3 ,
955
+ " subscriptions" : [
956
+ {
957
+ " default" : 0 ,
958
+ },
959
+ ],
777
960
},
778
961
],
779
962
" write_checkpoint" : undefined ,
0 commit comments