File tree
24 files changed
+546
-75
lines changed- google/cloud/pubsublite_v1
- services
- admin_service
- transports
- cursor_service
- transports
- partition_assignment_service/transports
- publisher_service/transports
- subscriber_service/transports
- topic_stats_service/transports
- types
- tests/unit/gapic/pubsublite_v1
24 files changed
+546
-75
lines changedLines changed: 18 additions & 18 deletions
Original file line number | Diff line number | Diff line change | |
---|---|---|---|
| |||
260 | 260 |
| |
261 | 261 |
| |
262 | 262 |
| |
263 |
| - | |
| 263 | + | |
264 | 264 |
| |
265 | 265 |
| |
266 | 266 |
| |
| |||
332 | 332 |
| |
333 | 333 |
| |
334 | 334 |
| |
335 |
| - | |
| 335 | + | |
336 | 336 |
| |
337 | 337 |
| |
338 | 338 |
| |
| |||
401 | 401 |
| |
402 | 402 |
| |
403 | 403 |
| |
404 |
| - | |
| 404 | + | |
405 | 405 |
| |
406 | 406 |
| |
407 | 407 |
| |
| |||
474 | 474 |
| |
475 | 475 |
| |
476 | 476 |
| |
477 |
| - | |
| 477 | + | |
478 | 478 |
| |
479 | 479 |
| |
480 | 480 |
| |
| |||
556 | 556 |
| |
557 | 557 |
| |
558 | 558 |
| |
559 |
| - | |
| 559 | + | |
560 | 560 |
| |
561 | 561 |
| |
562 | 562 |
| |
| |||
624 | 624 |
| |
625 | 625 |
| |
626 | 626 |
| |
627 |
| - | |
| 627 | + | |
628 | 628 |
| |
629 | 629 |
| |
630 | 630 |
| |
| |||
696 | 696 |
| |
697 | 697 |
| |
698 | 698 |
| |
699 |
| - | |
| 699 | + | |
700 | 700 |
| |
701 | 701 |
| |
702 | 702 |
| |
| |||
791 | 791 |
| |
792 | 792 |
| |
793 | 793 |
| |
794 |
| - | |
| 794 | + | |
795 | 795 |
| |
796 | 796 |
| |
797 | 797 |
| |
| |||
866 | 866 |
| |
867 | 867 |
| |
868 | 868 |
| |
869 |
| - | |
| 869 | + | |
870 | 870 |
| |
871 | 871 |
| |
872 | 872 |
| |
| |||
940 | 940 |
| |
941 | 941 |
| |
942 | 942 |
| |
943 |
| - | |
| 943 | + | |
944 | 944 |
| |
945 | 945 |
| |
946 | 946 |
| |
| |||
1024 | 1024 |
| |
1025 | 1025 |
| |
1026 | 1026 |
| |
1027 |
| - | |
| 1027 | + | |
1028 | 1028 |
| |
1029 | 1029 |
| |
1030 | 1030 |
| |
| |||
1092 | 1092 |
| |
1093 | 1093 |
| |
1094 | 1094 |
| |
1095 |
| - | |
| 1095 | + | |
1096 | 1096 |
| |
1097 | 1097 |
| |
1098 | 1098 |
| |
| |||
1265 | 1265 |
| |
1266 | 1266 |
| |
1267 | 1267 |
| |
1268 |
| - | |
| 1268 | + | |
1269 | 1269 |
| |
1270 | 1270 |
| |
1271 | 1271 |
| |
| |||
1340 | 1340 |
| |
1341 | 1341 |
| |
1342 | 1342 |
| |
1343 |
| - | |
| 1343 | + | |
1344 | 1344 |
| |
1345 | 1345 |
| |
1346 | 1346 |
| |
| |||
1414 | 1414 |
| |
1415 | 1415 |
| |
1416 | 1416 |
| |
1417 |
| - | |
| 1417 | + | |
1418 | 1418 |
| |
1419 | 1419 |
| |
1420 | 1420 |
| |
| |||
1498 | 1498 |
| |
1499 | 1499 |
| |
1500 | 1500 |
| |
1501 |
| - | |
| 1501 | + | |
1502 | 1502 |
| |
1503 | 1503 |
| |
1504 | 1504 |
| |
| |||
1567 | 1567 |
| |
1568 | 1568 |
| |
1569 | 1569 |
| |
1570 |
| - | |
| 1570 | + | |
1571 | 1571 |
| |
1572 | 1572 |
| |
1573 | 1573 |
| |
| |||
1640 | 1640 |
| |
1641 | 1641 |
| |
1642 | 1642 |
| |
1643 |
| - | |
| 1643 | + | |
1644 | 1644 |
| |
1645 | 1645 |
| |
1646 | 1646 |
| |
|
Lines changed: 18 additions & 18 deletions
Original file line number | Diff line number | Diff line change | |
---|---|---|---|
| |||
487 | 487 |
| |
488 | 488 |
| |
489 | 489 |
| |
490 |
| - | |
| 490 | + | |
491 | 491 |
| |
492 | 492 |
| |
493 | 493 |
| |
| |||
559 | 559 |
| |
560 | 560 |
| |
561 | 561 |
| |
562 |
| - | |
| 562 | + | |
563 | 563 |
| |
564 | 564 |
| |
565 | 565 |
| |
| |||
628 | 628 |
| |
629 | 629 |
| |
630 | 630 |
| |
631 |
| - | |
| 631 | + | |
632 | 632 |
| |
633 | 633 |
| |
634 | 634 |
| |
| |||
701 | 701 |
| |
702 | 702 |
| |
703 | 703 |
| |
704 |
| - | |
| 704 | + | |
705 | 705 |
| |
706 | 706 |
| |
707 | 707 |
| |
| |||
783 | 783 |
| |
784 | 784 |
| |
785 | 785 |
| |
786 |
| - | |
| 786 | + | |
787 | 787 |
| |
788 | 788 |
| |
789 | 789 |
| |
| |||
851 | 851 |
| |
852 | 852 |
| |
853 | 853 |
| |
854 |
| - | |
| 854 | + | |
855 | 855 |
| |
856 | 856 |
| |
857 | 857 |
| |
| |||
923 | 923 |
| |
924 | 924 |
| |
925 | 925 |
| |
926 |
| - | |
| 926 | + | |
927 | 927 |
| |
928 | 928 |
| |
929 | 929 |
| |
| |||
1018 | 1018 |
| |
1019 | 1019 |
| |
1020 | 1020 |
| |
1021 |
| - | |
| 1021 | + | |
1022 | 1022 |
| |
1023 | 1023 |
| |
1024 | 1024 |
| |
| |||
1093 | 1093 |
| |
1094 | 1094 |
| |
1095 | 1095 |
| |
1096 |
| - | |
| 1096 | + | |
1097 | 1097 |
| |
1098 | 1098 |
| |
1099 | 1099 |
| |
| |||
1167 | 1167 |
| |
1168 | 1168 |
| |
1169 | 1169 |
| |
1170 |
| - | |
| 1170 | + | |
1171 | 1171 |
| |
1172 | 1172 |
| |
1173 | 1173 |
| |
| |||
1251 | 1251 |
| |
1252 | 1252 |
| |
1253 | 1253 |
| |
1254 |
| - | |
| 1254 | + | |
1255 | 1255 |
| |
1256 | 1256 |
| |
1257 | 1257 |
| |
| |||
1319 | 1319 |
| |
1320 | 1320 |
| |
1321 | 1321 |
| |
1322 |
| - | |
| 1322 | + | |
1323 | 1323 |
| |
1324 | 1324 |
| |
1325 | 1325 |
| |
| |||
1493 | 1493 |
| |
1494 | 1494 |
| |
1495 | 1495 |
| |
1496 |
| - | |
| 1496 | + | |
1497 | 1497 |
| |
1498 | 1498 |
| |
1499 | 1499 |
| |
| |||
1568 | 1568 |
| |
1569 | 1569 |
| |
1570 | 1570 |
| |
1571 |
| - | |
| 1571 | + | |
1572 | 1572 |
| |
1573 | 1573 |
| |
1574 | 1574 |
| |
| |||
1642 | 1642 |
| |
1643 | 1643 |
| |
1644 | 1644 |
| |
1645 |
| - | |
| 1645 | + | |
1646 | 1646 |
| |
1647 | 1647 |
| |
1648 | 1648 |
| |
| |||
1726 | 1726 |
| |
1727 | 1727 |
| |
1728 | 1728 |
| |
1729 |
| - | |
| 1729 | + | |
1730 | 1730 |
| |
1731 | 1731 |
| |
1732 | 1732 |
| |
| |||
1795 | 1795 |
| |
1796 | 1796 |
| |
1797 | 1797 |
| |
1798 |
| - | |
| 1798 | + | |
1799 | 1799 |
| |
1800 | 1800 |
| |
1801 | 1801 |
| |
| |||
1868 | 1868 |
| |
1869 | 1869 |
| |
1870 | 1870 |
| |
1871 |
| - | |
| 1871 | + | |
1872 | 1872 |
| |
1873 | 1873 |
| |
1874 | 1874 |
| |
|
Lines changed: 5 additions & 2 deletions
Original file line number | Diff line number | Diff line change | |
---|---|---|---|
| |||
165 | 165 |
| |
166 | 166 |
| |
167 | 167 |
| |
| 168 | + | |
168 | 169 |
| |
169 |
| - | |
| 170 | + | |
| 171 | + | |
| 172 | + | |
170 | 173 |
| |
171 | 174 |
| |
172 | 175 |
| |
| |||
239 | 242 |
| |
240 | 243 |
| |
241 | 244 |
| |
242 |
| - | |
| 245 | + | |
243 | 246 |
| |
244 | 247 |
| |
245 | 248 |
| |
|
Lines changed: 5 additions & 2 deletions
Original file line number | Diff line number | Diff line change | |
---|---|---|---|
| |||
210 | 210 |
| |
211 | 211 |
| |
212 | 212 |
| |
| 213 | + | |
213 | 214 |
| |
214 |
| - | |
| 215 | + | |
| 216 | + | |
| 217 | + | |
215 | 218 |
| |
216 | 219 |
| |
217 | 220 |
| |
| |||
241 | 244 |
| |
242 | 245 |
| |
243 | 246 |
| |
244 |
| - | |
| 247 | + | |
245 | 248 |
| |
246 | 249 |
| |
247 | 250 |
| |
|
Lines changed: 1 addition & 1 deletion
Original file line number | Diff line number | Diff line change | |
---|---|---|---|
| |||
357 | 357 |
| |
358 | 358 |
| |
359 | 359 |
| |
360 |
| - | |
| 360 | + | |
361 | 361 |
| |
362 | 362 |
| |
363 | 363 |
| |
|
Lines changed: 1 addition & 1 deletion
Original file line number | Diff line number | Diff line change | |
---|---|---|---|
| |||
526 | 526 |
| |
527 | 527 |
| |
528 | 528 |
| |
529 |
| - | |
| 529 | + | |
530 | 530 |
| |
531 | 531 |
| |
532 | 532 |
| |
|
Lines changed: 4 additions & 1 deletion
Original file line number | Diff line number | Diff line change | |
---|---|---|---|
| |||
161 | 161 |
| |
162 | 162 |
| |
163 | 163 |
| |
| 164 | + | |
164 | 165 |
| |
165 |
| - | |
| 166 | + | |
| 167 | + | |
| 168 | + | |
166 | 169 |
| |
167 | 170 |
| |
168 | 171 |
| |
|
0 commit comments