@@ -10,9 +10,20 @@ exports[`sync - mongodb > compacting data - invalidate checkpoint 1`] = `
1010 " checksum" : - 93886621 ,
1111 " count" : 2 ,
1212 " priority" : 3 ,
13+ " subscriptions" : [
14+ {
15+ " default" : 0 ,
16+ },
17+ ],
1318 },
1419 ],
1520 " last_op_id" : " 2" ,
21+ " streams" : [
22+ {
23+ " is_default" : true ,
24+ " name" : " mybucket" ,
25+ },
26+ ],
1627 " write_checkpoint" : undefined ,
1728 },
1829 } ,
@@ -46,6 +57,11 @@ exports[`sync - mongodb > compacting data - invalidate checkpoint 2`] = `
4657 " checksum" : 499012468 ,
4758 " count" : 4 ,
4859 " priority" : 3 ,
60+ " subscriptions" : [
61+ {
62+ " default" : 0 ,
63+ },
64+ ],
4965 },
5066 ],
5167 " write_checkpoint" : undefined ,
@@ -105,9 +121,20 @@ exports[`sync - mongodb > expiring token 1`] = `
105121 " checksum" : 0 ,
106122 " count" : 0 ,
107123 " priority" : 3 ,
124+ " subscriptions" : [
125+ {
126+ " default" : 0 ,
127+ },
128+ ],
108129 },
109130 ],
110131 " last_op_id" : " 0" ,
132+ " streams" : [
133+ {
134+ " is_default" : true ,
135+ " name" : " mybucket" ,
136+ },
137+ ],
111138 " write_checkpoint" : undefined ,
112139 },
113140 } ,
@@ -137,9 +164,20 @@ exports[`sync - mongodb > sends checkpoint complete line for empty checkpoint 1`
137164 " checksum" : - 1221282404 ,
138165 " count" : 1 ,
139166 " priority" : 3 ,
167+ " subscriptions" : [
168+ {
169+ " default" : 0 ,
170+ },
171+ ],
140172 },
141173 ],
142174 " last_op_id" : " 1" ,
175+ " streams" : [
176+ {
177+ " is_default" : true ,
178+ " name" : " mybucket" ,
179+ },
180+ ],
143181 " write_checkpoint" : undefined ,
144182 },
145183 } ,
@@ -193,15 +231,35 @@ exports[`sync - mongodb > sync buckets in order 1`] = `
193231 " checksum" : 920318466 ,
194232 " count" : 1 ,
195233 " priority" : 2 ,
234+ " subscriptions" : [
235+ {
236+ " default" : 0 ,
237+ },
238+ ],
196239 },
197240 {
198241 " bucket" : " b1[]" ,
199242 " checksum" : - 1382098757 ,
200243 " count" : 1 ,
201244 " priority" : 1 ,
245+ " subscriptions" : [
246+ {
247+ " default" : 1 ,
248+ },
249+ ],
202250 },
203251 ],
204252 " 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+ ],
205263 " write_checkpoint" : undefined ,
206264 },
207265 } ,
@@ -267,9 +325,20 @@ exports[`sync - mongodb > sync global data 1`] = `
267325 " checksum" : - 93886621 ,
268326 " count" : 2 ,
269327 " priority" : 3 ,
328+ " subscriptions" : [
329+ {
330+ " default" : 0 ,
331+ },
332+ ],
270333 },
271334 ],
272335 " last_op_id" : " 2" ,
336+ " streams" : [
337+ {
338+ " is_default" : true ,
339+ " name" : " mybucket" ,
340+ },
341+ ],
273342 " write_checkpoint" : undefined ,
274343 },
275344 } ,
@@ -319,21 +388,50 @@ exports[`sync - mongodb > sync interrupts low-priority buckets on new checkpoint
319388 " checksum" : - 659831575 ,
320389 " count" : 2000 ,
321390 " priority" : 2 ,
391+ " subscriptions" : [
392+ {
393+ " default" : 0 ,
394+ },
395+ ],
322396 },
323397 {
324398 " bucket" : " b0b[]" ,
325399 " checksum" : - 659831575 ,
326400 " count" : 2000 ,
327401 " priority" : 2 ,
402+ " subscriptions" : [
403+ {
404+ " default" : 1 ,
405+ },
406+ ],
328407 },
329408 {
330409 " bucket" : " b1[]" ,
331410 " checksum" : - 1096116670 ,
332411 " count" : 1 ,
333412 " priority" : 1 ,
413+ " subscriptions" : [
414+ {
415+ " default" : 2 ,
416+ },
417+ ],
334418 },
335419 ],
336420 " 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+ ],
337435 " write_checkpoint" : undefined ,
338436 },
339437 } ,
@@ -380,18 +478,33 @@ exports[`sync - mongodb > sync interrupts low-priority buckets on new checkpoint
380478 " checksum" : 883076828 ,
381479 " count" : 2001 ,
382480 " priority" : 2 ,
481+ " subscriptions" : [
482+ {
483+ " default" : 0 ,
484+ },
485+ ],
383486 },
384487 {
385488 " bucket" : " b0b[]" ,
386489 " checksum" : 883076828 ,
387490 " count" : 2001 ,
388491 " priority" : 2 ,
492+ " subscriptions" : [
493+ {
494+ " default" : 1 ,
495+ },
496+ ],
389497 },
390498 {
391499 " bucket" : " b1[]" ,
392500 " checksum" : 1841937527 ,
393501 " count" : 2 ,
394502 " priority" : 1 ,
503+ " subscriptions" : [
504+ {
505+ " default" : 2 ,
506+ },
507+ ],
395508 },
396509 ],
397510 " write_checkpoint" : undefined ,
@@ -466,9 +579,20 @@ exports[`sync - mongodb > sync legacy non-raw data 1`] = `
466579 " checksum" : - 852817836 ,
467580 " count" : 1 ,
468581 " priority" : 3 ,
582+ " subscriptions" : [
583+ {
584+ " default" : 0 ,
585+ },
586+ ],
469587 },
470588 ],
471589 " last_op_id" : " 1" ,
590+ " streams" : [
591+ {
592+ " is_default" : true ,
593+ " name" : " mybucket" ,
594+ },
595+ ],
472596 " write_checkpoint" : undefined ,
473597 },
474598 } ,
@@ -514,9 +638,20 @@ exports[`sync - mongodb > sync updates to data query only 1`] = `
514638 " checksum" : 0 ,
515639 " count" : 0 ,
516640 " priority" : 3 ,
641+ " subscriptions" : [
642+ {
643+ " default" : 0 ,
644+ },
645+ ],
517646 },
518647 ],
519648 " last_op_id" : " 1" ,
649+ " streams" : [
650+ {
651+ " is_default" : true ,
652+ " name" : " by_user" ,
653+ },
654+ ],
520655 " write_checkpoint" : undefined ,
521656 },
522657 } ,
@@ -540,6 +675,11 @@ exports[`sync - mongodb > sync updates to data query only 2`] = `
540675 " checksum" : 1418351250 ,
541676 " count" : 1 ,
542677 " priority" : 3 ,
678+ " subscriptions" : [
679+ {
680+ " default" : 0 ,
681+ },
682+ ],
543683 },
544684 ],
545685 " write_checkpoint" : undefined ,
@@ -582,9 +722,20 @@ exports[`sync - mongodb > sync updates to global data 1`] = `
582722 " checksum" : 0 ,
583723 " count" : 0 ,
584724 " priority" : 3 ,
725+ " subscriptions" : [
726+ {
727+ " default" : 0 ,
728+ },
729+ ],
585730 },
586731 ],
587732 " last_op_id" : " 0" ,
733+ " streams" : [
734+ {
735+ " is_default" : true ,
736+ " name" : " mybucket" ,
737+ },
738+ ],
588739 " write_checkpoint" : undefined ,
589740 },
590741 } ,
@@ -608,6 +759,11 @@ exports[`sync - mongodb > sync updates to global data 2`] = `
608759 " checksum" : 920318466 ,
609760 " count" : 1 ,
610761 " priority" : 3 ,
762+ " subscriptions" : [
763+ {
764+ " default" : 0 ,
765+ },
766+ ],
611767 },
612768 ],
613769 " write_checkpoint" : undefined ,
@@ -652,6 +808,11 @@ exports[`sync - mongodb > sync updates to global data 3`] = `
652808 " checksum" : - 93886621 ,
653809 " count" : 2 ,
654810 " priority" : 3 ,
811+ " subscriptions" : [
812+ {
813+ " default" : 0 ,
814+ },
815+ ],
655816 },
656817 ],
657818 " write_checkpoint" : undefined ,
@@ -690,6 +851,12 @@ exports[`sync - mongodb > sync updates to parameter query + data 1`] = `
690851 " checkpoint" : {
691852 " buckets" : [],
692853 " last_op_id" : " 0" ,
854+ " streams" : [
855+ {
856+ " is_default" : true ,
857+ " name" : " by_user" ,
858+ },
859+ ],
693860 " write_checkpoint" : undefined ,
694861 },
695862 } ,
@@ -713,6 +880,11 @@ exports[`sync - mongodb > sync updates to parameter query + data 2`] = `
713880 " checksum" : 1418351250 ,
714881 " count" : 1 ,
715882 " priority" : 3 ,
883+ " subscriptions" : [
884+ {
885+ " default" : 0 ,
886+ },
887+ ],
716888 },
717889 ],
718890 " write_checkpoint" : undefined ,
@@ -751,6 +923,12 @@ exports[`sync - mongodb > sync updates to parameter query only 1`] = `
751923 " checkpoint" : {
752924 " buckets" : [],
753925 " last_op_id" : " 0" ,
926+ " streams" : [
927+ {
928+ " is_default" : true ,
929+ " name" : " by_user" ,
930+ },
931+ ],
754932 " write_checkpoint" : undefined ,
755933 },
756934 } ,
@@ -774,6 +952,11 @@ exports[`sync - mongodb > sync updates to parameter query only 2`] = `
774952 " checksum" : 0 ,
775953 " count" : 0 ,
776954 " priority" : 3 ,
955+ " subscriptions" : [
956+ {
957+ " default" : 0 ,
958+ },
959+ ],
777960 },
778961 ],
779962 " write_checkpoint" : undefined ,
0 commit comments