rust-zero-core 0.1.0-alpha.1

Runtime primitives for rust-zero services
Documentation 
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
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126

//! Framework-neutral runtime primitives shared by rust-zero services.
//!
//! The crate provides configuration loading, circuit breaking, adaptive load shedding,
//! consistent hashing, and async retry helpers.  They intentionally do not depend on a
//! particular HTTP or gRPC framework so REST, RPC, and background services can share them.

pub mod auth;
pub mod balancer;
pub mod bloom;
pub mod breaker;
pub mod cache;
pub mod config;
pub mod config_center;
pub mod discov;
#[cfg(feature = "etcd")]
pub mod etcd;
pub mod executor;
pub mod fx;
pub mod hash;
pub mod health;
#[cfg(feature = "kubernetes")]
pub mod kubernetes;
pub mod limit;
pub mod load;
pub mod log;
pub mod metric;
pub mod profile;
pub mod pubsub;
pub mod queue;
pub mod rolling;
pub mod service;
pub mod singleflight;
#[cfg(feature = "stores-mongo")]
pub mod stores_mongo;
#[cfg(feature = "stores-redis")]
pub mod stores_redis;
#[cfg(feature = "stores-sql")]
pub mod stores_sql;
#[cfg(feature = "telemetry")]
pub mod telemetry;
pub mod trace;
pub mod validation;

pub use auth::{
    decode_jwt_hs256, encode_jwt_hs256, sign_request, AuthFailure, JwtClaimProjection,
    JwtValidationError, RequestSignature, RequestSignatureVerifier, AUTH_KEY_ID_HEADER,
    AUTH_SIGNATURE_HEADER, AUTH_TIMESTAMP_HEADER,
};
pub use balancer::{BalancerError, NodeSnapshot, P2cBalancer, P2cRequest};
pub use bloom::{BloomError, BloomFilter};
pub use breaker::{
    BreakerState, CircuitBreaker, CircuitBreakerConfig, CircuitBreakerError, CircuitBreakerPermit,
    CircuitBreakerPolicy, CircuitBreakerSnapshot, CircuitOutcome, RollingCircuitBreakerConfig,
};
pub use cache::{CacheStats, MemoryCache, ReadThroughCache, TtlCache};
pub use config::{load_config, parse_config, ConfigError, ConfigFormat, ServiceConfig};
pub use config_center::{ConfigCenterError, ConfigSnapshot, DynamicConfig};
pub use discov::{
    DiscoveredEndpoint, DiscoveryError, DiscoveryReconnectBackoff, EndpointChangeFuture,
    EndpointSubscription, ServiceEvent, ServiceLease, ServiceRegistry, ServiceSubscription,
};
#[cfg(feature = "etcd")]
pub use etcd::{
    EtcdClient, EtcdConfig, EtcdConfigWatcher, EtcdError, EtcdServiceLease, EtcdServiceSubscription,
};
pub use executor::{
    BatchExecutor, BatchExecutorError, ChunkExecutor, DelayExecutor, DelayExecutorError,
    LessExecutor, PeriodicExecutor, PeriodicExecutorError,
};
pub use fx::{retry, timeout, RetryPolicy};
pub use hash::ConsistentHash;
pub use health::{HealthRegistry, HealthSnapshot};
#[cfg(feature = "kubernetes")]
pub use kubernetes::{
    KubernetesDiscovery, KubernetesDiscoveryConfig, KubernetesDiscoveryError,
    KubernetesServiceSubscription,
};
pub use limit::{LimitDecision, PeriodLimiter, TokenLimiter};
#[cfg(feature = "stores-redis")]
pub use limit::{RedisLimiterSnapshot, RedisPeriodLimiter, RedisTokenLimiter};
pub use load::{
    AdaptiveShedder, LoadShedderConfig, LoadShedderMode, LoadShedderSnapshot, ShedPermit,
};
pub use log::{
    LogConfig, LogContext, LogEncoding, LogError, LogField, LogLevel, LogSampler, LogTarget,
    Logger, RotationPolicy, Sensitive,
};
pub use metric::{
    CounterVec, GaugeVec, HistogramOptions, HistogramVec, Metrics, MetricsError, VectorOptions,
};
pub use profile::{ProfilePoint, ProfileSnapshot, Profiler};
pub use pubsub::{Broker, Subscription};
pub use queue::{
    BalancedPusher, FanoutPusher, PushError, PusherConfigError, QueueConfigError, QueueEvent,
    QueueMetrics, QueueProducer, QueueReceiver, QueueRuntime, QueueRuntimeConfig,
    QueueRuntimeError, QueueSender, RunningQueue,
};
pub use rolling::{RollingSnapshot, RollingWindow};
pub use service::{
    wait_for_shutdown_signal, RunningServices, ServiceGroup, ServiceGroupError, Shutdown,
    ShutdownHandle, ShutdownSignal,
};
pub use singleflight::{SingleFlight, SingleFlightError};
#[cfg(feature = "stores-mongo")]
pub use stores_mongo::{
    CachedMongoCollection, MongoCacheConfig, MongoStore, MongoStoreConfig, MongoStoreError,
    MongoStoreMetrics,
};
#[cfg(feature = "stores-redis")]
pub use stores_redis::{
    RedisCacheError, RedisJsonCache, RedisLock, RedisModelCache, RedisModelCacheConfig,
    RedisModelCacheError, RedisStore, RedisStoreConfig, RedisStoreError, RedisStoreMetrics,
    RedisSubscription, RedisSubscriptionConfig, RedisSubscriptionEvent, RedisSubscriptionMessage,
    RedisTtl,
};
#[cfg(feature = "stores-sql")]
pub use stores_sql::{
    CachedSqlStore, MySqlStore, PostgresStore, SqlCacheConfig, SqlStore, SqlStoreConfig,
    SqlStoreError, SqlStoreMetrics, SqliteStore,
};
#[cfg(feature = "telemetry")]
pub use telemetry::{
    OtlpTransport, Telemetry, TelemetryConfig, TelemetryError, TelemetrySpan, TelemetrySpanKind,
};
pub use trace::{TraceContext, TraceContextError, TraceFlags};
pub use validation::{Validate, Validation, ValidationErrors, Violation};