esq

esq copied to clipboard

rebar2.config is missing from hex.

1

This package is a dependency of [erlkaf](https://github.com/silviucpp/erlkaf/pull/8) and when erlkaf is build as a dependency in a mix project, there is an error: ``` Error evaluating Rebar config script ./rebar.config.script:22:...

lud

Validate queue options and exit if option is not acceptable

5

Hello, Having the following queue: ```erlang {ok, Q}= esq:new( "priv/client_producer", [{tts, 0}, {capacity, 0}]). ``` After I add few items inside the queue and restart the app and do: ```erlang...

silviucpp

In-flight capability implements a simple protocol that ensures message retransmission in case of consumer failure. In-flight heap is pure in-memory segment. Existed queue behaviour deletes the on-disk segment one its...

fogfish

The error has not been 100% reproduced. I am only suspecting such behaviour.

fogfish

``` terminated with reason: no match of right hand value {error,eexist} in esq_writer:open/1 line 75 ``` The error is caused by Out-Of-Disk space. The segment rotation shall handle errors carefully.

fogfish

fogfish

[Streams](https://github.com/datum) is an efficient mechanism to handle sequence of data. ``` stream:foreach(fun(_) -> ... end, esq:stream(Queue)) ```

fogfish

Length of the queue

2

A function `-spec esq:length(_) -> integer()` is a nice feature. There are no rocket science to make it for in-memory queue. However, the file queue requires persistency of counter that...

fogfish