Enum ManagerInput 

pub enum ManagerInput<'a> {
    ClientDatagram {
        src: SocketAddr,
        payload: &'a [u8],
    },
    BackendDatagram {
        flow: FlowId,
        payload: &'a [u8],
    },
    Config(ConfigEvent),
    BackendResolved {
        flow: FlowId,
        backend: BackendId,
        addr: SocketAddr,
    },
}

Inputs the shell feeds into the manager. Borrows the recv buffer; the core copies into an owned Vec<u8> only on admission.

Variants

ClientDatagram

A datagram from a client. Admitted into an existing/new flow or dropped.

Fields

src: SocketAddr

Real (pre-NAT) client source address.

payload: &'a [u8]

Borrowed datagram bytes.

BackendDatagram

A datagram from a backend, tagged by the shell with the owning flow (upstream_token -> FlowId). Drives the symmetric NAT return path.

Fields

flow: FlowId

Flow that owns the connected upstream socket this arrived on.

payload: &'a [u8]

Borrowed datagram bytes.

Config(ConfigEvent)

A control-plane / health event (add/remove backend, LB algo, timeouts, per-cluster knobs, drain). Never allocates a flow.

BackendResolved

Reply to an earlier Output::SelectBackend: the shell resolved the backend via the BackendMap and is committing it to the flow.

Fields

flow: FlowId

Flow awaiting a backend.

backend: BackendId

Resolved backend identifier.

addr: SocketAddr

Resolved backend address for the connected upstream socket.

Trait Implementations

impl<'a> Debug for ManagerInput<'a>

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.