orion-server 1.0.0

Turn business logic into live REST/Kafka services. Declare workflows as JSON and Orion runs them, with rate limiting, circuit breakers, versioning, and observability built in
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37

pub mod cache_backend;
pub mod circuit_breaker;
mod config;
pub(crate) mod lru_cache;
mod masking;
pub mod mongo_pool;
pub mod pool_cache;
pub mod redis_pool;
mod registry;
pub mod secrets;

pub(crate) use pool_access_counter::POOL_ACCESS_COUNTER;

pub use config::{
    AuthConfig, CacheConnectorConfig, CacheOperationGates, ConnectorConfig, ConnectorType,
    DbConnectorConfig, DialectGuards, EsConnectorConfig, HttpConnectorConfig, HttpOperationGates,
    KafkaConnectorConfig, KafkaOperationGates, OperationGates, RetryConfig, VALID_CACHE_BACKENDS,
    VALID_CONNECTOR_TYPES, VALID_HTTP_METHODS, is_mongo_url,
};
pub(crate) use masking::MASK;
pub use masking::{
    find_masked_value, mask_channel_config, mask_connector, mask_secrets, redact_url_secrets,
    redact_url_secrets_or_raw, unmask_channel_config, unmask_config,
};
pub use registry::ConnectorRegistry;
/// A stub `ConnectorRepository` shared by the connector and channel registry
/// tests — the channel registry's reuse cache is keyed on the connector
/// token, so testing it takes a connector *load*.
#[cfg(test)]
pub(crate) use registry::test_support;

mod pool_access_counter {
    use std::sync::atomic::AtomicU64;

    /// Shared monotonic counter for LRU tracking across connector pool caches.
    pub(crate) static POOL_ACCESS_COUNTER: AtomicU64 = AtomicU64::new(0);
}