Something went wrong. Try again.
Constellation, Spacedust, Slingshot, UFOs: atproto crates and services for microcosm forked from microcosm.blue/microcosm-rs
Something went wrong. Try again.
1.8 kB · 57 lines
Rust
12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849505152535455565758use thiserror::Error;
#[derive(Debug, Error)]pub enum MainTaskError { #[error(transparent)] ConsumerTaskError(#[from] ConsumerError), #[error(transparent)] ServerTaskError(#[from] ServerError), #[error(transparent)] DelayTaskError(#[from] DelayError),}
#[derive(Debug, Error)]pub enum ConsumerError { #[error(transparent)] JetstreamConnectionError(#[from] jetstream::error::ConnectionError), #[error(transparent)] JetstreamConfigValidationError(#[from] jetstream::error::ConfigValidationError), #[error("jetstream ended")] JetstreamEnded, #[error("delay queue output dropped")] DelayQueueOutputDropped,}
#[derive(Debug, Error)]pub enum SubscriberUpdateError { #[error("failed to parse json for subscriber update: {0}")] FailedToParseMessage(serde_json::Error), #[error("more wantedSources were requested than allowed (max 1,000)")] TooManySourcesWanted, #[error("more wantedSubjectDids were requested than allowed (max 10,000)")] TooManyDidsWanted, #[error("more wantedSubjectPrefixes were requested than allowed (max 100)")] TooManySubjectPrefixesWanted, #[error("more wantedSubjects were requested than allowed (max 50,000)")] TooManySubjectsWanted,}
#[derive(Debug, Error)]pub enum DelayError { #[error("delay ended")] DelayEnded,}
#[derive(Debug, Error)]pub enum ServerError { #[error("failed to configure server logger: {0}")] ConfigLogError(std::io::Error), #[error("failed to render json for openapi: {0}")] OpenApiJsonFail(serde_json::Error), #[error(transparent)] FailedToBuildServer(#[from] dropshot::BuildError), #[error("server exited: {0}")] ServerExited(String), #[error("server closed badly: {0}")] BadClose(String),}