Module transport

Module transport 

Source

Re-exports§

pub use runtime_endpoint::RunStarter;
pub use runtime_endpoint::RuntimeEndpoint;
pub use transcoder::TranscoderEndpoint;

Modules§

http_run
http_sse
nats
runtime_endpoint
RuntimeEndpoint: message-driven Endpoint<AgentEvent, RuntimeInput>.
transcoder

Structs§

EndpointPair
A matched pair of endpoints representing both sides of a transport channel.
RelayCancellation
Lightweight cancellation token for relay loops.
SessionId
Session key for one chat transport binding.
TransportBinding
Bound transport session with both sides.
TransportCapabilities
Transport-level capability declaration used for composition checks.

Enums§

NatsProtocolError
TransportError

Traits§

Endpoint
Generic endpoint view.

Functions§

channel_pair
Create an in-memory EndpointPair backed by bounded channels.
relay_binding
Relay one bound session bidirectionally:

Type Aliases§

BoxStream
Common boxed stream for transport endpoints.