Module: LogCourier
- Defined in:
- lib/log-courier/event_queue.rb,
lib/log-courier/client.rb,
lib/log-courier/server.rb,
lib/log-courier/client_tcp.rb,
lib/log-courier/server_tcp.rb,
lib/log-courier/server_zmq.rb
Overview
This is a queue implementation dervied from SizedQueue, but with a timeout.
It is significantly faster than using SizedQueue wrapped in Timeout::timeout because it uses mutex.sleep, whereas Timeout::timeout actually starts another thread that waits and then raises exception or has to be stopped on exiting the block.
The majority of the code is taken from Ruby’s SizedQueue<Queue implementation.
Defined Under Namespace
Classes: Client, ClientFactoryZmq, ClientTcp, ClientZmq, ConnectionTcp, EventQueue, ExtendedTCPServer, PendingPayload, ProtocolError, Server, ServerTcp, ServerZmq, ShutdownSignal, TimeoutError