jcoffey-dev
6b3ba85dc8
cargo fmt --all over the workspace, with the rustfmt of the CI image (1.98.1); 1.99's output is the same. Formatting only: 167 files, no code changes, plus the AGPL notice on the two upstream files this touched first. Vendored crates are outside the workspace and stay as they are. The tree had drifted, so formatting any one changed file reformatted dozens of untouched ones. CI now runs cargo fmt --all --check before the build on both forges.
60 lines
1.6 KiB
Rust
60 lines
1.6 KiB
Rust
/*
|
|
* SPDX-FileCopyrightText: 2020 Stalwart Labs LLC <[email protected]>
|
|
*
|
|
* SPDX-License-Identifier: AGPL-3.0-only OR LicenseRef-SEL
|
|
*
|
|
* Modified by Coffey Labs in 2026 for INBUXA.
|
|
*/
|
|
|
|
// inbuxa: composite stores (sharded members, read replicas) nest store
|
|
// futures deeply enough to pass rustc's default query depth
|
|
#![recursion_limit = "512"]
|
|
#![warn(clippy::large_futures)]
|
|
|
|
#[allow(unused_imports)]
|
|
use std::sync::Arc;
|
|
|
|
pub mod backend;
|
|
pub mod bootstrap;
|
|
pub mod dispatch;
|
|
|
|
#[derive(Clone, Default)]
|
|
pub enum Coordinator {
|
|
#[cfg(feature = "redis")]
|
|
Redis(Arc<store::backend::redis::RedisStore>),
|
|
#[cfg(feature = "nats")]
|
|
Nats(Arc<backend::nats::NatsPubSub>),
|
|
#[cfg(feature = "zenoh")]
|
|
Zenoh(Arc<backend::zenoh::ZenohPubSub>),
|
|
#[cfg(feature = "kafka")]
|
|
Kafka(Arc<backend::kafka::KafkaPubSub>),
|
|
#[default]
|
|
None,
|
|
}
|
|
|
|
pub enum PubSubStream {
|
|
#[cfg(feature = "redis")]
|
|
Redis(crate::backend::redis::pubsub::RedisPubSubStream),
|
|
#[cfg(feature = "redis")]
|
|
RedisCluster(crate::backend::redis::pubsub::RedisClusterPubSubStream),
|
|
#[cfg(feature = "nats")]
|
|
Nats(crate::backend::nats::pubsub::NatsPubSubStream),
|
|
#[cfg(feature = "zenoh")]
|
|
Zenoh(crate::backend::zenoh::pubsub::ZenohPubSubStream),
|
|
#[cfg(feature = "kafka")]
|
|
Kafka(crate::backend::kafka::pubsub::KafkaPubSubStream),
|
|
Unimplemented,
|
|
}
|
|
|
|
pub enum Msg {
|
|
#[cfg(feature = "redis")]
|
|
Redis(redis::Msg),
|
|
#[cfg(feature = "nats")]
|
|
Nats(async_nats::Message),
|
|
#[cfg(feature = "zenoh")]
|
|
Zenoh(Vec<u8>),
|
|
#[cfg(feature = "kafka")]
|
|
Kafka(Vec<u8>),
|
|
Unimplemented,
|
|
}
|