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 cache;
13pub mod circuit_breaker;
14pub mod claim_check;
15pub mod component_metadata;
16pub mod component_metrics;
17pub mod data_format;
18pub mod datasource;
19pub mod declarative;
20pub mod delayer;
21pub mod dynamic_router;
22pub mod endpoint_pipeline;
23pub mod endpoint_uri;
24pub mod error;
25pub mod error_handler;
26pub mod exchange;
27pub mod exchange_lookup;
28pub mod filter;
29pub mod from_body;
30pub mod function;
31pub mod health;
32pub mod http_error_mapping;
33
34pub mod idempotent;
35pub mod in_flight;
36mod layer;
37pub mod lifecycle;
38pub mod load_balancer;
39pub mod loop_eip;
40pub mod message;
41pub mod metrics;
42pub mod multicast;
43pub mod outcome_pipeline;
44pub mod outcome_segment;
45pub mod pipeline_outcome;
46pub mod platform;
47pub mod processor;
48pub mod producer;
49pub mod recipient_list;
50pub mod redact;
51pub mod resequencer;
52pub mod reserved_suffix;
53pub mod route_controller;
54pub mod routing_slip;
55pub mod runtime;
56mod script_source;
57pub mod security_policy;
58pub mod span_kind;
59pub mod splitter;
60pub mod ssrf;
61pub mod step_lifecycle;
62pub mod stream_cache;
63pub mod supervision;
64pub mod template;
65pub mod throttler;
66pub mod unit_of_work;
67pub mod value;
68pub mod xml_convert;
69
70// Re-export core types at crate root for convenience.
71pub use aggregator::{AggregationFn, AggregatorConfig, CompletionCondition};
72pub use backoff::{BackoffConfig, BackoffState};
73pub use body::{Body, BoxAsyncRead, StreamBody, StreamMetadata, body_type_name};
74pub use body_converter::{BodyType, convert as convert_body};
75pub use cache::{CacheEntry, CacheRepository, CacheStats, ContentType};
76pub use circuit_breaker::CircuitBreakerConfig;
77pub use claim_check::ClaimCheckRepository;
78pub use component_metrics::ComponentMetrics;
79pub use component_metrics::ComponentMetricsLevers;
80pub use data_format::DataFormat;
81pub use datasource::{
82    DatasourceCatalog, DatasourceConfig, DatasourceHandle, PoolFactory, ResourceRef,
83};
84pub use declarative::{LanguageExpressionDef, ValueSourceDef};
85pub use delayer::{DEFAULT_MAX_DELAY_MS, DelayConfig};
86pub use dynamic_router::DynamicRouterConfig;
87pub use endpoint_pipeline::{CAMEL_SLIP_ENDPOINT, EndpointPipelineConfig, EndpointResolver};
88pub use endpoint_uri::EndpointUri;
89pub use error::{
90    BoxError, CIRCUIT_OPEN, CamelError, ConfigValidationError, ConversionDetail, EndpointUriError,
91    ErrorPosition, ExpressionErrorClass, OpaqueErrorSource, RedactedJson,
92};
93pub use error_handler::{
94    BoundaryKind, ErrorHandlerConfig, ExceptionDisposition, ExceptionPolicy,
95    ExceptionPolicyBuilder, HEADER_REDELIVERED, HEADER_REDELIVERY_COUNTER,
96    HEADER_REDELIVERY_MAX_COUNTER, PolicyId, RedeliveryPolicy, RetryOutcome, RetryableStep,
97    StepDisposition,
98};
99pub use exchange::{
100    CAMEL_STOP, Exchange, ExchangePattern, ORIGINAL_CONTENT_TYPE_INHERITED_EXTENSION,
101    ORIGINAL_MESSAGE_EXTENSION, OriginalContentTypeInherited, PROPERTY_HTTP_CONTENT_TYPE_INHERITED,
102    is_camel_stop,
103};
104pub use exchange_lookup::{ExchangeLookupPath, LookupPathError, PathSegment};
105pub use filter::{
106    BoxBoolFuture, BoxValueFuture, FilterPredicate, PredicateSource, RecipientSource, TargetSource,
107    ValueSource,
108};
109pub use from_body::FromBody;
110pub use function::{
111    ExchangePatch, FunctionDefinition, FunctionDiff, FunctionId, FunctionInvocationError,
112    FunctionInvoker, FunctionInvokerSync, PatchBody,
113};
114pub use health::{AsyncHealthCheck, CheckResult, HealthReport, HealthSource, ServiceHealth};
115pub use http_error_mapping::{
116    DEFAULT_BUSINESS_STATUS, HttpErrorMapping, HttpErrorMappingError, MAX_MAPPED_STATUS,
117    MIN_MAPPED_STATUS, MappingTable, business_status, default_kind_status, is_mapped_status,
118    validate_key, validate_status,
119};
120pub use idempotent::IdempotentRepository;
121pub use in_flight::{InFlightClaim, InFlightGauge};
122pub use layer::{CamelErrorAdapter, LayerFactory, ProcessorLayer, SegmentProcessor};
123pub use lifecycle::{HealthStatus, Lifecycle, ServiceStatus};
124pub use load_balancer::{LoadBalanceStrategy, LoadBalancerConfig};
125pub use message::Message;
126pub use metrics::{CompositeMetricsCollector, MetricsCollector, MetricsHandle, NoOpMetrics};
127pub use multicast::{MulticastAggregationFn, MulticastConfig, MulticastStrategy};
128pub use outcome_pipeline::OutcomePipeline;
129pub use outcome_segment::OutcomeSegment;
130pub use pipeline_outcome::PipelineOutcome;
131pub use platform::{
132    LeadershipEvent, LeadershipHandle, LeadershipService, NoopLeadershipService,
133    NoopPlatformService, NoopReadinessGate, PlatformError, PlatformIdentity, PlatformService,
134    ReadinessGate,
135};
136pub use processor::{
137    BoxProcessor, BoxProcessorExt, IdentityProcessor, OpaqueProcessor, Processor, ProcessorFn,
138    SyncBoxProcessor,
139};
140pub use producer::ProducerContext;
141pub use resequencer::{
142    BatchCompletion, CapacityPolicy, GapPolicy, ResequenceMode, ResequencePolicyConfig,
143};
144pub use route_controller::{RouteAction, RouteController, RouteStatus};
145pub use routing_slip::RoutingSlipConfig;
146pub use runtime::{
147    CANONICAL_CONTRACT_DECLARATIVE_ONLY_STEPS, CANONICAL_CONTRACT_EXCLUDED_DECLARATIVE_STEPS,
148    CANONICAL_CONTRACT_NAME, CANONICAL_CONTRACT_RUST_ONLY_STEPS,
149    CANONICAL_CONTRACT_SUPPORTED_STEPS, CANONICAL_CONTRACT_VERSION, CanonicalConcurrencySpec,
150    CanonicalFieldLoss, CanonicalLossReport, CanonicalRouteSpec, RuntimeCommand, RuntimeCommandBus,
151    RuntimeCommandResult, RuntimeEvent, RuntimeHandle, RuntimeQuery, RuntimeQueryBus,
152    RuntimeQueryResult, canonical_contract_rejection_reason, canonical_contract_supports_step,
153};
154pub use script_source::{infer_script_language, read_script_source};
155pub use security_policy::{
156    AccessMode, AudienceBinding, AuthContext, AuthPrincipal, AuthorizationDecision,
157    PRINCIPAL_AUDIENCE_KEY, PRINCIPAL_CLAIMS_KEY, PRINCIPAL_ISSUER_KEY, PRINCIPAL_KEY,
158    PRINCIPAL_ROLES_KEY, PRINCIPAL_SCOPES_KEY, PRINCIPAL_SUBJECT_KEY, Principal, RouteSecurityPlan,
159    SecurityPolicy, SecurityPolicyConfig, TransportId, store_principal_properties,
160};
161pub use span_kind::SpanKindHint;
162pub use splitter::{
163    AggregationStrategy, SplitExpression, SplitSource, SplitterConfig, StreamSplitConfig,
164    StreamSplitFormat, StreamingSplitExpression, fragment_exchange, split_body,
165    split_body_json_array, split_body_lines, streaming_split_type_error,
166};
167pub use ssrf::{SsrfPolicy, is_ssrf_blocked_ip};
168pub use step_lifecycle::{StepLifecycle, StepShutdownReason};
169pub use supervision::SupervisionConfig;
170pub use throttler::{ThrottleStrategy, ThrottlerConfig};
171pub use unit_of_work::UnitOfWorkConfig;
172pub use value::{Headers, Value, cmp_values, value_type_name};
173
174// Template types
175pub use template::{
176    RouteTemplateSpec, TemplateError, TemplateInstanceRecord, TemplateParameterSpec,
177    TemplatedRouteSpec,
178};
camel_api/lib.rs

camel_api/
lib.rs
