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
[lib] re-export public api deps in deps
+13
-4
+4
-4
examples/statusphere.rs
+4
-4
examples/statusphere.rs
···
19
19
use std::time::Duration;
20
20
21
21
use chrono::DateTime;
22
-
use futures::StreamExt;
23
22
use hydrant::FilterMode;
24
23
use hydrant::config::Config;
25
24
use hydrant::control::{EventStream, Hydrant, ReposControl};
26
-
use jacquard_common::types::did::Did;
27
-
use jacquard_common::types::tid::Tid;
25
+
use hydrant::deps::futures::StreamExt;
26
+
use hydrant::deps::jacquard::types::did::Did;
27
+
use hydrant::deps::jacquard::types::tid::Tid;
28
28
use scc::HashMap;
29
29
30
30
const COLLECTION: &str = "xyz.statusphere.status";
···
159
159
160
160
#[tokio::main]
161
161
async fn main() -> miette::Result<()> {
162
-
rustls::crypto::aws_lc_rs::default_provider()
162
+
hydrant::deps::rustls::crypto::aws_lc_rs::default_provider()
163
163
.install_default()
164
164
.ok();
165
165
+9
src/lib.rs
+9
src/lib.rs
···
1
+
/// hydrant configuration
1
2
pub mod config;
2
3
/// hydrant main api, includes the Hydrant type for programmatic control.
3
4
pub mod control;
4
5
pub(crate) mod filter;
5
6
pub(crate) mod pds_meta;
6
7
pub mod types;
8
+
9
+
/// dependencies hydrant uses in it's public api
10
+
pub mod deps {
11
+
pub use futures;
12
+
pub use jacquard_common as jacquard;
13
+
pub use rustls;
14
+
pub use smol_str;
15
+
}
7
16
8
17
#[cfg(all(feature = "relay", feature = "indexer"))]
9
18
compile_error!("can't be relay and indexer at the same time");