emqx/replayq

Generic on-disk persistent queue implementation for Erlang

ErlangMakefileerlangelixirpersistent-queuedisk-queuereplay-queue
This is stars and forks stats for /emqx/replayq repository. As of 03 May, 2024 this repository has 35 stars and 15 forks.

ReplayQ A Disk Queue for Log Replay in Erlang Features Queue items are written to segment files on disk to survive restart. Batch popping items out of queue with size/count limit. An ack/2 API is provided to record the reader position within a segment. Add config option max_total_bytes to limit the total size of replayq logs Usage Example Mem Only Q0 = replayq:open(#{mem_only => true}), Q1 = replayq:append(Q0, [Binary1, Binary2]), {Q2, AckRef, [Binary1]} = replayq:pop(Q1, #{bytes_limt => 1}), ok...
Read on GithubGithub Stats Page
repotechsstarsweeklyforksweekly
GoogleCloudPlatform/terraform-google-cloud-runHCLGoMakefile104+170+1
diracdeltas/tweetsShellMakefile7680237+1
StudioKeys/vendor_PixelLauncherMakefile16060
jkeys089/lua-resty-hmacPerlLuaMakefile1500970
mininet/mininetPythonCShell4.9k01.7k0
ThomasChln/mastodonRMakefile36050
abba23/spotify-adblockRustMakefile1.5k0820
vimpostor/vim-tpipelineVim ScriptLuaMakefile276-180
Wall-Brew-Co/brewtilityClojureMakefile4000
ash-project/ash_graphqlElixir46029+1