camel_api/
lib.rs

1pub mod aggregator;
2pub mod body;
3pub mod body_converter;
4pub mod circuit_breaker;
5pub mod data_format;
6pub mod declarative;
7pub mod dynamic_router;
8pub mod endpoint_pipeline;
9pub mod error;
10pub mod error_handler;
11pub mod exchange;
12pub mod filter;
13pub mod from_body;
14pub mod health;
15pub mod lifecycle;
16pub mod load_balancer;
17pub mod message;
18pub mod metrics;
19pub mod multicast;
20pub mod processor;
21pub mod producer;
22pub mod route_controller;
23pub mod routing_slip;
24pub mod runtime;
25pub mod splitter;
26pub mod supervision;
27pub mod throttler;
28pub mod unit_of_work;
29pub mod value;
30
31// Re-export core types at crate root for convenience.
32pub use aggregator::{AggregationFn, AggregatorConfig, CompletionCondition};
33pub use body::{Body, BoxAsyncRead, StreamBody, StreamMetadata};
34pub use body_converter::{BodyType, convert as convert_body};
35pub use circuit_breaker::CircuitBreakerConfig;
36pub use data_format::DataFormat;
37pub use declarative::{LanguageExpressionDef, ValueSourceDef};
38pub use dynamic_router::{DynamicRouterConfig, RouterExpression};
39pub use endpoint_pipeline::{CAMEL_SLIP_ENDPOINT, EndpointPipelineConfig, EndpointResolver};
40pub use error::CamelError;
41pub use error_handler::{
42    ErrorHandlerConfig, ExceptionPolicy, ExceptionPolicyBuilder, HEADER_REDELIVERED,
43    HEADER_REDELIVERY_COUNTER, HEADER_REDELIVERY_MAX_COUNTER, RedeliveryPolicy,
44};
45// Backwards compatibility re-export (deprecated)
46#[allow(deprecated)]
47pub use error_handler::ExponentialBackoff;
48pub use exchange::{Exchange, ExchangePattern};
49pub use filter::FilterPredicate;
50pub use from_body::FromBody;
51pub use health::{HealthReport, ServiceHealth};
52pub use lifecycle::{HealthStatus, Lifecycle, ServiceStatus};
53pub use load_balancer::{LoadBalanceStrategy, LoadBalancerConfig};
54pub use message::Message;
55pub use metrics::{MetricsCollector, NoOpMetrics};
56pub use multicast::{MulticastAggregationFn, MulticastConfig, MulticastStrategy};
57pub use processor::{BoxProcessor, BoxProcessorExt, IdentityProcessor, Processor, ProcessorFn};
58pub use producer::ProducerContext;
59pub use route_controller::{RouteAction, RouteController, RouteStatus};
60pub use routing_slip::{RoutingSlipConfig, RoutingSlipExpression};
61pub use runtime::{
62    CANONICAL_CONTRACT_DECLARATIVE_ONLY_STEPS, CANONICAL_CONTRACT_EXCLUDED_DECLARATIVE_STEPS,
63    CANONICAL_CONTRACT_NAME, CANONICAL_CONTRACT_RUST_ONLY_STEPS,
64    CANONICAL_CONTRACT_SUPPORTED_STEPS, CANONICAL_CONTRACT_VERSION, CanonicalRouteSpec,
65    RuntimeCommand, RuntimeCommandBus, RuntimeCommandResult, RuntimeEvent, RuntimeHandle,
66    RuntimeQuery, RuntimeQueryBus, RuntimeQueryResult, canonical_contract_rejection_reason,
67    canonical_contract_supports_step,
68};
69pub use splitter::{
70    AggregationStrategy, SplitExpression, SplitterConfig, split_body, split_body_json_array,
71    split_body_lines,
72};
73pub use supervision::SupervisionConfig;
74pub use throttler::{ThrottleStrategy, ThrottlerConfig};
75pub use unit_of_work::UnitOfWorkConfig;
76pub use value::{Headers, Value};
camel_api/lib.rs

camel_api/
lib.rs
