Module message_queue 

Distributed message queue primitives for OxiMedia.

Provides a lightweight priority-based in-memory message queue suitable for inter-node communication in a distributed encoding cluster.

Structs

DistributedMessage

An envelope wrapping a message payload for the distributed queue.

MessageQueue

A bounded, priority-ordered distributed message queue.

Enums

MessagePriority

Priority level of a message.