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

nekomimi.pet / hydrant

forked from ptr.pet/hydrant

fork atom

kind of like tap but different and in rust

fork atom

hydrant / src / ingest / mod.rs

at main 17 lines 433 B view raw

wrap content

ptr.pet [ingest] refactor internal message types and config cleanup 4w ago

2864d674

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