Module cloudi_write_ahead_logging

erase(ChunkId::cloudi_service:trans_id(), State::#state{file = undefined | binary() | string(), position = undefined | non_neg_integer(), chunks = dict(), chunks_free = [#chunk{size = undefined | pos_integer_64bit(), position = undefined | non_neg_integer_64bit(), request = cloudi_service_queue:request() | undefined, retries = non_neg_integer()}]}) -> {cloudi_service_queue:request(), #state{file = undefined | binary() | string(), position = undefined | non_neg_integer(), chunks = dict(), chunks_free = [#chunk{size = undefined | pos_integer_64bit(), position = undefined | non_neg_integer_64bit(), request = cloudi_service_queue:request() | undefined, retries = non_neg_integer()}]}}

erase_retry(ChunkId::cloudi_service:trans_id(), RetryMax::non_neg_integer(), RetryF::fun((cloudi_service_queue:request()) -> {ok, cloudi_service:trans_id()} | {error, any()}), State::#state{file = undefined | binary() | string(), position = undefined | non_neg_integer(), chunks = dict(), chunks_free = [#chunk{size = undefined | pos_integer_64bit(), position = undefined | non_neg_integer_64bit(), request = cloudi_service_queue:request() | undefined, retries = non_neg_integer()}]}) -> #state{file = undefined | binary() | string(), position = undefined | non_neg_integer(), chunks = dict(), chunks_free = [#chunk{size = undefined | pos_integer_64bit(), position = undefined | non_neg_integer_64bit(), request = cloudi_service_queue:request() | undefined, retries = non_neg_integer()}]}

fetch_keys(State::#state{file = undefined | binary() | string(), position = undefined | non_neg_integer(), chunks = dict(), chunks_free = [#chunk{size = undefined | pos_integer_64bit(), position = undefined | non_neg_integer_64bit(), request = cloudi_service_queue:request() | undefined, retries = non_neg_integer()}]}) -> [cloudi_service:trans_id()]

new(FilePath::string() | binary(), RetryF::fun((cloudi_service_queue:request()) -> {ok, cloudi_service:trans_id()} | {error, any()})) -> #state{file = undefined | binary() | string(), position = undefined | non_neg_integer(), chunks = dict(), chunks_free = [#chunk{size = undefined | pos_integer_64bit(), position = undefined | non_neg_integer_64bit(), request = cloudi_service_queue:request() | undefined, retries = non_neg_integer()}]}

size(State::#state{file = undefined | binary() | string(), position = undefined | non_neg_integer(), chunks = dict(), chunks_free = [#chunk{size = undefined | pos_integer_64bit(), position = undefined | non_neg_integer_64bit(), request = cloudi_service_queue:request() | undefined, retries = non_neg_integer()}]}) -> non_neg_integer()

size_free(State::#state{file = undefined | binary() | string(), position = undefined | non_neg_integer(), chunks = dict(), chunks_free = [#chunk{size = undefined | pos_integer_64bit(), position = undefined | non_neg_integer_64bit(), request = cloudi_service_queue:request() | undefined, retries = non_neg_integer()}]}) -> non_neg_integer()

store_end(ChunkId::cloudi_service:trans_id(), Chunk::#chunk{size = undefined | pos_integer_64bit(), position = undefined | non_neg_integer_64bit(), request = cloudi_service_queue:request() | undefined, retries = non_neg_integer()}, State::#state{file = undefined | binary() | string(), position = undefined | non_neg_integer(), chunks = dict(), chunks_free = [#chunk{size = undefined | pos_integer_64bit(), position = undefined | non_neg_integer_64bit(), request = cloudi_service_queue:request() | undefined, retries = non_neg_integer()}]}) -> #state{file = undefined | binary() | string(), position = undefined | non_neg_integer(), chunks = dict(), chunks_free = [#chunk{size = undefined | pos_integer_64bit(), position = undefined | non_neg_integer_64bit(), request = cloudi_service_queue:request() | undefined, retries = non_neg_integer()}]}

store_fail(Chunk::#chunk{size = undefined | pos_integer_64bit(), position = undefined | non_neg_integer_64bit(), request = cloudi_service_queue:request() | undefined, retries = non_neg_integer()}, State::#state{file = undefined | binary() | string(), position = undefined | non_neg_integer(), chunks = dict(), chunks_free = [#chunk{size = undefined | pos_integer_64bit(), position = undefined | non_neg_integer_64bit(), request = cloudi_service_queue:request() | undefined, retries = non_neg_integer()}]}) -> #state{file = undefined | binary() | string(), position = undefined | non_neg_integer(), chunks = dict(), chunks_free = [#chunk{size = undefined | pos_integer_64bit(), position = undefined | non_neg_integer_64bit(), request = cloudi_service_queue:request() | undefined, retries = non_neg_integer()}]}

store_start(ChunkRequest::cloudi_service_queue:request(), State::#state{file = undefined | binary() | string(), position = undefined | non_neg_integer(), chunks = dict(), chunks_free = [#chunk{size = undefined | pos_integer_64bit(), position = undefined | non_neg_integer_64bit(), request = cloudi_service_queue:request() | undefined, retries = non_neg_integer()}]}) -> {#chunk{size = undefined | pos_integer_64bit(), position = undefined | non_neg_integer_64bit(), request = cloudi_service_queue:request() | undefined, retries = non_neg_integer()}, #state{file = undefined | binary() | string(), position = undefined | non_neg_integer(), chunks = dict(), chunks_free = [#chunk{size = undefined | pos_integer_64bit(), position = undefined | non_neg_integer_64bit(), request = cloudi_service_queue:request() | undefined, retries = non_neg_integer()}]}}

update(ChunkId::cloudi_service:trans_id(), UpdateF::fun((cloudi_service_queue:request()) -> {cloudi_service:trans_id(), cloudi_service_queue:request()} | undefined), State::#state{file = undefined | binary() | string(), position = undefined | non_neg_integer(), chunks = dict(), chunks_free = [#chunk{size = undefined | pos_integer_64bit(), position = undefined | non_neg_integer_64bit(), request = cloudi_service_queue:request() | undefined, retries = non_neg_integer()}]}) -> {cloudi_service_queue:request() | undefined, #state{file = undefined | binary() | string(), position = undefined | non_neg_integer(), chunks = dict(), chunks_free = [#chunk{size = undefined | pos_integer_64bit(), position = undefined | non_neg_integer_64bit(), request = cloudi_service_queue:request() | undefined, retries = non_neg_integer()}]}}