diff --git a/asap-tools/data-sources/paced-feeder/Cargo.lock b/asap-tools/data-sources/paced-feeder/Cargo.lock
new file mode 100644
index 00000000..afd1b606
--- /dev/null
+++ b/asap-tools/data-sources/paced-feeder/Cargo.lock
@@ -0,0 +1,1363 @@
+# This file is automatically @generated by Cargo.
+# It is not intended for manual editing.
+version = 4
+
+[[package]]
+name = "anstream"
+version = "1.0.0"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "824a212faf96e9acacdbd09febd34438f8f711fb84e09a8916013cd7815ca28d"
+dependencies = [
+ "anstyle",
+ "anstyle-parse",
+ "anstyle-query",
+ "anstyle-wincon",
+ "colorchoice",
+ "is_terminal_polyfill",
+ "utf8parse",
+]
+
+[[package]]
+name = "anstyle"
+version = "1.0.14"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "940b3a0ca603d1eade50a4846a2afffd5ef57a9feac2c0e2ec2e14f9ead76000"
+
+[[package]]
+name = "anstyle-parse"
+version = "1.0.0"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "52ce7f38b242319f7cabaa6813055467063ecdc9d355bbb4ce0c68908cd8130e"
+dependencies = [
+ "utf8parse",
+]
+
+[[package]]
+name = "anstyle-query"
+version = "1.1.5"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "40c48f72fd53cd289104fc64099abca73db4166ad86ea0b4341abe65af83dadc"
+dependencies = [
+ "windows-sys 0.61.2",
+]
+
+[[package]]
+name = "anstyle-wincon"
+version = "3.0.11"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "291e6a250ff86cd4a820112fb8898808a366d8f9f58ce16d1f538353ad55747d"
+dependencies = [
+ "anstyle",
+ "once_cell_polyfill",
+ "windows-sys 0.61.2",
+]
+
+[[package]]
+name = "anyhow"
+version = "1.0.104"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "330a5ed07fa54e4702c9d6c4174f74427fc0ef6e214bbd677ae50a5099946470"
+
+[[package]]
+name = "base64"
+version = "0.21.7"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "9d297deb1925b89f2ccc13d7635fa0714f12c87adce1c75356b39ca9b7178567"
+
+[[package]]
+name = "bitflags"
+version = "1.3.2"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "bef38d45163c2f1dde094a7dfd33ccf595c92905c8f8f4fdc18d06fb1037718a"
+
+[[package]]
+name = "bitflags"
+version = "2.13.2"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "3ded4057c258ba199e2d26386d3af3780957ecaee6c4ef4041c6b4b8b97c0b06"
+
+[[package]]
+name = "bumpalo"
+version = "3.20.3"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "72f5acc6cb2ba439de613abc23857ec3d78374d8ed5ac84e9d11336e87da8649"
+
+[[package]]
+name = "bytes"
+version = "1.12.1"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "fc652a48c352aef3ea3aed32080501cf3ef6ed5da78602a020c991775b0aff04"
+
+[[package]]
+name = "cfg-if"
+version = "1.0.5"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "4e7648175b45a9a48536d676f68d918270699102aa8dab5496df06904c914600"
+
+[[package]]
+name = "clap"
+version = "4.6.7"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "aa8876b300ab35ba921adea3dfd70157a46249b33f95c9084ae5709785478946"
+dependencies = [
+ "clap_builder",
+ "clap_derive",
+]
+
+[[package]]
+name = "clap_builder"
+version = "4.6.7"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "ec0797fb7aeb1406c84efac526901f7ec3ead2124f946b494e72879d4b54704d"
+dependencies = [
+ "anstream",
+ "anstyle",
+ "clap_lex",
+ "strsim",
+]
+
+[[package]]
+name = "clap_derive"
+version = "4.6.7"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "f9c751b79415d4e559e3d1fcf128e09e720eb673a06d26cf6f392d37d75b66e0"
+dependencies = [
+ "heck",
+ "proc-macro2",
+ "quote",
+ "syn 3.0.6",
+]
+
+[[package]]
+name = "clap_lex"
+version = "1.1.1"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "1c133bc6a41be0d194c306b5506d15e6feeea7b1d6604bd3f8310dfb2ca96486"
+
+[[package]]
+name = "colorchoice"
+version = "1.0.5"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "1d07550c9036bf2ae0c684c4297d503f838287c83c53686d05370d0e139ae570"
+
+[[package]]
+name = "core-foundation"
+version = "0.9.4"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "91e195e091a93c46f7102ec7818a2aa394e1e1771c3ab4825963fa03e45afb8f"
+dependencies = [
+ "core-foundation-sys",
+ "libc",
+]
+
+[[package]]
+name = "core-foundation-sys"
+version = "0.8.7"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "773648b94d0e5d620f64f280777445740e61fe701025087ec8b57f45c791888b"
+
+[[package]]
+name = "core_detect"
+version = "1.0.0"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "7f8f80099a98041a3d1622845c271458a2d73e688351bf3cb999266764b81d48"
+
+[[package]]
+name = "displaydoc"
+version = "0.2.7"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "c6232dd377dcc64799954cbd3a9bb882e9cdc1308ccd87b1c098f1fb2eaf82a8"
+dependencies = [
+ "proc-macro2",
+ "quote",
+ "syn 3.0.6",
+]
+
+[[package]]
+name = "either"
+version = "1.18.0"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "252afb9ae5eaa683babdc6a068b3f5726eb19e05070c731f9b2a23a7c3e8ed34"
+
+[[package]]
+name = "encoding_rs"
+version = "0.8.42"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "8e985e0451871ad22fb8d2b6b076e2028a502a0d3950998c2c5c0a4f9b5d9679"
+dependencies = [
+ "cfg-if",
+ "core_detect",
+ "multiversion_no_op",
+ "rustversion",
+ "scopeguard",
+ "simdutf8",
+]
+
+[[package]]
+name = "equivalent"
+version = "1.0.2"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "877a4ace8713b0bcf2a4e7eec82529c029f1d0619886d18145fea96c3ffe5c0f"
+
+[[package]]
+name = "errno"
+version = "0.3.14"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "39cab71617ae0d63f51a36d69f866391735b51691dbda63cf6f96d042b63efeb"
+dependencies = [
+ "libc",
+ "windows-sys 0.61.2",
+]
+
+[[package]]
+name = "fnv"
+version = "1.0.7"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "3f9eec918d3f24069decb9af1554cad7c880e2da24a9afd88aca000531ab82c1"
+
+[[package]]
+name = "form_urlencoded"
+version = "1.2.2"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "cb4cb245038516f5f85277875cdaa4f7d2c9a0fa0468de06ed190163b1581fcf"
+dependencies = [
+ "percent-encoding",
+]
+
+[[package]]
+name = "futures-channel"
+version = "0.3.34"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "b1f9e3d69d39e4862ffed03ed071a76f9a13ba1d9109d355b0f0aa6b15e393c4"
+dependencies = [
+ "futures-core",
+]
+
+[[package]]
+name = "futures-core"
+version = "0.3.34"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "92d699e522242e69e3003b94ecc1f960f3a5e015aa7c5d7486e65ad01dd94f5e"
+
+[[package]]
+name = "futures-sink"
+version = "0.3.34"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "1944426bf7d03f1d14f708785e4b33efd750b36d48a157b836b3efc15ede8e1d"
+
+[[package]]
+name = "futures-task"
+version = "0.3.34"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "cd417de3d1d015fc3bfd2b1ea46dfc7bab72ef86f1cc7cc9c78e728b34a6d1fd"
+
+[[package]]
+name = "futures-util"
+version = "0.3.34"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "0d50a92467f8ba5dd6e3ee5d4bd04d73ab2e4e1c44474a0674821dfce14b79bc"
+dependencies = [
+ "futures-core",
+ "futures-task",
+ "pin-project-lite",
+ "slab",
+]
+
+[[package]]
+name = "h2"
+version = "0.3.27"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "0beca50380b1fc32983fc1cb4587bfa4bb9e78fc259aad4a0032d2080309222d"
+dependencies = [
+ "bytes",
+ "fnv",
+ "futures-core",
+ "futures-sink",
+ "futures-util",
+ "http",
+ "indexmap",
+ "slab",
+ "tokio",
+ "tokio-util",
+ "tracing",
+]
+
+[[package]]
+name = "hashbrown"
+version = "0.17.1"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "ed5909b6e89a2db4456e54cd5f673791d7eca6732202bbf2a9cc504fe2f9b84a"
+
+[[package]]
+name = "heck"
+version = "0.5.0"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "2304e00983f87ffb38b55b444b5e3b60a884b5d30c0fca7d82fe33449bbe55ea"
+
+[[package]]
+name = "http"
+version = "0.2.12"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "601cbb57e577e2f5ef5be8e7b83f0f63994f25aa94d673e54a92d5c516d101f1"
+dependencies = [
+ "bytes",
+ "fnv",
+ "itoa",
+]
+
+[[package]]
+name = "http-body"
+version = "0.4.6"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "7ceab25649e9960c0311ea418d17bee82c0dcec1bd053b5f9a66e265a693bed2"
+dependencies = [
+ "bytes",
+ "http",
+ "pin-project-lite",
+]
+
+[[package]]
+name = "httparse"
+version = "1.10.1"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "6dbf3de79e51f3d586ab4cb9d5c3e2c14aa28ed23d180cf89b4df0454a69cc87"
+
+[[package]]
+name = "httpdate"
+version = "1.0.3"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "df3b46402a9d5adb4c86a0cf463f42e19994e3ee891101b1841f30a545cb49a9"
+
+[[package]]
+name = "hyper"
+version = "0.14.32"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "41dfc780fdec9373c01bae43289ea34c972e40ee3c9f6b3c8801a35f35586ce7"
+dependencies = [
+ "bytes",
+ "futures-channel",
+ "futures-core",
+ "futures-util",
+ "h2",
+ "http",
+ "http-body",
+ "httparse",
+ "httpdate",
+ "itoa",
+ "pin-project-lite",
+ "socket2 0.5.10",
+ "tokio",
+ "tower-service",
+ "tracing",
+ "want",
+]
+
+[[package]]
+name = "icu_collections"
+version = "2.3.0"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "fa68d21081c4a05d5a901a1c62add574c77048b6a1c67be3b50ce0b60d4ca513"
+dependencies = [
+ "displaydoc",
+ "potential_utf",
+ "utf8_iter",
+ "yoke",
+ "zerofrom",
+ "zerovec",
+]
+
+[[package]]
+name = "icu_locale_core"
+version = "2.3.0"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "d56e28588da92eee5c3201a6eff33fabdd49b62269c8938d4ff050ce4d900deb"
+dependencies = [
+ "displaydoc",
+ "litemap",
+ "tinystr",
+ "writeable",
+ "zerovec",
+]
+
+[[package]]
+name = "icu_normalizer"
+version = "2.3.0"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "12f9cf5f235641ed274641dd81c3f28d870e276763d0797aeeab72317b1c646f"
+dependencies = [
+ "icu_collections",
+ "icu_normalizer_data",
+ "icu_properties",
+ "icu_provider",
+ "smallvec",
+ "zerovec",
+]
+
+[[package]]
+name = "icu_normalizer_data"
+version = "2.3.0"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "1563da1ed3e0b3bf3d74c9b85917ac9c56464d2f57242270c09c9e752f8021a0"
+
+[[package]]
+name = "icu_properties"
+version = "2.3.0"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "7e7ca276ad3145661a65914e6daf131ca5120cd3dcee8f8f3214b8875184a148"
+dependencies = [
+ "displaydoc",
+ "icu_collections",
+ "icu_locale_core",
+ "icu_properties_data",
+ "icu_provider",
+ "zerotrie",
+ "zerovec",
+]
+
+[[package]]
+name = "icu_properties_data"
+version = "2.3.0"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "e590f038c1464a96894fd6d10127e90a8be4509f56ff7ecef851b15cee0b7caa"
+
+[[package]]
+name = "icu_provider"
+version = "2.3.1"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "d27bbb9d3abbefac45d55f647c9de1d44aafcd1186eb91879afef17c396c3e73"
+dependencies = [
+ "displaydoc",
+ "icu_locale_core",
+ "writeable",
+ "yoke",
+ "zerofrom",
+ "zerotrie",
+ "zerovec",
+]
+
+[[package]]
+name = "idna"
+version = "1.1.0"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "3b0875f23caa03898994f6ddc501886a45c7d3d62d04d2d90788d47be1b1e4de"
+dependencies = [
+ "idna_adapter",
+ "smallvec",
+ "utf8_iter",
+]
+
+[[package]]
+name = "idna_adapter"
+version = "1.2.2"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "cb68373c0d6620ef8105e855e7745e18b0d00d3bdb07fb532e434244cdb9a714"
+dependencies = [
+ "icu_normalizer",
+ "icu_properties",
+]
+
+[[package]]
+name = "indexmap"
+version = "2.14.2"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "cc4e190f5d26ca7051642629da2c52fc03bde85a03197c99408dcd291734c855"
+dependencies = [
+ "equivalent",
+ "hashbrown",
+]
+
+[[package]]
+name = "ipnet"
+version = "2.12.2"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "791930b43c0d5973160d90a8f3894509f2b273430f5c5c73b668636d0287c5c0"
+
+[[package]]
+name = "is_terminal_polyfill"
+version = "1.70.2"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "a6cb138bb79a146c1bd460005623e142ef0181e3d0219cb493e02f7d08a35695"
+
+[[package]]
+name = "itertools"
+version = "0.14.0"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "2b192c782037fadd9cfa75548310488aabdbf3d2da73885b31bd0abd03351285"
+dependencies = [
+ "either",
+]
+
+[[package]]
+name = "itoa"
+version = "1.0.18"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "8f42a60cbdf9a97f5d2305f08a87dc4e09308d1276d28c869c684d7777685682"
+
+[[package]]
+name = "js-sys"
+version = "0.3.106"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "7883d941dae510fb2d978fc3fe018c71c9e2892fd38854de3e8b92c2e5ad9cc5"
+dependencies = [
+ "cfg-if",
+ "futures-util",
+ "wasm-bindgen",
+]
+
+[[package]]
+name = "libc"
+version = "0.2.190"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "ce5d3ddc6d3fa000eb1536d85e147bfe31aacaba692ed6a876f95cb7c855be78"
+
+[[package]]
+name = "litemap"
+version = "0.8.3"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "47d9d19d1d6efa0109d2f65ff4c85cddd50bd572e5a00127ab10987290bcefae"
+
+[[package]]
+name = "lock_api"
+version = "0.4.14"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "224399e74b87b5f3557511d98dff8b14089b3dadafcab6bb93eab67d3aace965"
+dependencies = [
+ "scopeguard",
+]
+
+[[package]]
+name = "log"
+version = "0.4.34"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "f9f8bd3e56ce4dfc153cf470fffbfa98c7620958b312ca5c3a4b8d5181fd13c6"
+
+[[package]]
+name = "memchr"
+version = "2.8.3"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "cf8baf1c55e62ffcace7a9f06f4bd9cd3f0c4beb022d3b367256b91b87513d98"
+
+[[package]]
+name = "mime"
+version = "0.3.17"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "6877bb514081ee2a7ff5ef9de3281f14a4dd4bceac4c09388074a6b5df8a139a"
+
+[[package]]
+name = "mio"
+version = "1.2.4"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "1788edb87fdc09c7e26304471e2f5be8cdefb1b6930d6e3985fc02ff53bf86ee"
+dependencies = [
+ "libc",
+ "wasi",
+ "windows-sys 0.61.2",
+]
+
+[[package]]
+name = "multiversion_no_op"
+version = "1.0.0"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "743fb55ba31b18fb1ecef6bdc9aa2743314978ac084044301a7eee33fb99a20d"
+
+[[package]]
+name = "once_cell"
+version = "1.21.4"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "9f7c3e4beb33f85d45ae3e3a1792185706c8e16d043238c593331cc7cd313b50"
+
+[[package]]
+name = "once_cell_polyfill"
+version = "1.70.2"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "384b8ab6d37215f3c5301a95a4accb5d64aa607f1fcb26a11b5303878451b4fe"
+
+[[package]]
+name = "paced_feeder"
+version = "0.1.0"
+dependencies = [
+ "anyhow",
+ "clap",
+ "prost",
+ "reqwest",
+ "serde",
+ "serde_json",
+ "snap",
+ "tokio",
+]
+
+[[package]]
+name = "parking_lot"
+version = "0.12.5"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "93857453250e3077bd71ff98b6a65ea6621a19bb0f559a85248955ac12c45a1a"
+dependencies = [
+ "lock_api",
+ "parking_lot_core",
+]
+
+[[package]]
+name = "parking_lot_core"
+version = "0.9.12"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "2621685985a2ebf1c516881c026032ac7deafcda1a2c9b7850dc81e3dfcb64c1"
+dependencies = [
+ "cfg-if",
+ "libc",
+ "redox_syscall",
+ "smallvec",
+ "windows-link",
+]
+
+[[package]]
+name = "percent-encoding"
+version = "2.3.2"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "9b4f627cb1b25917193a259e49bdad08f671f8d9708acfd5fe0a8c1455d87220"
+
+[[package]]
+name = "pin-project-lite"
+version = "0.2.17"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "a89322df9ebe1c1578d689c92318e070967d1042b512afbe49518723f4e6d5cd"
+
+[[package]]
+name = "potential_utf"
+version = "0.1.6"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "d83eb9bc6d8e5cf568e7a1101d60ee05e81ed50ea106026f3d18deeb046d7661"
+dependencies = [
+ "zerovec",
+]
+
+[[package]]
+name = "proc-macro2"
+version = "1.0.107"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "985e7ec9bb745e6ce6535b544d84d6cd6f7ad8bd711c398938ae983b91a766d9"
+dependencies = [
+ "unicode-ident",
+]
+
+[[package]]
+name = "prost"
+version = "0.13.5"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "2796faa41db3ec313a31f7624d9286acf277b52de526150b7e69f3debf891ee5"
+dependencies = [
+ "bytes",
+ "prost-derive",
+]
+
+[[package]]
+name = "prost-derive"
+version = "0.13.5"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "8a56d757972c98b346a9b766e3f02746cde6dd1cd1d1d563472929fdd74bec4d"
+dependencies = [
+ "anyhow",
+ "itertools",
+ "proc-macro2",
+ "quote",
+ "syn 2.0.119",
+]
+
+[[package]]
+name = "quote"
+version = "1.0.47"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "1fbf4db142a473a8d80c26bbf18454ed458bf8d26c8219c331daecfdbd079001"
+dependencies = [
+ "proc-macro2",
+]
+
+[[package]]
+name = "redox_syscall"
+version = "0.5.18"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "ed2bf2547551a7053d6fdfafda3f938979645c44812fbfcda098faae3f1a362d"
+dependencies = [
+ "bitflags 2.13.2",
+]
+
+[[package]]
+name = "reqwest"
+version = "0.11.27"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "dd67538700a17451e7cba03ac727fb961abb7607553461627b97de0b89cf4a62"
+dependencies = [
+ "base64",
+ "bytes",
+ "encoding_rs",
+ "futures-core",
+ "futures-util",
+ "h2",
+ "http",
+ "http-body",
+ "hyper",
+ "ipnet",
+ "js-sys",
+ "log",
+ "mime",
+ "once_cell",
+ "percent-encoding",
+ "pin-project-lite",
+ "serde",
+ "serde_json",
+ "serde_urlencoded",
+ "sync_wrapper",
+ "system-configuration",
+ "tokio",
+ "tower-service",
+ "url",
+ "wasm-bindgen",
+ "wasm-bindgen-futures",
+ "web-sys",
+ "winreg",
+]
+
+[[package]]
+name = "rustversion"
+version = "1.0.23"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "cf54715a573b99ac80df0bc206da022bcd442c974952c7b9720069370852e21f"
+
+[[package]]
+name = "ryu"
+version = "1.0.23"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "9774ba4a74de5f7b1c1451ed6cd5285a32eddb5cccb8cc655a4e50009e06477f"
+
+[[package]]
+name = "scopeguard"
+version = "1.2.0"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "94143f37725109f92c262ed2cf5e59bce7498c01bcc1502d7b9afe439a4e9f49"
+
+[[package]]
+name = "serde"
+version = "1.0.229"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "4148590afebada386688f18773da617792bf2ef03ffc1e4cbd2b1d45b023e0ba"
+dependencies = [
+ "serde_core",
+ "serde_derive",
+]
+
+[[package]]
+name = "serde_core"
+version = "1.0.229"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "67dca2c9c51e58a4791a4b1ed58308b39c64224d349a935ab5039aa360942a48"
+dependencies = [
+ "serde_derive",
+]
+
+[[package]]
+name = "serde_derive"
+version = "1.0.229"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "e7a5d71263a5a7d47b41f6b3f06ba276f10cc18b0931f1799f710578e2309348"
+dependencies = [
+ "proc-macro2",
+ "quote",
+ "syn 3.0.6",
+]
+
+[[package]]
+name = "serde_json"
+version = "1.0.151"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "c841b55ecdae098c80dcae9cf767f6f8a0c2cdb3416bbef72181df4d0fe73f14"
+dependencies = [
+ "itoa",
+ "memchr",
+ "serde",
+ "serde_core",
+ "zmij",
+]
+
+[[package]]
+name = "serde_urlencoded"
+version = "0.7.1"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "d3491c14715ca2294c4d6a88f15e84739788c1d030eed8c110436aafdaa2f3fd"
+dependencies = [
+ "form_urlencoded",
+ "itoa",
+ "ryu",
+ "serde",
+]
+
+[[package]]
+name = "signal-hook-registry"
+version = "1.4.8"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "c4db69cba1110affc0e9f7bcd48bbf87b3f4fc7c61fc9155afd4c469eb3d6c1b"
+dependencies = [
+ "errno",
+ "libc",
+]
+
+[[package]]
+name = "simdutf8"
+version = "0.1.5"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "e3a9fe34e3e7a50316060351f37187a3f546bce95496156754b601a5fa71b76e"
+
+[[package]]
+name = "slab"
+version = "0.4.12"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "0c790de23124f9ab44544d7ac05d60440adc586479ce501c1d6d7da3cd8c9cf5"
+
+[[package]]
+name = "smallvec"
+version = "1.16.2"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "f9395f0f0eee849a9b707b2f06bb92a6a422090e2123bb2ef8e87a0e61892a8e"
+
+[[package]]
+name = "snap"
+version = "1.1.2"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "199905e6153d6405f9728fe44daace35f8f837bbf830bb6e85fbd5828709a886"
+
+[[package]]
+name = "socket2"
+version = "0.5.10"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "e22376abed350d73dd1cd119b57ffccad95b4e585a7cda43e286245ce23c0678"
+dependencies = [
+ "libc",
+ "windows-sys 0.52.0",
+]
+
+[[package]]
+name = "socket2"
+version = "0.6.5"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "c3d1e2c7f27f8d4cb10542a02c49005dbd6e93095799d6f3be745fae9f8fedd4"
+dependencies = [
+ "libc",
+ "windows-sys 0.61.2",
+]
+
+[[package]]
+name = "stable_deref_trait"
+version = "1.2.1"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "6ce2be8dc25455e1f91df71bfa12ad37d7af1092ae736f3a6cd0e37bc7810596"
+
+[[package]]
+name = "strsim"
+version = "0.11.1"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "7da8b5736845d9f2fcb837ea5d9e2628564b3b043a70948a3f0b778838c5fb4f"
+
+[[package]]
+name = "syn"
+version = "2.0.119"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "872831b642d1a07999a962a351ed35b955ea2cfc8f3862091e2a240a84f17297"
+dependencies = [
+ "proc-macro2",
+ "quote",
+ "unicode-ident",
+]
+
+[[package]]
+name = "syn"
+version = "3.0.6"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "8593e8e72159ed2257d083c7a454a85cbf854f37a0966d8d483aff8c8a3ebcee"
+dependencies = [
+ "proc-macro2",
+ "quote",
+ "unicode-ident",
+]
+
+[[package]]
+name = "sync_wrapper"
+version = "0.1.2"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "2047c6ded9c721764247e62cd3b03c09ffc529b2ba5b10ec482ae507a4a70160"
+
+[[package]]
+name = "synstructure"
+version = "0.14.0"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "901704edd0dfe137f1987838ee4f259e4e063c31371bdb423f7ae38ec6f77f02"
+dependencies = [
+ "proc-macro2",
+ "quote",
+ "syn 3.0.6",
+]
+
+[[package]]
+name = "system-configuration"
+version = "0.5.1"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "ba3a3adc5c275d719af8cb4272ea1c4a6d668a777f37e115f6d11ddbc1c8e0e7"
+dependencies = [
+ "bitflags 1.3.2",
+ "core-foundation",
+ "system-configuration-sys",
+]
+
+[[package]]
+name = "system-configuration-sys"
+version = "0.5.0"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "a75fb188eb626b924683e3b95e3a48e63551fcfb51949de2f06a9d91dbee93c9"
+dependencies = [
+ "core-foundation-sys",
+ "libc",
+]
+
+[[package]]
+name = "tinystr"
+version = "0.8.4"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "b1e27c91459209c2986af3dcf603a5a74a4368754ce37414f59acc971167f643"
+dependencies = [
+ "displaydoc",
+ "zerovec",
+]
+
+[[package]]
+name = "tokio"
+version = "1.53.2"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "e95f91fcc7a621e8b030f6aa23c71fe9838ae2fb4d8118b75602a328f5144044"
+dependencies = [
+ "bytes",
+ "libc",
+ "mio",
+ "parking_lot",
+ "pin-project-lite",
+ "signal-hook-registry",
+ "socket2 0.6.5",
+ "tokio-macros",
+ "windows-sys 0.61.2",
+]
+
+[[package]]
+name = "tokio-macros"
+version = "2.7.2"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "78773a2a397f451582ce068015985c33193cf6dea8b74d2a639fe457b2f07b0e"
+dependencies = [
+ "proc-macro2",
+ "quote",
+ "syn 3.0.6",
+]
+
+[[package]]
+name = "tokio-util"
+version = "0.7.19"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "494815d09bf52b5548659851081238f0ca39ff638363907596da739561c62c52"
+dependencies = [
+ "bytes",
+ "futures-core",
+ "futures-sink",
+ "libc",
+ "pin-project-lite",
+ "tokio",
+]
+
+[[package]]
+name = "tower-service"
+version = "0.3.3"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "8df9b6e13f2d32c91b9bd719c00d1958837bc7dec474d94952798cc8e69eeec3"
+
+[[package]]
+name = "tracing"
+version = "0.1.44"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "63e71662fa4b2a2c3a26f570f037eb95bb1f85397f3cd8076caed2f026a6d100"
+dependencies = [
+ "pin-project-lite",
+ "tracing-core",
+]
+
+[[package]]
+name = "tracing-core"
+version = "0.1.36"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "db97caf9d906fbde555dd62fa95ddba9eecfd14cb388e4f491a66d74cd5fb79a"
+dependencies = [
+ "once_cell",
+]
+
+[[package]]
+name = "try-lock"
+version = "0.2.5"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "e421abadd41a4225275504ea4d6566923418b7f05506fbc9c0fe86ba7396114b"
+
+[[package]]
+name = "unicode-ident"
+version = "1.0.26"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "d245f478577f809a851594d02313b640fb437e0bb33866753cff937863096954"
+
+[[package]]
+name = "url"
+version = "2.5.8"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "ff67a8a4397373c3ef660812acab3268222035010ab8680ec4215f38ba3d0eed"
+dependencies = [
+ "form_urlencoded",
+ "idna",
+ "percent-encoding",
+ "serde",
+]
+
+[[package]]
+name = "utf8_iter"
+version = "1.0.4"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "b6c140620e7ffbb22c2dee59cafe6084a59b5ffc27a8859a5f0d494b5d52b6be"
+
+[[package]]
+name = "utf8parse"
+version = "0.2.2"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "06abde3611657adf66d383f00b093d7faecc7fa57071cce2578660c9f1010821"
+
+[[package]]
+name = "want"
+version = "0.3.1"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "bfa7760aed19e106de2c7c0b581b509f2f25d3dacaf737cb82ac61bc6d760b0e"
+dependencies = [
+ "try-lock",
+]
+
+[[package]]
+name = "wasi"
+version = "0.11.1+wasi-snapshot-preview1"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "ccf3ec651a847eb01de73ccad15eb7d99f80485de043efb2f370cd654f4ea44b"
+
+[[package]]
+name = "wasm-bindgen"
+version = "0.2.129"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "9bb54f33acc68fd454578d9820b0bde1a1a3d17aa17bb7b6595806d02886d409"
+dependencies = [
+ "cfg-if",
+ "once_cell",
+ "rustversion",
+ "wasm-bindgen-macro",
+ "wasm-bindgen-shared",
+]
+
+[[package]]
+name = "wasm-bindgen-futures"
+version = "0.4.79"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "3cbab34de2d982e9b48e18d216d04c4a6f641066ff19ffb699980f591ee3610e"
+dependencies = [
+ "js-sys",
+ "tokio",
+ "wasm-bindgen",
+]
+
+[[package]]
+name = "wasm-bindgen-macro"
+version = "0.2.129"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "2e29d0c35b16e224a7eeb5cd2d25e3e1968fbd65604117b44d3b789d00ee8535"
+dependencies = [
+ "quote",
+ "wasm-bindgen-macro-support",
+]
+
+[[package]]
+name = "wasm-bindgen-macro-support"
+version = "0.2.129"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "6f501a8bc3719dba86ef8ae4728879c08001bea749eb1333ac5b91e040e2a6b7"
+dependencies = [
+ "bumpalo",
+ "proc-macro2",
+ "quote",
+ "syn 3.0.6",
+ "wasm-bindgen-shared",
+]
+
+[[package]]
+name = "wasm-bindgen-shared"
+version = "0.2.129"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "23f0c9c52aa7cd7d77769a4cfe2a9adb1b331f489a41d912ce14513d5ab995c6"
+dependencies = [
+ "unicode-ident",
+]
+
+[[package]]
+name = "web-sys"
+version = "0.3.106"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "88261b9deccee56594c11a3460c462c41f58d148598fe70ad77070126a68aba4"
+dependencies = [
+ "js-sys",
+ "wasm-bindgen",
+]
+
+[[package]]
+name = "windows-link"
+version = "0.2.1"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "f0805222e57f7521d6a62e36fa9163bc891acd422f971defe97d64e70d0a4fe5"
+
+[[package]]
+name = "windows-sys"
+version = "0.48.0"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "677d2418bec65e3338edb076e806bc1ec15693c5d0104683f2efe857f61056a9"
+dependencies = [
+ "windows-targets 0.48.5",
+]
+
+[[package]]
+name = "windows-sys"
+version = "0.52.0"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "282be5f36a8ce781fad8c8ae18fa3f9beff57ec1b52cb3de0789201425d9a33d"
+dependencies = [
+ "windows-targets 0.52.6",
+]
+
+[[package]]
+name = "windows-sys"
+version = "0.61.2"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "ae137229bcbd6cdf0f7b80a31df61766145077ddf49416a728b02cb3921ff3fc"
+dependencies = [
+ "windows-link",
+]
+
+[[package]]
+name = "windows-targets"
+version = "0.48.5"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "9a2fa6e2155d7247be68c096456083145c183cbbbc2764150dda45a87197940c"
+dependencies = [
+ "windows_aarch64_gnullvm 0.48.5",
+ "windows_aarch64_msvc 0.48.5",
+ "windows_i686_gnu 0.48.5",
+ "windows_i686_msvc 0.48.5",
+ "windows_x86_64_gnu 0.48.5",
+ "windows_x86_64_gnullvm 0.48.5",
+ "windows_x86_64_msvc 0.48.5",
+]
+
+[[package]]
+name = "windows-targets"
+version = "0.52.6"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "9b724f72796e036ab90c1021d4780d4d3d648aca59e491e6b98e725b84e99973"
+dependencies = [
+ "windows_aarch64_gnullvm 0.52.6",
+ "windows_aarch64_msvc 0.52.6",
+ "windows_i686_gnu 0.52.6",
+ "windows_i686_gnullvm",
+ "windows_i686_msvc 0.52.6",
+ "windows_x86_64_gnu 0.52.6",
+ "windows_x86_64_gnullvm 0.52.6",
+ "windows_x86_64_msvc 0.52.6",
+]
+
+[[package]]
+name = "windows_aarch64_gnullvm"
+version = "0.48.5"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "2b38e32f0abccf9987a4e3079dfb67dcd799fb61361e53e2882c3cbaf0d905d8"
+
+[[package]]
+name = "windows_aarch64_gnullvm"
+version = "0.52.6"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "32a4622180e7a0ec044bb555404c800bc9fd9ec262ec147edd5989ccd0c02cd3"
+
+[[package]]
+name = "windows_aarch64_msvc"
+version = "0.48.5"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "dc35310971f3b2dbbf3f0690a219f40e2d9afcf64f9ab7cc1be722937c26b4bc"
+
+[[package]]
+name = "windows_aarch64_msvc"
+version = "0.52.6"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "09ec2a7bb152e2252b53fa7803150007879548bc709c039df7627cabbd05d469"
+
+[[package]]
+name = "windows_i686_gnu"
+version = "0.48.5"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "a75915e7def60c94dcef72200b9a8e58e5091744960da64ec734a6c6e9b3743e"
+
+[[package]]
+name = "windows_i686_gnu"
+version = "0.52.6"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "8e9b5ad5ab802e97eb8e295ac6720e509ee4c243f69d781394014ebfe8bbfa0b"
+
+[[package]]
+name = "windows_i686_gnullvm"
+version = "0.52.6"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "0eee52d38c090b3caa76c563b86c3a4bd71ef1a819287c19d586d7334ae8ed66"
+
+[[package]]
+name = "windows_i686_msvc"
+version = "0.48.5"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "8f55c233f70c4b27f66c523580f78f1004e8b5a8b659e05a4eb49d4166cca406"
+
+[[package]]
+name = "windows_i686_msvc"
+version = "0.52.6"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "240948bc05c5e7c6dabba28bf89d89ffce3e303022809e73deaefe4f6ec56c66"
+
+[[package]]
+name = "windows_x86_64_gnu"
+version = "0.48.5"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "53d40abd2583d23e4718fddf1ebec84dbff8381c07cae67ff7768bbf19c6718e"
+
+[[package]]
+name = "windows_x86_64_gnu"
+version = "0.52.6"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "147a5c80aabfbf0c7d901cb5895d1de30ef2907eb21fbbab29ca94c5b08b1a78"
+
+[[package]]
+name = "windows_x86_64_gnullvm"
+version = "0.48.5"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "0b7b52767868a23d5bab768e390dc5f5c55825b6d30b86c844ff2dc7414044cc"
+
+[[package]]
+name = "windows_x86_64_gnullvm"
+version = "0.52.6"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "24d5b23dc417412679681396f2b49f3de8c1473deb516bd34410872eff51ed0d"
+
+[[package]]
+name = "windows_x86_64_msvc"
+version = "0.48.5"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "ed94fce61571a4006852b7389a063ab983c02eb1bb37b47f8272ce92d06d9538"
+
+[[package]]
+name = "windows_x86_64_msvc"
+version = "0.52.6"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "589f6da84c646204747d1270a2a5661ea66ed1cced2631d546fdfb155959f9ec"
+
+[[package]]
+name = "winreg"
+version = "0.50.0"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "524e57b2c537c0f9b1e69f1965311ec12182b4122e45035b1508cd24d2adadb1"
+dependencies = [
+ "cfg-if",
+ "windows-sys 0.48.0",
+]
+
+[[package]]
+name = "writeable"
+version = "0.6.4"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "3ad82d2a33cdc9674dc7465672f271e096168fcdbe0f799d9e6db8c5892679dc"
+
+[[package]]
+name = "yoke"
+version = "0.8.3"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "709fe23a0424b6a435d82152b1bd3fdfb0833487d5fa90d05d42762a9891fef5"
+dependencies = [
+ "stable_deref_trait",
+ "yoke-derive",
+ "zerofrom",
+]
+
+[[package]]
+name = "yoke-derive"
+version = "0.8.4"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "ec8ebde2db3681e8c9980cc27822030e68752690ddfa9473e739aeb4dbde6d71"
+dependencies = [
+ "proc-macro2",
+ "quote",
+ "syn 3.0.6",
+ "synstructure",
+]
+
+[[package]]
+name = "zerofrom"
+version = "0.1.8"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "0ec05a11813ea801ff6d75110ad09cd0824ddba17dfe17128ea0d5f68e6c5272"
+dependencies = [
+ "zerofrom-derive",
+]
+
+[[package]]
+name = "zerofrom-derive"
+version = "0.1.8"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "f75b4683f6c7f45248d4d64056a24298c6281e0993356d7d1b4a1a962ef10d4a"
+dependencies = [
+ "proc-macro2",
+ "quote",
+ "syn 3.0.6",
+ "synstructure",
+]
+
+[[package]]
+name = "zerotrie"
+version = "0.2.5"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "4ea269c3bd32f0a32c321907a2ae912ba6f4649bb0fc764a15627e99a7095a3f"
+dependencies = [
+ "displaydoc",
+ "yoke",
+ "zerofrom",
+]
+
+[[package]]
+name = "zerovec"
+version = "0.11.8"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "bb0464e17806c1d976d5cba29399c7f08e516e279e2ba493f63123b5fca67dd8"
+dependencies = [
+ "yoke",
+ "zerofrom",
+ "zerovec-derive",
+]
+
+[[package]]
+name = "zerovec-derive"
+version = "0.11.6"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "34df6fc39dbd26ddc9c10e6a2984476e13acce22e64e4487636ef494369225da"
+dependencies = [
+ "proc-macro2",
+ "quote",
+ "syn 3.0.6",
+]
+
+[[package]]
+name = "zmij"
+version = "1.0.23"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "29666d0abbfad1e3dc4dcf6144730dd3a3ab225bbbdac83319345b1b44ccfc1b"
diff --git a/asap-tools/data-sources/paced-feeder/Cargo.toml b/asap-tools/data-sources/paced-feeder/Cargo.toml
new file mode 100644
index 00000000..0eec93bd
--- /dev/null
+++ b/asap-tools/data-sources/paced-feeder/Cargo.toml
@@ -0,0 +1,22 @@
+[package]
+name = "paced_feeder"
+version = "0.1.0"
+edition = "2021"
+description = "Generates a seeded synthetic workload on the fly and sends it in real time to ASAPQuery (Prometheus remote write) or ClickHouse (RowBinary INSERT)"
+
+[[bin]]
+name = "paced_feeder"
+path = "src/main.rs"
+
+[dependencies]
+anyhow = "1.0"
+clap = { version = "4.0", features = ["derive", "env"] }
+prost = "0.13"
+reqwest = { version = "0.11", default-features = false }
+serde = { version = "1.0", features = ["derive"] }
+serde_json = "1.0"
+snap = "1"
+tokio = { version = "1.0", features = ["full"] }
+
+# Standalone tool, not a member of the root workspace.
+[workspace]
diff --git a/asap-tools/data-sources/paced-feeder/README.md b/asap-tools/data-sources/paced-feeder/README.md
new file mode 100644
index 00000000..d1f3b10a
--- /dev/null
+++ b/asap-tools/data-sources/paced-feeder/README.md
@@ -0,0 +1,78 @@
+# paced_feeder
+
+Generates a seeded synthetic workload on the fly and sends it in real time,
+one second of event time per wall-clock second, to either:
+
+- **ASAPQuery** over Prometheus remote write (`/api/v1/write`), or
+- **ClickHouse** over its HTTP interface (`INSERT … FORMAT RowBinary`).
+
+It drives the data-plane vs ClickHouse evaluation
+(`asap-tools/experiments/DATA_PLANE_CLICKHOUSE_EVAL_PLAN.md`). Two feeders
+started with the same workload flags send identical data, so each system gets
+the same stream without a dataset file on disk.
+
+## Workload
+
+- `--groups C` values of `label_0` (`g0`, `g1`, …) and `--series-per-group s`
+  values of `instance` (`i0`, `i1`, …) per group: `C·s` series.
+- Each series emits `--samples-per-sec` samples per second, evenly spaced.
+- Values are Pareto(`--pareto-shape`, `--pareto-scale`), all ≥ the scale.
+- A value depends only on `(--seed, series, sample index)`, never on wall-clock
+  time or the sink.
+
+Event time starts at the next whole wall-clock second (or `--start-ms`), so
+`NOW()`-relative queries see the data as it arrives.
+
+## Usage
+
+```sh
+cargo build --release
+
+# ASAPQuery
+target/release/paced_feeder --sink remote-write \
+  --url http://localhost:9090/api/v1/write --metric data \
+  --groups 1000 --series-per-group 100 --duration-secs 900 \
+  --stats-out asap-feed.json
+
+# ClickHouse
+target/release/paced_feeder --sink clickhouse \
+  --url http://localhost:8123 --table data \
+  --groups 1000 --series-per-group 100 --duration-secs 900 \
+  --stats-out clickhouse-feed.json
+```
+
+The ClickHouse table must have these columns (any engine and ordering):
+
+```sql
+CREATE TABLE data (ts DateTime64(3), label_0 String, instance String, value Float64)
+ENGINE = MergeTree ORDER BY (label_0, instance, ts);
+```
+
+`CLICKHOUSE_USER` / `CLICKHOUSE_PASSWORD` (or the matching flags) set
+credentials.
+
+## Pacing and stats
+
+Each tick's rows are split into `--batch-rows` requests and sent with up to
+`--concurrency` in flight. The next tick starts only after every request of
+the current one returns, so a series' samples never arrive out of order. The
+default batch size is 50,000 rows for remote write, which keeps a compressed
+request under axum's 2 MB body limit in ASAPQuery's ingest, and 100,000 for
+ClickHouse, where every INSERT creates a part.
+
+`--stats-out` writes, per tick, the rows, bytes, start lag and elapsed time,
+plus totals:
+- `achieved_rows_per_sec`;
+- `overrun_ticks` (ticks that took longer than one second);
+- `max_start_lag_ms`;
+- the first errors.
+
+A run with `overrun_ticks > 0` did not keep up. Any failed request makes the
+feeder exit non-zero.
+
+Measured on a CloudLab c6320 (feeder pinned to 2 cores, 10 s at 1e6 rows/s):
+
+| Sink | Ticks over 1 s | Feeder CPU |
+|---|---|---|
+| ClickHouse 26.10 | 0 | 0.15 cores |
+| ASAPQuery precompute engine | 0 | 0.34 cores |
diff --git a/asap-tools/data-sources/paced-feeder/src/encode.rs b/asap-tools/data-sources/paced-feeder/src/encode.rs
new file mode 100644
index 00000000..880c2202
--- /dev/null
+++ b/asap-tools/data-sources/paced-feeder/src/encode.rs
@@ -0,0 +1,217 @@
+//! Wire encoders for the two sinks. Each series' labels are encoded once up
+//! front, so the per-sample cost at high rates is just the value and timestamp.
+
+use crate::workload::{Row, Workload};
+use prost::encoding::{encode_key, encode_varint, encoded_len_varint, WireType};
+
+pub trait Encoder: Send + Sync {
+    fn encode(&self, rows: &[Row]) -> Vec<u8>;
+}
+
+/// Prometheus remote write: a snappy-compressed `WriteRequest` with one
+/// `TimeSeries` (labels + one sample) per row.
+pub struct RemoteWriteEncoder {
+    /// Encoded `Label` fields (`TimeSeries` field 1) for each series, sorted by
+    /// label name as Prometheus requires: `__name__`, `instance`, `label_0`.
+    series_labels: Vec<Vec<u8>>,
+}
+
+impl RemoteWriteEncoder {
+    pub fn new(workload: &Workload, metric: &str) -> Self {
+        let series_labels = (0..workload.num_series())
+            .map(|series| {
+                let (label_0, instance) = workload.series_labels(series);
+                let mut buf = Vec::new();
+                for (name, value) in [
+                    ("__name__", metric),
+                    ("instance", instance.as_str()),
+                    ("label_0", label_0.as_str()),
+                ] {
+                    let mut label = Vec::new();
+                    encode_bytes_field(1, name.as_bytes(), &mut label);
+                    encode_bytes_field(2, value.as_bytes(), &mut label);
+                    encode_bytes_field(1, &label, &mut buf);
+                }
+                buf
+            })
+            .collect();
+        Self { series_labels }
+    }
+}
+
+impl Encoder for RemoteWriteEncoder {
+    fn encode(&self, rows: &[Row]) -> Vec<u8> {
+        let mut request = Vec::new();
+        let mut series = Vec::new();
+        let mut sample = Vec::new();
+        for row in rows {
+            sample.clear();
+            encode_key(1, WireType::SixtyFourBit, &mut sample);
+            sample.extend_from_slice(&row.value.to_le_bytes());
+            encode_key(2, WireType::Varint, &mut sample);
+            encode_varint(row.timestamp_ms as u64, &mut sample);
+
+            series.clear();
+            series.extend_from_slice(&self.series_labels[row.series]);
+            encode_bytes_field(2, &sample, &mut series);
+
+            encode_bytes_field(1, &series, &mut request);
+        }
+        snap::raw::Encoder::new()
+            .compress_vec(&request)
+            .expect("snappy compression of an in-memory buffer cannot fail")
+    }
+}
+
+/// ClickHouse `RowBinary` for columns `(ts DateTime64(3), label_0 String,
+/// instance String, value Float64)`.
+pub struct RowBinaryEncoder {
+    /// `label_0` then `instance`, each as a varint length plus bytes.
+    series_labels: Vec<Vec<u8>>,
+}
+
+/// The column list `RowBinaryEncoder` writes, in order.
+pub const ROW_BINARY_COLUMNS: &str = "ts, label_0, instance, value";
+
+impl RowBinaryEncoder {
+    pub fn new(workload: &Workload) -> Self {
+        let series_labels = (0..workload.num_series())
+            .map(|series| {
+                let (label_0, instance) = workload.series_labels(series);
+                let mut buf = Vec::new();
+                for s in [label_0, instance] {
+                    encode_varint(s.len() as u64, &mut buf);
+                    buf.extend_from_slice(s.as_bytes());
+                }
+                buf
+            })
+            .collect();
+        Self { series_labels }
+    }
+}
+
+impl Encoder for RowBinaryEncoder {
+    fn encode(&self, rows: &[Row]) -> Vec<u8> {
+        let mut buf = Vec::with_capacity(rows.len() * 32);
+        for row in rows {
+            buf.extend_from_slice(&row.timestamp_ms.to_le_bytes());
+            buf.extend_from_slice(&self.series_labels[row.series]);
+            buf.extend_from_slice(&row.value.to_le_bytes());
+        }
+        buf
+    }
+}
+
+fn encode_bytes_field(tag: u32, bytes: &[u8], buf: &mut Vec<u8>) {
+    encode_key(tag, WireType::LengthDelimited, buf);
+    buf.reserve(encoded_len_varint(bytes.len() as u64) + bytes.len());
+    encode_varint(bytes.len() as u64, buf);
+    buf.extend_from_slice(bytes);
+}
+
+#[cfg(test)]
+mod tests {
+    use super::*;
+    use prost::Message;
+
+    // Mirrors the remote write types in
+    // asap-query-engine/src/drivers/ingest/prometheus_remote_write.rs.
+    #[derive(Clone, PartialEq, Message)]
+    struct WriteRequest {
+        #[prost(message, repeated, tag = "1")]
+        timeseries: Vec<TimeSeries>,
+    }
+    #[derive(Clone, PartialEq, Message)]
+    struct TimeSeries {
+        #[prost(message, repeated, tag = "1")]
+        labels: Vec<Label>,
+        #[prost(message, repeated, tag = "2")]
+        samples: Vec<Sample>,
+    }
+    #[derive(Clone, PartialEq, Message)]
+    struct Label {
+        #[prost(string, tag = "1")]
+        name: String,
+        #[prost(string, tag = "2")]
+        value: String,
+    }
+    #[derive(Clone, PartialEq, Message)]
+    struct Sample {
+        #[prost(double, tag = "1")]
+        value: f64,
+        #[prost(int64, tag = "2")]
+        timestamp: i64,
+    }
+
+    fn workload() -> Workload {
+        Workload {
+            seed: 1,
+            groups: 2,
+            series_per_group: 3,
+            samples_per_sec: 1,
+            pareto_shape: 1.5,
+            pareto_scale: 1.0,
+        }
+    }
+
+    #[test]
+    fn remote_write_decodes_to_one_series_per_row() {
+        let w = workload();
+        let rows = w.tick_rows(2, 1_700_000_000_000);
+        let body = RemoteWriteEncoder::new(&w, "data").encode(&rows);
+
+        let raw = snap::raw::Decoder::new().decompress_vec(&body).unwrap();
+        let request = WriteRequest::decode(raw.as_slice()).unwrap();
+        assert_eq!(request.timeseries.len(), rows.len());
+        for (ts, row) in request.timeseries.iter().zip(&rows) {
+            let (label_0, instance) = w.series_labels(row.series);
+            let labels: Vec<(&str, &str)> = ts
+                .labels
+                .iter()
+                .map(|l| (l.name.as_str(), l.value.as_str()))
+                .collect();
+            assert_eq!(
+                labels,
+                vec![
+                    ("__name__", "data"),
+                    ("instance", instance.as_str()),
+                    ("label_0", label_0.as_str()),
+                ]
+            );
+            assert_eq!(
+                ts.samples,
+                vec![Sample {
+                    value: row.value,
+                    timestamp: row.timestamp_ms
+                }]
+            );
+        }
+    }
+
+    #[test]
+    fn row_binary_round_trips_every_column() {
+        let w = workload();
+        let rows = w.tick_rows(0, 42_000);
+        let buf = RowBinaryEncoder::new(&w).encode(&rows);
+
+        let mut cursor = buf.as_slice();
+        let mut take = |n: usize| -> Vec<u8> {
+            let (head, rest) = cursor.split_at(n);
+            cursor = rest;
+            head.to_vec()
+        };
+        for row in &rows {
+            let ts = i64::from_le_bytes(take(8).try_into().unwrap());
+            // Labels are short, so their varint length is one byte.
+            let label_0_len = take(1)[0] as usize;
+            let label_0 = String::from_utf8(take(label_0_len)).unwrap();
+            let instance_len = take(1)[0] as usize;
+            let instance = String::from_utf8(take(instance_len)).unwrap();
+            let value = f64::from_le_bytes(take(8).try_into().unwrap());
+            assert_eq!(ts, row.timestamp_ms);
+            assert_eq!((label_0, instance), w.series_labels(row.series));
+            assert_eq!(value, row.value);
+        }
+        assert!(cursor.is_empty());
+    }
+}
diff --git a/asap-tools/data-sources/paced-feeder/src/main.rs b/asap-tools/data-sources/paced-feeder/src/main.rs
new file mode 100644
index 00000000..24e47d18
--- /dev/null
+++ b/asap-tools/data-sources/paced-feeder/src/main.rs
@@ -0,0 +1,340 @@
+//! Paced feeder: generates a seeded synthetic workload on the fly and sends it
+//! in real time, one second of event time per wall-clock second, to either
+//! ASAPQuery (Prometheus remote write) or ClickHouse (RowBinary INSERT).
+//!
+//! Two feeders with the same workload flags send byte-identical data to their
+//! systems, so the systems can be compared on the same stream. Per-tick timing
+//! is written to `--stats-out` so a run can be checked for keeping up.
+
+mod encode;
+mod workload;
+
+use anyhow::{bail, Context, Result};
+use clap::{Parser, ValueEnum};
+use encode::{Encoder, RemoteWriteEncoder, RowBinaryEncoder, ROW_BINARY_COLUMNS};
+use serde::Serialize;
+use std::sync::Arc;
+use std::time::{Duration, Instant, SystemTime, UNIX_EPOCH};
+use tokio::sync::Semaphore;
+use workload::Workload;
+
+#[derive(Debug, Clone, Copy, ValueEnum, Serialize)]
+#[serde(rename_all = "kebab-case")]
+enum SinkKind {
+    /// Prometheus remote write, e.g. to ASAPQuery's `/api/v1/write`.
+    RemoteWrite,
+    /// ClickHouse HTTP interface, `INSERT … FORMAT RowBinary`.
+    Clickhouse,
+}
+
+#[derive(Debug, Parser)]
+#[command(about = "Send a seeded synthetic workload in real time to ASAPQuery or ClickHouse")]
+struct Args {
+    #[arg(long, value_enum)]
+    sink: SinkKind,
+    /// Remote write endpoint (`http://host:port/api/v1/write`) or ClickHouse
+    /// HTTP base URL (`http://host:8123`).
+    #[arg(long)]
+    url: String,
+    /// Metric name sent as `__name__` (remote write only).
+    #[arg(long, default_value = "data")]
+    metric: String,
+    /// Target table, optionally `database.table` (ClickHouse only). Must have
+    /// columns `ts DateTime64(3), label_0 String, instance String, value Float64`.
+    #[arg(long, default_value = "data")]
+    table: String,
+    #[arg(long, env = "CLICKHOUSE_USER")]
+    clickhouse_user: Option<String>,
+    #[arg(long, env = "CLICKHOUSE_PASSWORD")]
+    clickhouse_password: Option<String>,
+
+    /// Number of `label_0` values (C).
+    #[arg(long)]
+    groups: usize,
+    /// Number of `instance` values per group (s).
+    #[arg(long)]
+    series_per_group: usize,
+    #[arg(long, default_value_t = 1)]
+    samples_per_sec: u32,
+    #[arg(long, default_value_t = 1.5)]
+    pareto_shape: f64,
+    #[arg(long, default_value_t = 1.0)]
+    pareto_scale: f64,
+    #[arg(long, default_value_t = 42)]
+    seed: u64,
+
+    /// Seconds of event time to send.
+    #[arg(long)]
+    duration_secs: u64,
+    /// Event time of the first tick, in ms since the epoch. Defaults to the
+    /// next whole wall-clock second, so `NOW()`-relative queries see live data.
+    #[arg(long)]
+    start_ms: Option<i64>,
+
+    /// Rows per HTTP request. Defaults to 50,000 for remote write, which keeps
+    /// a compressed request under axum's 2 MB body limit in ASAPQuery's ingest,
+    /// and 100,000 for ClickHouse, where each INSERT creates a part.
+    #[arg(long)]
+    batch_rows: Option<usize>,
+    /// Concurrent requests within one tick.
+    #[arg(long, default_value_t = 16)]
+    concurrency: usize,
+    /// Where to write per-tick timing and totals as JSON.
+    #[arg(long)]
+    stats_out: Option<String>,
+}
+
+#[derive(Debug, Serialize)]
+struct TickStats {
+    tick: u64,
+    rows: usize,
+    bytes: usize,
+    /// How late the tick started relative to its schedule.
+    start_lag_ms: f64,
+    /// Generation, encoding and sending, until the last request returned.
+    elapsed_ms: f64,
+}
+
+#[derive(Debug, Serialize)]
+struct RunStats {
+    sink: SinkKind,
+    groups: usize,
+    series_per_group: usize,
+    samples_per_sec: u32,
+    pareto_shape: f64,
+    pareto_scale: f64,
+    seed: u64,
+    start_ms: i64,
+    duration_secs: u64,
+    target_rows_per_sec: usize,
+    rows_sent: usize,
+    bytes_sent: usize,
+    /// Rows sent divided by wall-clock time from the first tick's schedule to
+    /// the later of the last tick's end and the run's nominal end.
+    achieved_rows_per_sec: f64,
+    /// Ticks whose work took longer than one second.
+    overrun_ticks: usize,
+    max_start_lag_ms: f64,
+    failed_requests: usize,
+    first_errors: Vec<String>,
+    ticks: Vec<TickStats>,
+}
+
+struct Sink {
+    client: reqwest::Client,
+    request: reqwest::RequestBuilder,
+    encoder: Box<dyn Encoder>,
+}
+
+impl Sink {
+    fn new(args: &Args, workload: &Workload) -> Result<Self> {
+        let client = reqwest::Client::builder()
+            .pool_max_idle_per_host(args.concurrency)
+            .build()?;
+        let (request, encoder): (_, Box<dyn Encoder>) = match args.sink {
+            SinkKind::RemoteWrite => (
+                client
+                    .post(&args.url)
+                    .header("Content-Encoding", "snappy")
+                    .header("Content-Type", "application/x-protobuf")
+                    .header("X-Prometheus-Remote-Write-Version", "0.1.0"),
+                Box::new(RemoteWriteEncoder::new(workload, &args.metric)),
+            ),
+            SinkKind::Clickhouse => {
+                let query = format!(
+                    "INSERT INTO {} ({ROW_BINARY_COLUMNS}) FORMAT RowBinary",
+                    args.table
+                );
+                let mut request = client.post(&args.url).query(&[("query", query)]);
+                if let Some(user) = &args.clickhouse_user {
+                    request = request.header("X-ClickHouse-User", user);
+                }
+                if let Some(password) = &args.clickhouse_password {
+                    request = request.header("X-ClickHouse-Key", password);
+                }
+                (request, Box::new(RowBinaryEncoder::new(workload)))
+            }
+        };
+        Ok(Self {
+            client,
+            request,
+            encoder,
+        })
+    }
+
+    async fn send(&self, body: Vec<u8>) -> Result<()> {
+        let request = self
+            .request
+            .try_clone()
+            .context("request builder must be clonable")?
+            .body(body)
+            .build()?;
+        let response = self.client.execute(request).await?;
+        let status = response.status();
+        if !status.is_success() {
+            let text = response.text().await.unwrap_or_default();
+            bail!("HTTP {status}: {}", text.trim());
+        }
+        Ok(())
+    }
+}
+
+fn next_whole_second_ms() -> i64 {
+    let now_ms = SystemTime::now()
+        .duration_since(UNIX_EPOCH)
+        .expect("system clock is after the epoch")
+        .as_millis() as i64;
+    (now_ms / 1_000 + 1) * 1_000
+}
+
+/// Sleep until wall-clock `epoch_ms`, then return the monotonic instant it maps to.
+async fn wait_for_wall_clock(epoch_ms: i64) -> Instant {
+    let now_ms = SystemTime::now()
+        .duration_since(UNIX_EPOCH)
+        .expect("system clock is after the epoch")
+        .as_millis() as i64;
+    if epoch_ms > now_ms {
+        tokio::time::sleep(Duration::from_millis((epoch_ms - now_ms) as u64)).await;
+    }
+    Instant::now()
+}
+
+#[tokio::main]
+async fn main() -> Result<()> {
+    let args = Args::parse();
+    if args.groups == 0 || args.series_per_group == 0 || args.samples_per_sec == 0 {
+        bail!("--groups, --series-per-group and --samples-per-sec must be positive");
+    }
+    if args.pareto_shape <= 0.0 || args.pareto_scale <= 0.0 {
+        bail!("--pareto-shape and --pareto-scale must be positive");
+    }
+    let batch_rows = args.batch_rows.unwrap_or(match args.sink {
+        SinkKind::RemoteWrite => 50_000,
+        SinkKind::Clickhouse => 100_000,
+    });
+    if batch_rows == 0 || args.concurrency == 0 {
+        bail!("--batch-rows and --concurrency must be positive");
+    }
+
+    let workload = Workload {
+        seed: args.seed,
+        groups: args.groups,
+        series_per_group: args.series_per_group,
+        samples_per_sec: args.samples_per_sec,
+        pareto_shape: args.pareto_shape,
+        pareto_scale: args.pareto_scale,
+    };
+    let sink = Arc::new(Sink::new(&args, &workload)?);
+    let permits = Arc::new(Semaphore::new(args.concurrency));
+    let start_ms = args.start_ms.unwrap_or_else(next_whole_second_ms);
+
+    eprintln!(
+        "paced_feeder: {:?} -> {}, {} series x {}/s = {} rows/s for {}s, start_ms={start_ms}",
+        args.sink,
+        args.url,
+        workload.num_series(),
+        args.samples_per_sec,
+        workload.rows_per_tick(),
+        args.duration_secs
+    );
+
+    let base = wait_for_wall_clock(start_ms).await;
+    let mut ticks = Vec::with_capacity(args.duration_secs as usize);
+    let mut errors: Vec<String> = Vec::new();
+    let mut failed_requests = 0;
+
+    for tick in 0..args.duration_secs {
+        let scheduled = base + Duration::from_secs(tick);
+        tokio::time::sleep_until(scheduled.into()).await;
+        let started = Instant::now();
+
+        let rows = Arc::new(workload.tick_rows(tick, start_ms));
+        let mut tasks = tokio::task::JoinSet::new();
+        for begin in (0..rows.len()).step_by(batch_rows) {
+            let end = (begin + batch_rows).min(rows.len());
+            let (rows, sink) = (Arc::clone(&rows), Arc::clone(&sink));
+            let permit = Arc::clone(&permits).acquire_owned().await?;
+            tasks.spawn(async move {
+                let _permit = permit;
+                let body = sink.encoder.encode(&rows[begin..end]);
+                let bytes = body.len();
+                sink.send(body).await.map(|()| bytes)
+            });
+        }
+
+        let mut bytes = 0;
+        while let Some(joined) = tasks.join_next().await {
+            match joined? {
+                Ok(n) => bytes += n,
+                Err(e) => {
+                    failed_requests += 1;
+                    if errors.len() < 10 {
+                        errors.push(format!("tick {tick}: {e:#}"));
+                    }
+                }
+            }
+        }
+
+        let stats = TickStats {
+            tick,
+            rows: rows.len(),
+            bytes,
+            start_lag_ms: started.duration_since(scheduled).as_secs_f64() * 1e3,
+            elapsed_ms: started.elapsed().as_secs_f64() * 1e3,
+        };
+        if tick % 10 == 0 || stats.elapsed_ms > 1_000.0 {
+            eprintln!(
+                "tick {tick}: {} rows in {:.0} ms (start lag {:.0} ms)",
+                stats.rows, stats.elapsed_ms, stats.start_lag_ms
+            );
+        }
+        ticks.push(stats);
+    }
+
+    // A run that keeps up still spans the full duration, even though the last
+    // tick's work ends before its second does.
+    let wall_secs = base.elapsed().as_secs_f64().max(args.duration_secs as f64);
+    let rows_sent: usize = ticks.iter().map(|t| t.rows).sum();
+    let run = RunStats {
+        sink: args.sink,
+        groups: args.groups,
+        series_per_group: args.series_per_group,
+        samples_per_sec: args.samples_per_sec,
+        pareto_shape: args.pareto_shape,
+        pareto_scale: args.pareto_scale,
+        seed: args.seed,
+        start_ms,
+        duration_secs: args.duration_secs,
+        target_rows_per_sec: workload.rows_per_tick(),
+        rows_sent,
+        bytes_sent: ticks.iter().map(|t| t.bytes).sum(),
+        achieved_rows_per_sec: rows_sent as f64 / wall_secs.max(f64::EPSILON),
+        overrun_ticks: ticks.iter().filter(|t| t.elapsed_ms > 1_000.0).count(),
+        max_start_lag_ms: ticks.iter().map(|t| t.start_lag_ms).fold(0.0, f64::max),
+        failed_requests,
+        first_errors: errors,
+        ticks,
+    };
+
+    eprintln!(
+        "done: {} rows, {:.0} rows/s achieved (target {}), {} overrun ticks, max start lag {:.0} ms, {} failed requests",
+        run.rows_sent,
+        run.achieved_rows_per_sec,
+        run.target_rows_per_sec,
+        run.overrun_ticks,
+        run.max_start_lag_ms,
+        run.failed_requests
+    );
+    if let Some(path) = &args.stats_out {
+        std::fs::write(path, serde_json::to_vec_pretty(&run)?)
+            .with_context(|| format!("writing {path}"))?;
+    }
+    if run.failed_requests > 0 {
+        bail!(
+            "{} requests failed; first: {:?}",
+            run.failed_requests,
+            run.first_errors
+        );
+    }
+    Ok(())
+}
diff --git a/asap-tools/data-sources/paced-feeder/src/workload.rs b/asap-tools/data-sources/paced-feeder/src/workload.rs
new file mode 100644
index 00000000..c1f9ec22
--- /dev/null
+++ b/asap-tools/data-sources/paced-feeder/src/workload.rs
@@ -0,0 +1,160 @@
+//! Seeded synthetic workload: `groups × series_per_group` series, each emitting
+//! `samples_per_sec` Pareto-distributed values per second.
+//!
+//! A sample's value depends only on `(seed, series, sample index)`, never on
+//! wall-clock time or on which sink sends it, so two feeders started with the
+//! same parameters produce identical data.
+
+/// One generated sample. `series` indexes into [`Workload::series_labels`].
+#[derive(Debug, Clone, Copy, PartialEq)]
+pub struct Row {
+    pub series: usize,
+    pub timestamp_ms: i64,
+    pub value: f64,
+}
+
+#[derive(Debug, Clone)]
+pub struct Workload {
+    pub seed: u64,
+    pub groups: usize,
+    pub series_per_group: usize,
+    pub samples_per_sec: u32,
+    pub pareto_shape: f64,
+    pub pareto_scale: f64,
+}
+
+impl Workload {
+    pub fn num_series(&self) -> usize {
+        self.groups * self.series_per_group
+    }
+
+    pub fn rows_per_tick(&self) -> usize {
+        self.num_series() * self.samples_per_sec as usize
+    }
+
+    /// `(label_0, instance)` for a series: series `g * series_per_group + i`
+    /// is `("g{g}", "i{i}")`.
+    pub fn series_labels(&self, series: usize) -> (String, String) {
+        let group = series / self.series_per_group;
+        let instance = series % self.series_per_group;
+        (format!("g{group}"), format!("i{instance}"))
+    }
+
+    /// All samples for one-second tick `tick`, with event time starting at
+    /// `start_ms`. Samples within the second are spaced evenly.
+    pub fn tick_rows(&self, tick: u64, start_ms: i64) -> Vec<Row> {
+        let per_sec = u64::from(self.samples_per_sec);
+        let tick_start_ms = start_ms + tick as i64 * 1_000;
+        let mut rows = Vec::with_capacity(self.rows_per_tick());
+        for k in 0..per_sec {
+            let timestamp_ms = tick_start_ms + (k * 1_000 / per_sec) as i64;
+            let sample_index = tick * per_sec + k;
+            for series in 0..self.num_series() {
+                rows.push(Row {
+                    series,
+                    timestamp_ms,
+                    value: self.value(series, sample_index),
+                });
+            }
+        }
+        rows
+    }
+
+    /// Pareto(shape, scale) by inverse transform: `scale · U^(-1/shape)` with
+    /// `U` uniform in (0, 1], so every value is ≥ `scale` and positive.
+    pub fn value(&self, series: usize, sample_index: u64) -> f64 {
+        let u = unit_uniform(self.seed, series as u64, sample_index);
+        self.pareto_scale * u.powf(-1.0 / self.pareto_shape)
+    }
+}
+
+/// Counter-based uniform draw in (0, 1]: a stateless hash of the inputs, so
+/// any sample can be regenerated independently of the ones before it.
+fn unit_uniform(seed: u64, series: u64, sample_index: u64) -> f64 {
+    let x = splitmix64(seed ^ splitmix64(series ^ splitmix64(sample_index)));
+    // Top 53 bits, shifted into (0, 1] so the Pareto transform never divides by zero.
+    ((x >> 11) + 1) as f64 / (1u64 << 53) as f64
+}
+
+fn splitmix64(mut z: u64) -> u64 {
+    z = z.wrapping_add(0x9E37_79B9_7F4A_7C15);
+    z = (z ^ (z >> 30)).wrapping_mul(0xBF58_476D_1CE4_E5B9);
+    z = (z ^ (z >> 27)).wrapping_mul(0x94D0_49BB_1331_11EB);
+    z ^ (z >> 31)
+}
+
+#[cfg(test)]
+mod tests {
+    use super::*;
+
+    fn workload() -> Workload {
+        Workload {
+            seed: 7,
+            groups: 3,
+            series_per_group: 2,
+            samples_per_sec: 2,
+            pareto_shape: 1.5,
+            pareto_scale: 1.0,
+        }
+    }
+
+    #[test]
+    fn tick_has_every_series_at_every_sub_second_slot() {
+        let w = workload();
+        let rows = w.tick_rows(5, 10_000);
+        assert_eq!(rows.len(), 3 * 2 * 2);
+        let first: Vec<_> = rows.iter().filter(|r| r.timestamp_ms == 15_000).collect();
+        let second: Vec<_> = rows.iter().filter(|r| r.timestamp_ms == 15_500).collect();
+        assert_eq!(first.len(), 6);
+        assert_eq!(second.len(), 6);
+    }
+
+    #[test]
+    fn values_depend_only_on_seed_series_and_sample_index() {
+        let w = workload();
+        // Same tick, different start time: same values.
+        let a: Vec<f64> = w.tick_rows(4, 0).iter().map(|r| r.value).collect();
+        let b: Vec<f64> = w.tick_rows(4, 1_000_000).iter().map(|r| r.value).collect();
+        assert_eq!(a, b);
+        // A different seed changes them.
+        let other = Workload { seed: 8, ..w };
+        assert_ne!(
+            a,
+            other
+                .tick_rows(4, 0)
+                .iter()
+                .map(|r| r.value)
+                .collect::<Vec<_>>()
+        );
+    }
+
+    #[test]
+    fn labels_split_series_into_groups_and_instances() {
+        let w = workload();
+        assert_eq!(w.series_labels(0), ("g0".to_string(), "i0".to_string()));
+        assert_eq!(w.series_labels(3), ("g1".to_string(), "i1".to_string()));
+        assert_eq!(w.series_labels(5), ("g2".to_string(), "i1".to_string()));
+    }
+
+    #[test]
+    fn values_follow_pareto_distribution() {
+        let w = Workload {
+            groups: 1,
+            series_per_group: 1,
+            ..workload()
+        };
+        let n = 200_000u64;
+        let mut values: Vec<f64> = (0..n).map(|i| w.value(0, i)).collect();
+        assert!(values.iter().all(|&v| v >= 1.0));
+        values.sort_by(f64::total_cmp);
+        // Pareto(a, xm) quantile: xm · (1 - q)^(-1/a).
+        for q in [0.5, 0.9, 0.99] {
+            let empirical = values[(q * n as f64) as usize];
+            let theoretical = (1.0 - q).powf(-1.0 / 1.5);
+            assert!(
+                (empirical - theoretical).abs() / theoretical < 0.05,
+                "q={q}: empirical {empirical} vs theoretical {theoretical}"
+            );
+        }
+    }
+}