at protocol indexer with flexible filtering, xrpc queries, and a cursor-backed event stream, built on fjall
at-protocol atproto indexer rust fjall

[docs] db warning

ptr.pet 64b2c0ea 85528411

verified
+3
+2
README.md
··· 4 5 you can see [random.wisp.place](https://tangled.org/did:plc:dfl62fgb7wtjj3fcbb72naae/random.wisp.place) for an example on how to use hydrant. 6 7 ## vs `tap` 8 9 while [`tap`](https://github.com/bluesky-social/indigo/tree/main/cmd/tap) is designed as a firehose consumer and simply just propagates events while handling sync, `hydrant` is flexible, it allows you to directly query the database for records, and it also provides an ordered view of events, allowing the use of a cursor to fetch events from a specific point in time.
··· 4 5 you can see [random.wisp.place](https://tangled.org/did:plc:dfl62fgb7wtjj3fcbb72naae/random.wisp.place) for an example on how to use hydrant. 6 7 + **WARNING: *the db format is not stable yet.*** it's in active development so if you are going to rely on the db format being stable, don't (eg. for query features, if you are using ephemeral mode this doesn't matter for example, or you dont mind losing your existing backfilled data in hydrant if you already processed them.). 8 + 9 ## vs `tap` 10 11 while [`tap`](https://github.com/bluesky-social/indigo/tree/main/cmd/tap) is designed as a firehose consumer and simply just propagates events while handling sync, `hydrant` is flexible, it allows you to directly query the database for records, and it also provides an ordered view of events, allowing the use of a cursor to fetch events from a specific point in time.
+1
src/types.rs
··· 39 pub status: RepoStatus, 40 pub rev: Option<DbTid>, 41 pub data: Option<IpldCid>, 42 pub last_updated_at: i64, // unix timestamp 43 #[serde(borrow)] 44 pub handle: Option<Handle<'i>>,
··· 39 pub status: RepoStatus, 40 pub rev: Option<DbTid>, 41 pub data: Option<IpldCid>, 42 + /// this is when we *ingested* any last updates 43 pub last_updated_at: i64, // unix timestamp 44 #[serde(borrow)] 45 pub handle: Option<Handle<'i>>,