+445 -9

Cargo.lock

··· 3 3 version = 4 4 4 5 5 [[package]] 6 6 + name = "ahash" 7 7 + version = "0.8.12" 8 8 + source = "registry+https://github.com/rust-lang/crates.io-index" 9 9 + checksum = "5a15f179cd60c4584b8a8c596927aadc462e27f2ca70c04e0071964a73ba7a75" 10 10 + dependencies = [ 11 11 + "cfg-if", 12 12 + "once_cell", 13 13 + "version_check", 14 14 + "zerocopy", 15 15 + ] 16 16 + 17 17 + [[package]] 6 18 name = "aho-corasick" 7 19 version = "1.1.3" 8 20 source = "registry+https://github.com/rust-lang/crates.io-index" ··· 143 155 checksum = "c08606f8c3cbf4ce6ec8e28fb0014a2c086708fe954eaa885384a6165172e7e8" 144 156 145 157 [[package]] 158 158 + name = "aws-lc-rs" 159 159 + version = "1.14.1" 160 160 + source = "registry+https://github.com/rust-lang/crates.io-index" 161 161 + checksum = "879b6c89592deb404ba4dc0ae6b58ffd1795c78991cbb5b8bc441c48a070440d" 162 162 + dependencies = [ 163 163 + "aws-lc-sys", 164 164 + "zeroize", 165 165 + ] 166 166 + 167 167 + [[package]] 168 168 + name = "aws-lc-sys" 169 169 + version = "0.32.3" 170 170 + source = "registry+https://github.com/rust-lang/crates.io-index" 171 171 + checksum = "107a4e9d9cab9963e04e84bb8dee0e25f2a987f9a8bad5ed054abd439caa8f8c" 172 172 + dependencies = [ 173 173 + "bindgen", 174 174 + "cc", 175 175 + "cmake", 176 176 + "dunce", 177 177 + "fs_extra", 178 178 + ] 179 179 + 180 180 + [[package]] 146 181 name = "base-x" 147 182 version = "0.2.11" 148 183 source = "registry+https://github.com/rust-lang/crates.io-index" ··· 174 209 ] 175 210 176 211 [[package]] 212 212 + name = "bindgen" 213 213 + version = "0.72.1" 214 214 + source = "registry+https://github.com/rust-lang/crates.io-index" 215 215 + checksum = "993776b509cfb49c750f11b8f07a46fa23e0a1386ffc01fb1e7d343efc387895" 216 216 + dependencies = [ 217 217 + "bitflags 2.9.4", 218 218 + "cexpr", 219 219 + "clang-sys", 220 220 + "itertools", 221 221 + "log", 222 222 + "prettyplease", 223 223 + "proc-macro2", 224 224 + "quote", 225 225 + "regex", 226 226 + "rustc-hash", 227 227 + "shlex", 228 228 + "syn 2.0.106", 229 229 + ] 230 230 + 231 231 + [[package]] 177 232 name = "bitflags" 178 233 version = "1.3.2" 179 234 source = "registry+https://github.com/rust-lang/crates.io-index" ··· 225 280 ] 226 281 227 282 [[package]] 283 283 + name = "cexpr" 284 284 + version = "0.6.0" 285 285 + source = "registry+https://github.com/rust-lang/crates.io-index" 286 286 + checksum = "6fac387a98bb7c37292057cffc56d62ecb629900026402633ae9160df93a8766" 287 287 + dependencies = [ 288 288 + "nom", 289 289 + ] 290 290 + 291 291 + [[package]] 228 292 name = "cfg-if" 229 293 version = "1.0.4" 230 294 source = "registry+https://github.com/rust-lang/crates.io-index" ··· 259 323 ] 260 324 261 325 [[package]] 326 326 + name = "clang-sys" 327 327 + version = "1.8.1" 328 328 + source = "registry+https://github.com/rust-lang/crates.io-index" 329 329 + checksum = "0b023947811758c97c59bf9d1c188fd619ad4718dcaa767947df1cadb14f39f4" 330 330 + dependencies = [ 331 331 + "glob", 332 332 + "libc", 333 333 + "libloading", 334 334 + ] 335 335 + 336 336 + [[package]] 262 337 name = "clap" 263 338 version = "2.34.0" 264 339 source = "registry+https://github.com/rust-lang/crates.io-index" ··· 274 349 ] 275 350 276 351 [[package]] 352 352 + name = "cmake" 353 353 + version = "0.1.54" 354 354 + source = "registry+https://github.com/rust-lang/crates.io-index" 355 355 + checksum = "e7caa3f9de89ddbe2c607f4101924c5abec803763ae9534e4f4d7d8f84aa81f0" 356 356 + dependencies = [ 357 357 + "cc", 358 358 + ] 359 359 + 360 360 + [[package]] 277 361 name = "colorchoice" 278 362 version = "1.0.4" 279 363 source = "registry+https://github.com/rust-lang/crates.io-index" ··· 296 380 ] 297 381 298 382 [[package]] 383 383 + name = "core-foundation" 384 384 + version = "0.10.1" 385 385 + source = "registry+https://github.com/rust-lang/crates.io-index" 386 386 + checksum = "b2a6cd9ae233e7f62ba4e9353e81a88df7fc8a5987b8d445b4d90c879bd156f6" 387 387 + dependencies = [ 388 388 + "core-foundation-sys", 389 389 + "libc", 390 390 + ] 391 391 + 392 392 + [[package]] 299 393 name = "core-foundation-sys" 300 394 version = "0.8.7" 301 395 source = "registry+https://github.com/rust-lang/crates.io-index" ··· 419 513 "futures-util", 420 514 "jetstream", 421 515 "log", 516 516 + "metrics-exporter-prometheus", 517 517 + "metrics-util", 518 518 + "prometheus", 422 519 "reqwest", 423 520 "serde", 424 521 "serde_json", 425 522 "sled", 426 523 "tokio", 427 427 - "tokio-metrics", 524 524 + "tokio-metrics 0.3.1", 525 525 + "tokio-metrics-collector", 428 526 ] 429 527 430 528 [[package]] ··· 452 550 ] 453 551 454 552 [[package]] 553 553 + name = "dunce" 554 554 + version = "1.0.5" 555 555 + source = "registry+https://github.com/rust-lang/crates.io-index" 556 556 + checksum = "92773504d58c093f6de2459af4af33faa518c13451eb8f2b5698ed3d36e7c813" 557 557 + 558 558 + [[package]] 559 559 + name = "either" 560 560 + version = "1.15.0" 561 561 + source = "registry+https://github.com/rust-lang/crates.io-index" 562 562 + checksum = "48c757948c5ede0e46177b7add2e67155f70e33c07fea8284df6576da70b3719" 563 563 + 564 564 + [[package]] 455 565 name = "encoding_rs" 456 566 version = "0.8.35" 457 567 source = "registry+https://github.com/rust-lang/crates.io-index" ··· 461 571 ] 462 572 463 573 [[package]] 574 574 + name = "endian-type" 575 575 + version = "0.1.2" 576 576 + source = "registry+https://github.com/rust-lang/crates.io-index" 577 577 + checksum = "c34f04666d835ff5d62e058c3995147c06f42fe86ff053337632bca83e42702d" 578 578 + 579 579 + [[package]] 464 580 name = "env_filter" 465 581 version = "0.1.4" 466 582 source = "registry+https://github.com/rust-lang/crates.io-index" ··· 530 646 checksum = "3f9eec918d3f24069decb9af1554cad7c880e2da24a9afd88aca000531ab82c1" 531 647 532 648 [[package]] 649 649 + name = "foldhash" 650 650 + version = "0.1.5" 651 651 + source = "registry+https://github.com/rust-lang/crates.io-index" 652 652 + checksum = "d9c4f5dac5e15c24eb999c26181a6ca40b39fe946cbe4c263c7209467bc83af2" 653 653 + 654 654 + [[package]] 533 655 name = "foreign-types" 534 656 version = "0.3.2" 535 657 source = "registry+https://github.com/rust-lang/crates.io-index" ··· 564 686 ] 565 687 566 688 [[package]] 689 689 + name = "fs_extra" 690 690 + version = "1.3.0" 691 691 + source = "registry+https://github.com/rust-lang/crates.io-index" 692 692 + checksum = "42703706b716c37f96a77aea830392ad231f44c9e9a67872fa5548707e11b11c" 693 693 + 694 694 + [[package]] 567 695 name = "futures-channel" 568 696 version = "0.3.31" 569 697 source = "registry+https://github.com/rust-lang/crates.io-index" ··· 661 789 ] 662 790 663 791 [[package]] 792 792 + name = "glob" 793 793 + version = "0.3.3" 794 794 + source = "registry+https://github.com/rust-lang/crates.io-index" 795 795 + checksum = "0cc23270f6e1808e30a928bdc84dea0b9b4136a8bc82338574f23baf47bbd280" 796 796 + 797 797 + [[package]] 664 798 name = "h2" 665 799 version = "0.4.12" 666 800 source = "registry+https://github.com/rust-lang/crates.io-index" ··· 681 815 682 816 [[package]] 683 817 name = "hashbrown" 818 818 + version = "0.15.5" 819 819 + source = "registry+https://github.com/rust-lang/crates.io-index" 820 820 + checksum = "9229cfe53dfd69f0609a49f65461bd93001ea1ef889cd5529dd176593f5338a1" 821 821 + dependencies = [ 822 822 + "foldhash", 823 823 + ] 824 824 + 825 825 + [[package]] 826 826 + name = "hashbrown" 684 827 version = "0.16.0" 685 828 source = "registry+https://github.com/rust-lang/crates.io-index" 686 829 checksum = "5419bdc4f6a9207fbeba6d11b604d481addf78ecd10c11ad51e76c2f6482748d" ··· 744 887 checksum = "6dbf3de79e51f3d586ab4cb9d5c3e2c14aa28ed23d180cf89b4df0454a69cc87" 745 888 746 889 [[package]] 890 890 + name = "httpdate" 891 891 + version = "1.0.3" 892 892 + source = "registry+https://github.com/rust-lang/crates.io-index" 893 893 + checksum = "df3b46402a9d5adb4c86a0cf463f42e19994e3ee891101b1841f30a545cb49a9" 894 894 + 895 895 + [[package]] 747 896 name = "hyper" 748 897 version = "1.7.0" 749 898 source = "registry+https://github.com/rust-lang/crates.io-index" ··· 757 906 "http", 758 907 "http-body", 759 908 "httparse", 909 909 + "httpdate", 760 910 "itoa", 761 911 "pin-project-lite", 762 912 "pin-utils", ··· 775 925 "hyper", 776 926 "hyper-util", 777 927 "rustls", 928 928 + "rustls-native-certs", 778 929 "rustls-pki-types", 779 930 "tokio", 780 931 "tokio-rustls", ··· 961 1112 checksum = "6717a8d2a5a929a1a2eb43a12812498ed141a0bcfb7e8f7844fbdbe4303bba9f" 962 1113 dependencies = [ 963 1114 "equivalent", 964 964 - "hashbrown", 1115 1115 + "hashbrown 0.16.0", 965 1116 ] 966 1117 967 1118 [[package]] ··· 1007 1158 checksum = "7943c866cc5cd64cbc25b2e01621d07fa8eb2a1a23160ee81ce38704e97b8ecf" 1008 1159 1009 1160 [[package]] 1161 1161 + name = "itertools" 1162 1162 + version = "0.13.0" 1163 1163 + source = "registry+https://github.com/rust-lang/crates.io-index" 1164 1164 + checksum = "413ee7dfc52ee1a4949ceeb7dbc8a33f2d6c088194d9f922fb8318faf1f01186" 1165 1165 + dependencies = [ 1166 1166 + "either", 1167 1167 + ] 1168 1168 + 1169 1169 + [[package]] 1010 1170 name = "itoa" 1011 1171 version = "1.0.15" 1012 1172 source = "registry+https://github.com/rust-lang/crates.io-index" ··· 1096 1256 checksum = "2874a2af47a2325c2001a6e6fad9b16a53b802102b528163885171cf92b15976" 1097 1257 1098 1258 [[package]] 1259 1259 + name = "libloading" 1260 1260 + version = "0.8.9" 1261 1261 + source = "registry+https://github.com/rust-lang/crates.io-index" 1262 1262 + checksum = "d7c4b02199fee7c5d21a5ae7d8cfa79a6ef5bb2fc834d6e9058e89c825efdc55" 1263 1263 + dependencies = [ 1264 1264 + "cfg-if", 1265 1265 + "windows-link 0.2.1", 1266 1266 + ] 1267 1267 + 1268 1268 + [[package]] 1099 1269 name = "linux-raw-sys" 1100 1270 version = "0.11.0" 1101 1271 source = "registry+https://github.com/rust-lang/crates.io-index" ··· 1140 1310 checksum = "f52b00d39961fc5b2736ea853c9cc86238e165017a493d1d5c8eac6bdc4cc273" 1141 1311 1142 1312 [[package]] 1313 1313 + name = "metrics" 1314 1314 + version = "0.24.2" 1315 1315 + source = "registry+https://github.com/rust-lang/crates.io-index" 1316 1316 + checksum = "25dea7ac8057892855ec285c440160265225438c3c45072613c25a4b26e98ef5" 1317 1317 + dependencies = [ 1318 1318 + "ahash", 1319 1319 + "portable-atomic", 1320 1320 + ] 1321 1321 + 1322 1322 + [[package]] 1323 1323 + name = "metrics-exporter-prometheus" 1324 1324 + version = "0.17.2" 1325 1325 + source = "registry+https://github.com/rust-lang/crates.io-index" 1326 1326 + checksum = "2b166dea96003ee2531cf14833efedced545751d800f03535801d833313f8c15" 1327 1327 + dependencies = [ 1328 1328 + "base64", 1329 1329 + "http-body-util", 1330 1330 + "hyper", 1331 1331 + "hyper-rustls", 1332 1332 + "hyper-util", 1333 1333 + "indexmap", 1334 1334 + "ipnet", 1335 1335 + "metrics", 1336 1336 + "metrics-util", 1337 1337 + "quanta", 1338 1338 + "thiserror 2.0.17", 1339 1339 + "tokio", 1340 1340 + "tracing", 1341 1341 + ] 1342 1342 + 1343 1343 + [[package]] 1344 1344 + name = "metrics-util" 1345 1345 + version = "0.20.0" 1346 1346 + source = "registry+https://github.com/rust-lang/crates.io-index" 1347 1347 + checksum = "fe8db7a05415d0f919ffb905afa37784f71901c9a773188876984b4f769ab986" 1348 1348 + dependencies = [ 1349 1349 + "aho-corasick", 1350 1350 + "crossbeam-epoch", 1351 1351 + "crossbeam-utils", 1352 1352 + "hashbrown 0.15.5", 1353 1353 + "indexmap", 1354 1354 + "metrics", 1355 1355 + "ordered-float", 1356 1356 + "quanta", 1357 1357 + "radix_trie", 1358 1358 + "rand 0.9.2", 1359 1359 + "rand_xoshiro", 1360 1360 + "sketches-ddsketch", 1361 1361 + ] 1362 1362 + 1363 1363 + [[package]] 1143 1364 name = "mime" 1144 1365 version = "0.3.17" 1145 1366 source = "registry+https://github.com/rust-lang/crates.io-index" 1146 1367 checksum = "6877bb514081ee2a7ff5ef9de3281f14a4dd4bceac4c09388074a6b5df8a139a" 1147 1368 1148 1369 [[package]] 1370 1370 + name = "minimal-lexical" 1371 1371 + version = "0.2.1" 1372 1372 + source = "registry+https://github.com/rust-lang/crates.io-index" 1373 1373 + checksum = "68354c5c6bd36d73ff3feceb05efa59b6acb7626617f4962be322a825e61f79a" 1374 1374 + 1375 1375 + [[package]] 1149 1376 name = "mio" 1150 1377 version = "1.1.0" 1151 1378 source = "registry+https://github.com/rust-lang/crates.io-index" ··· 1200 1427 "openssl-probe", 1201 1428 "openssl-sys", 1202 1429 "schannel", 1203 1203 - "security-framework", 1430 1430 + "security-framework 2.11.1", 1204 1431 "security-framework-sys", 1205 1432 "tempfile", 1206 1433 ] 1207 1434 1208 1435 [[package]] 1436 1436 + name = "nibble_vec" 1437 1437 + version = "0.1.0" 1438 1438 + source = "registry+https://github.com/rust-lang/crates.io-index" 1439 1439 + checksum = "77a5d83df9f36fe23f0c3648c6bbb8b0298bb5f1939c8f2704431371f4b84d43" 1440 1440 + dependencies = [ 1441 1441 + "smallvec", 1442 1442 + ] 1443 1443 + 1444 1444 + [[package]] 1445 1445 + name = "nom" 1446 1446 + version = "7.1.3" 1447 1447 + source = "registry+https://github.com/rust-lang/crates.io-index" 1448 1448 + checksum = "d273983c5a657a70a3e8f2a01329822f3b8c8172b73826411a55751e404a0a4a" 1449 1449 + dependencies = [ 1450 1450 + "memchr", 1451 1451 + "minimal-lexical", 1452 1452 + ] 1453 1453 + 1454 1454 + [[package]] 1209 1455 name = "num-traits" 1210 1456 version = "0.2.19" 1211 1457 source = "registry+https://github.com/rust-lang/crates.io-index" ··· 1271 1517 ] 1272 1518 1273 1519 [[package]] 1520 1520 + name = "ordered-float" 1521 1521 + version = "4.6.0" 1522 1522 + source = "registry+https://github.com/rust-lang/crates.io-index" 1523 1523 + checksum = "7bb71e1b3fa6ca1c61f383464aaf2bb0e2f8e772a1f01d486832464de363b951" 1524 1524 + dependencies = [ 1525 1525 + "num-traits", 1526 1526 + ] 1527 1527 + 1528 1528 + [[package]] 1274 1529 name = "parking_lot" 1275 1530 version = "0.11.2" 1276 1531 source = "registry+https://github.com/rust-lang/crates.io-index" ··· 1376 1631 ] 1377 1632 1378 1633 [[package]] 1634 1634 + name = "prettyplease" 1635 1635 + version = "0.2.37" 1636 1636 + source = "registry+https://github.com/rust-lang/crates.io-index" 1637 1637 + checksum = "479ca8adacdd7ce8f1fb39ce9ecccbfe93a3f1344b3d0d97f20bc0196208f62b" 1638 1638 + dependencies = [ 1639 1639 + "proc-macro2", 1640 1640 + "syn 2.0.106", 1641 1641 + ] 1642 1642 + 1643 1643 + [[package]] 1379 1644 name = "proc-macro-error" 1380 1645 version = "1.0.4" 1381 1646 source = "registry+https://github.com/rust-lang/crates.io-index" ··· 1409 1674 ] 1410 1675 1411 1676 [[package]] 1677 1677 + name = "prometheus" 1678 1678 + version = "0.14.0" 1679 1679 + source = "registry+https://github.com/rust-lang/crates.io-index" 1680 1680 + checksum = "3ca5326d8d0b950a9acd87e6a3f94745394f62e4dae1b1ee22b2bc0c394af43a" 1681 1681 + dependencies = [ 1682 1682 + "cfg-if", 1683 1683 + "fnv", 1684 1684 + "lazy_static", 1685 1685 + "memchr", 1686 1686 + "parking_lot 0.12.5", 1687 1687 + "protobuf", 1688 1688 + "thiserror 2.0.17", 1689 1689 + ] 1690 1690 + 1691 1691 + [[package]] 1692 1692 + name = "protobuf" 1693 1693 + version = "3.7.2" 1694 1694 + source = "registry+https://github.com/rust-lang/crates.io-index" 1695 1695 + checksum = "d65a1d4ddae7d8b5de68153b48f6aa3bba8cb002b243dbdbc55a5afbc98f99f4" 1696 1696 + dependencies = [ 1697 1697 + "once_cell", 1698 1698 + "protobuf-support", 1699 1699 + "thiserror 1.0.69", 1700 1700 + ] 1701 1701 + 1702 1702 + [[package]] 1703 1703 + name = "protobuf-support" 1704 1704 + version = "3.7.2" 1705 1705 + source = "registry+https://github.com/rust-lang/crates.io-index" 1706 1706 + checksum = "3e36c2f31e0a47f9280fb347ef5e461ffcd2c52dd520d8e216b52f93b0b0d7d6" 1707 1707 + dependencies = [ 1708 1708 + "thiserror 1.0.69", 1709 1709 + ] 1710 1710 + 1711 1711 + [[package]] 1712 1712 + name = "quanta" 1713 1713 + version = "0.12.6" 1714 1714 + source = "registry+https://github.com/rust-lang/crates.io-index" 1715 1715 + checksum = "f3ab5a9d756f0d97bdc89019bd2e4ea098cf9cde50ee7564dde6b81ccc8f06c7" 1716 1716 + dependencies = [ 1717 1717 + "crossbeam-utils", 1718 1718 + "libc", 1719 1719 + "once_cell", 1720 1720 + "raw-cpuid", 1721 1721 + "wasi", 1722 1722 + "web-sys", 1723 1723 + "winapi", 1724 1724 + ] 1725 1725 + 1726 1726 + [[package]] 1412 1727 name = "quote" 1413 1728 version = "1.0.41" 1414 1729 source = "registry+https://github.com/rust-lang/crates.io-index" ··· 1424 1739 checksum = "69cdb34c158ceb288df11e18b4bd39de994f6657d83847bdffdbd7f346754b0f" 1425 1740 1426 1741 [[package]] 1742 1742 + name = "radix_trie" 1743 1743 + version = "0.2.1" 1744 1744 + source = "registry+https://github.com/rust-lang/crates.io-index" 1745 1745 + checksum = "c069c179fcdc6a2fe24d8d18305cf085fdbd4f922c041943e203685d6a1c58fd" 1746 1746 + dependencies = [ 1747 1747 + "endian-type", 1748 1748 + "nibble_vec", 1749 1749 + ] 1750 1750 + 1751 1751 + [[package]] 1427 1752 name = "rand" 1428 1753 version = "0.8.5" 1429 1754 source = "registry+https://github.com/rust-lang/crates.io-index" 1430 1755 checksum = "34af8d1a0e25924bc5b7c43c079c942339d8f0a8b57c39049bef581b46327404" 1431 1756 dependencies = [ 1432 1757 "libc", 1433 1433 - "rand_chacha", 1434 1434 - "rand_core", 1758 1758 + "rand_chacha 0.3.1", 1759 1759 + "rand_core 0.6.4", 1760 1760 + ] 1761 1761 + 1762 1762 + [[package]] 1763 1763 + name = "rand" 1764 1764 + version = "0.9.2" 1765 1765 + source = "registry+https://github.com/rust-lang/crates.io-index" 1766 1766 + checksum = "6db2770f06117d490610c7488547d543617b21bfa07796d7a12f6f1bd53850d1" 1767 1767 + dependencies = [ 1768 1768 + "rand_chacha 0.9.0", 1769 1769 + "rand_core 0.9.3", 1435 1770 ] 1436 1771 1437 1772 [[package]] ··· 1441 1776 checksum = "e6c10a63a0fa32252be49d21e7709d4d4baf8d231c2dbce1eaa8141b9b127d88" 1442 1777 dependencies = [ 1443 1778 "ppv-lite86", 1444 1444 - "rand_core", 1779 1779 + "rand_core 0.6.4", 1780 1780 + ] 1781 1781 + 1782 1782 + [[package]] 1783 1783 + name = "rand_chacha" 1784 1784 + version = "0.9.0" 1785 1785 + source = "registry+https://github.com/rust-lang/crates.io-index" 1786 1786 + checksum = "d3022b5f1df60f26e1ffddd6c66e8aa15de382ae63b3a0c1bfc0e4d3e3f325cb" 1787 1787 + dependencies = [ 1788 1788 + "ppv-lite86", 1789 1789 + "rand_core 0.9.3", 1445 1790 ] 1446 1791 1447 1792 [[package]] ··· 1451 1796 checksum = "ec0be4795e2f6a28069bec0b5ff3e2ac9bafc99e6a9a7dc3547996c5c816922c" 1452 1797 dependencies = [ 1453 1798 "getrandom 0.2.16", 1799 1799 + ] 1800 1800 + 1801 1801 + [[package]] 1802 1802 + name = "rand_core" 1803 1803 + version = "0.9.3" 1804 1804 + source = "registry+https://github.com/rust-lang/crates.io-index" 1805 1805 + checksum = "99d9a13982dcf210057a8a78572b2217b667c3beacbf3a0d8b454f6f82837d38" 1806 1806 + dependencies = [ 1807 1807 + "getrandom 0.3.4", 1808 1808 + ] 1809 1809 + 1810 1810 + [[package]] 1811 1811 + name = "rand_xoshiro" 1812 1812 + version = "0.7.0" 1813 1813 + source = "registry+https://github.com/rust-lang/crates.io-index" 1814 1814 + checksum = "f703f4665700daf5512dcca5f43afa6af89f09db47fb56be587f80636bda2d41" 1815 1815 + dependencies = [ 1816 1816 + "rand_core 0.9.3", 1817 1817 + ] 1818 1818 + 1819 1819 + [[package]] 1820 1820 + name = "raw-cpuid" 1821 1821 + version = "11.6.0" 1822 1822 + source = "registry+https://github.com/rust-lang/crates.io-index" 1823 1823 + checksum = "498cd0dc59d73224351ee52a95fee0f1a617a2eae0e7d9d720cc622c73a54186" 1824 1824 + dependencies = [ 1825 1825 + "bitflags 2.9.4", 1454 1826 ] 1455 1827 1456 1828 [[package]] ··· 1555 1927 ] 1556 1928 1557 1929 [[package]] 1930 1930 + name = "rustc-hash" 1931 1931 + version = "2.1.1" 1932 1932 + source = "registry+https://github.com/rust-lang/crates.io-index" 1933 1933 + checksum = "357703d41365b4b27c590e3ed91eabb1b663f07c4c084095e60cbed4362dff0d" 1934 1934 + 1935 1935 + [[package]] 1558 1936 name = "rustix" 1559 1937 version = "1.1.2" 1560 1938 source = "registry+https://github.com/rust-lang/crates.io-index" ··· 1573 1951 source = "registry+https://github.com/rust-lang/crates.io-index" 1574 1952 checksum = "751e04a496ca00bb97a5e043158d23d66b5aabf2e1d5aa2a0aaebb1aafe6f82c" 1575 1953 dependencies = [ 1954 1954 + "aws-lc-rs", 1576 1955 "once_cell", 1577 1956 "rustls-pki-types", 1578 1957 "rustls-webpki", ··· 1581 1960 ] 1582 1961 1583 1962 [[package]] 1963 1963 + name = "rustls-native-certs" 1964 1964 + version = "0.8.2" 1965 1965 + source = "registry+https://github.com/rust-lang/crates.io-index" 1966 1966 + checksum = "9980d917ebb0c0536119ba501e90834767bffc3d60641457fd84a1f3fd337923" 1967 1967 + dependencies = [ 1968 1968 + "openssl-probe", 1969 1969 + "rustls-pki-types", 1970 1970 + "schannel", 1971 1971 + "security-framework 3.5.1", 1972 1972 + ] 1973 1973 + 1974 1974 + [[package]] 1584 1975 name = "rustls-pki-types" 1585 1976 version = "1.12.0" 1586 1977 source = "registry+https://github.com/rust-lang/crates.io-index" ··· 1595 1986 source = "registry+https://github.com/rust-lang/crates.io-index" 1596 1987 checksum = "e10b3f4191e8a80e6b43eebabfac91e5dcecebb27a71f04e820c47ec41d314bf" 1597 1988 dependencies = [ 1989 1989 + "aws-lc-rs", 1598 1990 "ring", 1599 1991 "rustls-pki-types", 1600 1992 "untrusted", ··· 1634 2026 checksum = "897b2245f0b511c87893af39b033e5ca9cce68824c4d7e7630b5a1d339658d02" 1635 2027 dependencies = [ 1636 2028 "bitflags 2.9.4", 1637 1637 - "core-foundation", 2029 2029 + "core-foundation 0.9.4", 2030 2030 + "core-foundation-sys", 2031 2031 + "libc", 2032 2032 + "security-framework-sys", 2033 2033 + ] 2034 2034 + 2035 2035 + [[package]] 2036 2036 + name = "security-framework" 2037 2037 + version = "3.5.1" 2038 2038 + source = "registry+https://github.com/rust-lang/crates.io-index" 2039 2039 + checksum = "b3297343eaf830f66ede390ea39da1d462b6b0c1b000f420d0a83f898bbbe6ef" 2040 2040 + dependencies = [ 2041 2041 + "bitflags 2.9.4", 2042 2042 + "core-foundation 0.10.1", 1638 2043 "core-foundation-sys", 1639 2044 "libc", 1640 2045 "security-framework-sys", ··· 1753 2158 dependencies = [ 1754 2159 "libc", 1755 2160 ] 2161 2161 + 2162 2162 + [[package]] 2163 2163 + name = "sketches-ddsketch" 2164 2164 + version = "0.3.0" 2165 2165 + source = "registry+https://github.com/rust-lang/crates.io-index" 2166 2166 + checksum = "c1e9a774a6c28142ac54bb25d25562e6bcf957493a184f15ad4eebccb23e410a" 1756 2167 1757 2168 [[package]] 1758 2169 name = "slab" ··· 1892 2303 checksum = "3c879d448e9d986b661742763247d3693ed13609438cf3d006f51f5368a5ba6b" 1893 2304 dependencies = [ 1894 2305 "bitflags 2.9.4", 1895 1895 - "core-foundation", 2306 2306 + "core-foundation 0.9.4", 1896 2307 "system-configuration-sys", 1897 2308 ] 1898 2309 ··· 2016 2427 "pin-project-lite", 2017 2428 "tokio", 2018 2429 "tokio-stream", 2430 2430 + ] 2431 2431 + 2432 2432 + [[package]] 2433 2433 + name = "tokio-metrics" 2434 2434 + version = "0.4.5" 2435 2435 + source = "registry+https://github.com/rust-lang/crates.io-index" 2436 2436 + checksum = "a01bbf7db0b3f5eee8930a119fe99bfa1438de1095fe3d26b25e652a5933ef3f" 2437 2437 + dependencies = [ 2438 2438 + "futures-util", 2439 2439 + "pin-project-lite", 2440 2440 + "tokio", 2441 2441 + "tokio-stream", 2442 2442 + ] 2443 2443 + 2444 2444 + [[package]] 2445 2445 + name = "tokio-metrics-collector" 2446 2446 + version = "0.3.1" 2447 2447 + source = "registry+https://github.com/rust-lang/crates.io-index" 2448 2448 + checksum = "f360c6fa7fd188e65904979ea07f1f44c57f0759ab18ecca88551c26acdf4cd6" 2449 2449 + dependencies = [ 2450 2450 + "lazy_static", 2451 2451 + "parking_lot 0.12.5", 2452 2452 + "prometheus", 2453 2453 + "tokio", 2454 2454 + "tokio-metrics 0.4.5", 2019 2455 ] 2020 2456 2021 2457 [[package]] ··· 2170 2606 "httparse", 2171 2607 "log", 2172 2608 "native-tls", 2173 2173 - "rand", 2609 2609 + "rand 0.8.5", 2174 2610 "sha1", 2175 2611 "thiserror 1.0.69", 2176 2612 "utf-8",

+1 -1

packages-rs/drainpipe-store/src/lib.rs

··· 4 4 use serde::{Deserialize, Serialize}; 5 5 use sled::Tree; 6 6 7 7 + #[derive(Debug, Clone)] 7 8 pub struct Store { 8 9 db: sled::Db, 9 10 cursor_tree: Tree, ··· 11 12 } 12 13 13 14 #[derive(Serialize, Deserialize, Debug)] 14 14 - 15 15 enum CursorInner { 16 16 V1(u64), 17 17 }

+6

packages-rs/drainpipe/Cargo.toml

··· 13 13 futures-util = "0.3" 14 14 jetstream = { path = "../jetstream" } 15 15 log = "0.4.22" 16 16 + metrics-exporter-prometheus = { version = "0.17.2", features = [ 17 17 + "http-listener", 18 18 + ] } 19 19 + metrics-util = "0.20.0" 20 20 + prometheus = "0.14.0" 16 21 reqwest = { version = "0.12.4", features = ["json"] } 17 22 serde = { version = "1.0.215", features = ["derive"] } 18 23 serde_json = "1.0.132" 19 24 sled = "0.34.7" 20 25 tokio = { version = "1.38.0", features = ["full"] } 21 26 tokio-metrics = "0.3.1" 27 27 + tokio-metrics-collector = "0.3.1"

+27 -4

packages-rs/drainpipe/src/main.rs

··· 8 8 JetstreamReceiver, 9 9 }; 10 10 use serde_json::json; 11 11 + use std::net::SocketAddr; 11 12 use std::path::PathBuf; 12 13 use std::time::Duration; 13 14 use std::vec; ··· 25 26 26 27 env_logger::init(); 27 28 28 28 - let monitor = tokio_metrics::TaskMonitor::new(); 29 29 + metrics_exporter_prometheus::PrometheusBuilder::new() 30 30 + .with_http_listener(SocketAddr::from(([0, 0, 0, 0], 9898))) 31 31 + .install()?; 32 32 + let task_collector = tokio_metrics_collector::default_task_collector(); 33 33 + prometheus::default_registry().register(Box::new(task_collector))?; 34 34 + 35 35 + let jetstream_events_monitor = tokio_metrics_collector::TaskMonitor::new(); 36 36 + task_collector.add("jetstream_events", jetstream_events_monitor.clone())?; 29 37 30 38 let config = Config::from_env()?; 31 39 let store = drainpipe_store::Store::open(&config.store_location)?; ··· 58 66 .await?; 59 67 60 68 let metric_logs_abort_handler = { 61 61 - let metrics_monitor = monitor.clone(); 69 69 + let metrics_monitor = jetstream_events_monitor.clone(); 70 70 + let store = store.clone(); 62 71 tokio::spawn(async move { 63 72 for interval in metrics_monitor.intervals() { 64 64 - log::info!("{:?} per second", interval.instrumented_count as f64 / 5.0,); 73 73 + let lag_output = store.get_cursor().unwrap_or(None).and_then(|c| { 74 74 + let cursor_time = Utc.timestamp_micros(c as i64).earliest()?; 75 75 + let now = Utc::now(); 76 76 + let lag = now.signed_duration_since(cursor_time); 77 77 + Some(format!("Cursor lag: {}ms", lag.num_milliseconds())) 78 78 + }); 79 79 + if let Some(lag) = lag_output { 80 80 + log::info!( 81 81 + "{:?} per second; {}", 82 82 + interval.instrumented_count as f64 / 5.0, 83 83 + lag 84 84 + ); 85 85 + } else { 86 86 + log::info!("{:?} per second", interval.instrumented_count as f64 / 5.0); 87 87 + } 65 88 tokio::time::sleep(Duration::from_millis(5000)).await; 66 89 } 67 90 }) ··· 71 94 loop { 72 95 match receiver.recv_async().await { 73 96 Ok(Ok(event)) => { 74 74 - monitor 97 97 + jetstream_events_monitor 75 98 .instrument(async { 76 99 if let JetstreamEvent::Commit(ref commit) = event { 77 100 println!("Received commit: {:?}", commit);