src/ingest · hydrant · Tangled

very fast at protocol indexer with flexible filtering, xrpc queries, cursor-backed event stream, and more, built on fjall

rust fjall at-protocol atproto indexer

hydrant src ingest

4 folders · 9 files

· [stream] accept a #commit without rebase · 2d ago

[firehose] count-only stats for doc refreshes and key fetches

[crawler] count rewalks by listRepos bytes, not walks

[ingest] ignore a #sync that doesn't move the rev forward

[stream] accept a #commit without rebase

[stream] seal /stream into chunks a subscriber can start from

firehose_stats.rs

[db] migrate async boundaries to Db::run

[stream] drop a firehose that stops answering pings

[ingest] limit how often a peer can make us refetch a repo

[indexer] track, untrack and resync on the repo's owner shard

[ingest] cursor tracker: tickets from the reader, relay-side done, relay-only watermark

[xrpc] remove jacquard-api and jacquard-derive dependencies

[stream] accept a #commit without rebase

[ingest] ignore a #sync that doesn't move the rev forward