Current section
Files
Jump to
Current section
Files
src/erlkaf_local_queue.erl
-module(erlkaf_local_queue).
-include("erlkaf_private.hrl").
-export([
new/1,
free/1,
enq/6,
deq/1,
head/1
]).
new(ClientId) ->
Path = erlkaf_utils:get_priv_path(ClientId),
?LOG_INFO("persistent queue path: ~p", [Path]),
esq:new(Path).
free(undefined) ->
ok;
free(Queue) ->
esq:free(Queue).
enq(Queue, TopicName, Partition, Key, Value, Headers) ->
esq:enq({TopicName, Partition, Key, Value, Headers}, Queue).
deq(Queue) ->
esq:deq(Queue).
head(Queue) ->
esq:head(Queue).