LavinMQ::Clustering::Client

Capacity of the channel buffering acks from the stream-reading fiber to the ack-sending fiber. Only bounds an in-process queue (send_ack_loop drains and coalesces it continuously), so a fixed size is fine; the leader's ack deadline, not this, governs how far a follower may lag.

Buffer used when streaming replicated file changes to disk. Matches LZ4::Reader's internal 64 KiB buffer.

Files #hash_local_files hashes between Fiber.yields; a yield per (often tiny) file costs more than it gives back.

On promotion both the leader watcher and the controller close the client, and the controller binds the listeners as soon as its call returns, so a call made while another is closing waits for it to finish.