Module channel

Source
Expand description

channels used for communication between main process and workers

Structs§

Channel
Channel meant for communication between Sōzu processes over a UNIX socket. It wraps a unix socket using the mio crate, and transmit prost messages by serializing them in a binary format, with a fix-sized delimiter. To function, channels must come in pairs, one for each agent. They can function in a blocking or non-blocking way.

Enums§

ChannelError

Functions§

delimiter_size
the payload is prefixed with a delimiter of sizeof(usize) bytes