Crate allora Copy item path Source pub use allora_runtime::inventory ;ClosureProcessor DirectChannel Direct, synchronous handoff channel. EndpointBuilder Staged builder root for endpoints. Exchange An exchange wraps an inbound and outbound message, plus routing properties. HttpInboundAdapter HttpOutboundAdapter InMemoryEndpoint An in-memory FIFO endpoint for quick testing. InMemoryInOnlyEndpoint In-only endpoint: supports sending but not receiving (try_receive returns None). Message A message containing a payload and headers (metadata). OutboundDispatchResult Metadata returned from outbound dispatch. Leave fields optional / expandable for future. QueueChannel Runtime Allora builder holds configuration inputs prior to runtime construction.ServiceDescriptor EndpointSource Source metadata describing origin of messages entering an endpoint. Error HttpInboundMep Message Exchange Pattern for HTTP inbound. Payload Represents the payload of a message, supporting text, bytes, JSON, or empty. BaseAdapter Marker trait for all adapters (inbound or outbound). Intentionally empty so it can be
used for blanket implementations of decoration layers. Do NOT add methods here unless they
apply uniformly to both inbound and outbound adapters. Channel Core channel trait providing send capabilities and metadata. CorrelationSupport Correlation lookup extension (QueueChannel only). Endpoint A trait representing a message endpoint for sending and receiving Exchange InboundAdapter Inbound adapter: receives external data/events and produces Exchanges routed inside Allora. OutboundAdapter Outbound adapter: sends data derived from an Exchange to an external system. PollableChannel Dequeue extension (QueueChannel). Processor A Processor transforms an Exchange (async-only model). Service SubscribableChannel Register-and-fanout extension trait (DirectChannel). all_service_descriptors build Public: build full runtime from a file path (future: endpoints, filters, etc.). ensure_correlation Ensure a correlation_id header exists on the inbound message of the provided Exchange.
Safe to call multiple times (id will be stable after first generation). ChannelRef Type alias for a trait object reference to any Channel implementation. Result service Attribute macro for registering a Service implementation with the runtime inventory.