src/ingest/mod.rs at main · ptr.pet/hydrant

ptr.pet / hydrant

fork atom

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

at-protocol atproto indexer rust fjall

fork atom

hydrant / src / ingest / mod.rs

at main 18 lines 410 B view raw

wrap content

ptr.pet [all] drop jacquard, jacquard-axum, and some minor deps, use our own firehose stream impl 11d ago

69319002

 1use tokio::sync::mpsc;
 2
 3pub mod firehose;
 4pub mod stream;
 5pub mod worker;
 6
 7use jacquard_common::types::did::Did;
 8
 9use crate::ingest::stream::SubscribeReposMessage;
10
11#[derive(Debug)]
12pub enum IngestMessage {
13    Firehose(SubscribeReposMessage<'static>),
14    BackfillFinished(Did<'static>),
15}
16
17pub type BufferTx = mpsc::UnboundedSender<IngestMessage>;
18pub type BufferRx = mpsc::UnboundedReceiver<IngestMessage>;