Expand description
Generic async dispatch of flow work to a separate runtime over NATS pub/sub.
The RemoteDispatchHandler trait isolates the transport so it can be swapped
(e.g. to greentic-events EventBus) without touching the flow engine.
Structs§
- Built
Request - A built NATS message (broker-free; unit-testable).
- Nats
Dispatcher - Publishes dispatch requests to NATS via raw
async-nats. - Remote
Dispatch - Everything needed to dispatch one unit of work to a runtime.
Enums§
- Remote
Dispatch Action - Outcome of a dispatch: the flow waits for a response, or it was fire-and-forget.
Traits§
- Remote
Dispatch Handler - Transport-agnostic publisher for runtime dispatch requests. Implemented over
raw
async-natstoday; the trait lets a greentic-events EventBus be swapped in later without changing the flow engine.
Functions§
- build_
request - Pure builder: turn a
RemoteDispatchinto the subject/headers/body to publish plus the resulting action. No I/O — unit-testable without a broker. - build_
timeout_ response_ message - Build the subject, headers, and serialized body for a timeout error response.