Skip to main content

Module inbox

Module inbox 

Source
Expand description

Service inbox โ€” a bounded FIFO receive queue with per-message TTL.

Messages are pushed by the MaEndpoint implementation after validating incoming data. Each message carries its own created_at and ttl โ€” the endpoint computes expires_at from those fields. Consumers only read from the inbox via pop, peek, or drain.

Structsยง

Inbox
A bounded FIFO receive queue for incoming ma messages.