camel_api/
lib.rs

1//! # rust-camel API
2//!
3//! Core Camel abstractions: exchanges, messages, body, errors, processors.
4//!
5//! Note: Component, Endpoint, Consumer, Producer traits are defined in
6//! `camel-component-api`. This crate focuses on data types and EIP abstractions.
7
8pub mod aggregator;
9pub mod backoff;
10pub mod body;
11pub mod body_converter;
12pub mod circuit_breaker;
13pub mod claim_check;
14pub mod component_metadata;
15pub mod data_format;
16pub mod datasource;
17pub mod declarative;
18pub mod delayer;
19pub mod dynamic_router;
20pub mod endpoint_pipeline;
21pub mod error;
22pub mod error_handler;
23pub mod exchange;
24pub mod exchange_lookup;
25pub mod filter;
26pub mod from_body;
27pub mod function;
28pub mod health;
29pub mod idempotent;
30pub mod lifecycle;
31pub mod load_balancer;
32pub mod loop_eip;
33pub mod message;
34pub mod metrics;
35pub mod multicast;
36pub mod outcome_pipeline;
37pub mod outcome_segment;
38pub mod pipeline_outcome;
39pub mod platform;
40pub mod processor;
41pub mod producer;
42pub mod recipient_list;
43pub mod resequencer;
44pub mod route_controller;
45pub mod routing_slip;
46pub mod runtime;
47pub mod security_policy;
48pub mod splitter;
49pub mod ssrf;
50pub mod step_lifecycle;
51pub mod stream_cache;
52pub mod supervision;
53pub mod template;
54pub mod throttler;
55pub mod unit_of_work;
56pub mod value;
57pub mod xml_convert;
58
59// Re-export core types at crate root for convenience.
60pub use aggregator::{AggregationFn, AggregatorConfig, CompletionCondition};
61pub use backoff::{BackoffConfig, BackoffState};
62pub use body::{Body, BoxAsyncRead, StreamBody, StreamMetadata};
63pub use body_converter::{BodyType, convert as convert_body};
64pub use circuit_breaker::CircuitBreakerConfig;
65pub use data_format::DataFormat;
66pub use datasource::{
67    DatasourceCatalog, DatasourceConfig, DatasourceHandle, PoolFactory, ResourceRef,
68};
69pub use declarative::{LanguageExpressionDef, ValueSourceDef};
70pub use delayer::{DEFAULT_MAX_DELAY_MS, DelayConfig};
71pub use dynamic_router::{DynamicRouterConfig, RouterExpression};
72pub use endpoint_pipeline::{CAMEL_SLIP_ENDPOINT, EndpointPipelineConfig, EndpointResolver};
73pub use error::{CamelError, ConfigValidationError};
74pub use error_handler::{
75    BoundaryKind, ErrorHandlerConfig, ExceptionDisposition, ExceptionPolicy,
76    ExceptionPolicyBuilder, HEADER_REDELIVERED, HEADER_REDELIVERY_COUNTER,
77    HEADER_REDELIVERY_MAX_COUNTER, PolicyId, RedeliveryPolicy, RetryOutcome, RetryableStep,
78    StepDisposition,
79};
80pub use security_policy::{
81    AuthorizationDecision, PRINCIPAL_AUDIENCE_KEY, PRINCIPAL_CLAIMS_KEY, PRINCIPAL_ISSUER_KEY,
82    PRINCIPAL_KEY, PRINCIPAL_ROLES_KEY, PRINCIPAL_SCOPES_KEY, PRINCIPAL_SUBJECT_KEY, Principal,
83    SecurityPolicy, SecurityPolicyConfig, store_principal_properties,
84};
85// Backwards compatibility re-export (deprecated)
86pub use claim_check::ClaimCheckRepository;
87#[allow(deprecated)]
88pub use error_handler::ExponentialBackoff;
89pub use exchange::{
90    CAMEL_STOP, Exchange, ExchangePattern, ORIGINAL_MESSAGE_EXTENSION, is_camel_stop,
91};
92pub use exchange_lookup::{ExchangeLookupPath, LookupPathError, PathSegment};
93pub use filter::FilterPredicate;
94pub use from_body::FromBody;
95pub use function::{
96    ExchangePatch, FunctionDefinition, FunctionDiff, FunctionId, FunctionInvocationError,
97    FunctionInvoker, FunctionInvokerSync, PatchBody,
98};
99pub use health::{AsyncHealthCheck, CheckResult, HealthReport, HealthSource, ServiceHealth};
100pub use idempotent::IdempotentRepository;
101pub use lifecycle::{HealthStatus, Lifecycle, ServiceStatus};
102pub use load_balancer::{LoadBalanceStrategy, LoadBalancerConfig};
103pub use message::Message;
104pub use metrics::{MetricsCollector, NoOpMetrics};
105pub use multicast::{MulticastAggregationFn, MulticastConfig, MulticastStrategy};
106pub use outcome_pipeline::OutcomePipeline;
107pub use outcome_segment::OutcomeSegment;
108pub use pipeline_outcome::PipelineOutcome;
109pub use platform::{
110    LeadershipEvent, LeadershipHandle, LeadershipService, NoopLeadershipService,
111    NoopPlatformService, NoopReadinessGate, PlatformError, PlatformIdentity, PlatformService,
112    ReadinessGate,
113};
114pub use processor::{
115    BoxProcessor, BoxProcessorExt, IdentityProcessor, OpaqueProcessor, Processor, ProcessorFn,
116    SyncBoxProcessor,
117};
118pub use producer::ProducerContext;
119pub use resequencer::{
120    BatchCompletion, CapacityPolicy, GapPolicy, ResequenceMode, ResequencePolicyConfig,
121};
122pub use route_controller::{RouteAction, RouteController, RouteStatus};
123pub use routing_slip::{RoutingSlipConfig, RoutingSlipExpression};
124pub use runtime::{
125    CANONICAL_CONTRACT_DECLARATIVE_ONLY_STEPS, CANONICAL_CONTRACT_EXCLUDED_DECLARATIVE_STEPS,
126    CANONICAL_CONTRACT_NAME, CANONICAL_CONTRACT_RUST_ONLY_STEPS,
127    CANONICAL_CONTRACT_SUPPORTED_STEPS, CANONICAL_CONTRACT_VERSION, CanonicalConcurrencySpec,
128    CanonicalFieldLoss, CanonicalLossReport, CanonicalRouteSpec, RuntimeCommand, RuntimeCommandBus,
129    RuntimeCommandResult, RuntimeEvent, RuntimeHandle, RuntimeQuery, RuntimeQueryBus,
130    RuntimeQueryResult, canonical_contract_rejection_reason, canonical_contract_supports_step,
131};
132pub use splitter::{
133    AggregationStrategy, SplitExpression, SplitterConfig, StreamSplitConfig, StreamSplitFormat,
134    StreamingSplitExpression, fragment_exchange, split_body, split_body_json_array,
135    split_body_lines,
136};
137pub use ssrf::{SsrfPolicy, is_ssrf_blocked_ip};
138pub use step_lifecycle::{StepLifecycle, StepShutdownReason};
139pub use supervision::SupervisionConfig;
140pub use throttler::{ThrottleStrategy, ThrottlerConfig};
141pub use unit_of_work::UnitOfWorkConfig;
142pub use value::{Headers, Value, cmp_values};
143
144// Template types
145pub use template::{
146    RouteTemplateSpec, TemplateError, TemplateInstanceRecord, TemplateParameterSpec,
147    TemplatedRouteSpec,
148};
camel_api/lib.rs

camel_api/
lib.rs
