nexus-watcher 0.4.0

Nexus Watcher constructs a social graph out of all of the events on pubky-core homeservers
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20

//! # Nexus Watcher
//!
//! The `nexus-watcher` crate is responsible for monitoring a Pubky homeserver’s `/events` endpoint and processing
//! events into the Nexus databases. It integrates with `nexus-common` to manage database connections (Neo4j and Redis),
//! configuration, logging, metrics, and stack initialization.
//!
//! Key responsibilities include:
//!
//! - Listening to a homeserver’s events stream.
//! - Processing various event types (posts, bookmarks, follows, mutes, tags, user updates, etc.).
//! - Applying retry logic for events that fail to index.
//! - Updating both the graph database and Redis indexes based on incoming events.
//!
//! The crate provides a builder interface via `NexusWatcher::builder()` and supports configuration from files.
//! The main entry point is in `main.rs`, which simply calls the builder’s `run()` method to start the event loop.

mod builder;
pub mod events;

pub use builder::{NexusWatcher, NexusWatcherBuilder};