Packages

cloudi_service_queue

2.0.5
2.0.7 2.0.6 2.0.5 2.0.4 2.0.3 2.0.2 2.0.1 2.0.0 1.8.0 1.7.5 1.7.4 1.7.3 1.7.2 1.7.1 1.7.0 1.6.0 1.5.4 1.5.3 1.5.1 1.5.0 1.4.0 1.4.0-rc.4 1.3.3

Erlang/Elixir Cloud Framework Persistent Queue Service

Current section

23 Versions

Jump to
Readme
23 Versions
1 Dependency
Dependants
Files
Activity
Show whitespace

Compare versions

8 files changed
+46 additions
-57 deletions
  @@ -1,6 +1,6 @@
1 1 MIT License
2 2
3 - Copyright (c) 2009-2021 Michael Truog <mjtruog at protonmail dot com>
3 + Copyright (c) 2009-2022 Michael Truog <mjtruog at protonmail dot com>
4 4
5 5 Permission is hereby granted, free of charge, to any person obtaining a
6 6 copy of this software and associated documentation files (the "Software"),
  @@ -1,4 +1,4 @@
1 - [![Build Status](https://secure.travis-ci.org/CloudI/cloudi_service_queue.png?branch=master)](http://travis-ci.org/CloudI/cloudi_service_queue)
1 + [![Build Status](https://app.travis-ci.com/CloudI/cloudi_service_queue.svg?branch=master)](https://app.travis-ci.com/CloudI/cloudi_service_queue)
2 2 [![hex.pm version](https://img.shields.io/hexpm/v/cloudi_service_queue.svg)](https://hex.pm/packages/cloudi_service_queue)
3 3
4 4 If you are looking to see if you need this repository, please refer to the [`cloudi_core` repository](https://github.com/CloudI/cloudi_core#about).
  @@ -20,9 +20,9 @@ and the queue file path is provided to this service's configuration
20 20 arguments. You must make sure the queue file path is unique. If you
21 21 use a process count higher than 1, make sure to have "${I}" within the
22 22 file path, so the process index is used within the file path.</p>.
23 - <p>Copyright © 2014-2019 Michael Truog</p>
23 + <p>Copyright © 2014-2022 Michael Truog</p>
24 24
25 - <p><b>Version:</b> 1.8.0 May 27 2021 01:43:08
25 + <p><b>Version:</b> 2.0.5 Oct 12 2022 00:12:51
26 26 ------------------------------------------------------------------------</p>
27 27 <p><b>Behaviours:</b> <a href="deps/cloudi_core/doc/cloudi_service.html"><tt>cloudi_service</tt></a>.</p>
28 28 <p><b>Authors:</b> Michael Truog (<a href="mailto:mjtruog at protonmail dot com"><tt>mjtruog at protonmail dot com</tt></a>).</p>
  @@ -104,7 +104,7 @@ timeout of the service request.</p>
104 104 <p> cloudi_write_ahead_logging</p>
105 105
106 106 <h3 class="typedecl"><a name="type-request_destination_mode">request_destination_mode()</a></h3>
107 - <p><tt>request_destination_mode() = #destination_request{request_type = <a href="deps/cloudi_core/doc/cloudi_service.html#type-request_type">cloudi_service:request_type()</a>, name = <a href="deps/cloudi_core/doc/cloudi_service.html#type-service_name">cloudi_service:service_name()</a>, pattern = <a href="deps/cloudi_core/doc/cloudi_service.html#type-service_name_pattern">cloudi_service:service_name_pattern()</a>, request_info = <a href="deps/cloudi_core/doc/cloudi_service.html#type-request_info">cloudi_service:request_info()</a>, request = <a href="deps/cloudi_core/doc/cloudi_service.html#type-request">cloudi_service:request()</a>, timeout = <a href="deps/cloudi_core/doc/cloudi_service.html#type-timeout_value_milliseconds">cloudi_service:timeout_value_milliseconds()</a>, priority = <a href="deps/cloudi_core/doc/cloudi_service.html#type-priority">cloudi_service:priority()</a>, trans_id = <a href="deps/cloudi_core/doc/cloudi_service.html#type-trans_id">cloudi_service:trans_id()</a>, pid = <a href="deps/cloudi_core/doc/cloudi_service.html#type-source">cloudi_service:source()</a>}</tt></p>
107 + <p><tt>request_destination_mode() = #destination_request{request_type = <a href="deps/cloudi_core/doc/cloudi_service.html#type-request_type">cloudi_service:request_type()</a>, name = <a href="deps/cloudi_core/doc/cloudi_service.html#type-service_name">cloudi_service:service_name()</a>, pattern = <a href="deps/cloudi_core/doc/cloudi_service.html#type-service_name_pattern">cloudi_service:service_name_pattern()</a>, request_info = <a href="deps/cloudi_core/doc/cloudi_service.html#type-request_info">cloudi_service:request_info()</a>, request = <a href="deps/cloudi_core/doc/cloudi_service.html#type-request">cloudi_service:request()</a>, timeout = <a href="deps/cloudi_core/doc/cloudi_service.html#type-timeout_value_milliseconds">cloudi_service:timeout_value_milliseconds()</a>, priority = <a href="deps/cloudi_core/doc/cloudi_service.html#type-priority">cloudi_service:priority()</a>, trans_id = <a href="deps/cloudi_core/doc/cloudi_service.html#type-trans_id">cloudi_service:trans_id()</a>, source = <a href="deps/cloudi_core/doc/cloudi_service.html#type-source">cloudi_service:source()</a>}</tt></p>
108 108 <p> fault_isolation: both</p>
109 109
110 110 <h2><a name="index">Function Index</a></h2>
  @@ -124,7 +124,7 @@ timeout of the service request.</p>
124 124
125 125 <h3 class="function"><a name="cloudi_service_handle_request-11">cloudi_service_handle_request/11</a></h3>
126 126 <div class="spec">
127 - <p><tt>cloudi_service_handle_request(RequestType, Name, Pattern, RequestInfo, Request, Timeout, Priority, TransId, Pid, State, Dispatcher) -&gt; any()</tt></p>
127 + <p><tt>cloudi_service_handle_request(RequestType, Name, Pattern, RequestInfo, Request, Timeout, Priority, TransId, Source, State, Dispatcher) -&gt; any()</tt></p>
128 128 <p> </p>
129 129 </div>
  @@ -15,7 +15,7 @@
15 15 File storage for transaction logging done by cloudi_service_queue.
16 16 <p>Copyright © 2014-2021 Michael Truog</p>
17 17
18 - <p><b>Version:</b> 2.0.2 May 27 2021 01:43:07
18 + <p><b>Version:</b> 2.0.2 Oct 12 2022 00:12:51
19 19 ------------------------------------------------------------------------</p>
20 20 <p><b>Authors:</b> Michael Truog (<a href="mailto:mjtruog at protonmail dot com"><tt>mjtruog at protonmail dot com</tt></a>).</p>
21 21
  @@ -38,15 +38,15 @@
38 38
39 39
40 40 <h3 class="typedecl"><a name="type-retry_function">retry_function()</a></h3>
41 - <p><tt>retry_function() = fun((Chunk::<a href="cloudi_service_queue.html#type-request">cloudi_service_queue:request()</a>, Retry::boolean()) -&gt; {ok, <a href="deps/cloudi_core/doc/cloudi_service.html#type-trans_id">cloudi_service:trans_id()</a>} | {error, timeout})</tt></p>
41 + <p><tt>retry_function() = fun((Chunk::<a href="doc/cloudi_service_queue.html#type-request">cloudi_service_queue:request()</a>, Retry::boolean()) -&gt; {ok, <a href="deps/cloudi_core/doc/cloudi_service.html#type-trans_id">cloudi_service:trans_id()</a>} | {error, timeout})</tt></p>
42 42
43 43
44 44 <h3 class="typedecl"><a name="type-state">state()</a></h3>
45 - <p><tt>state() = #state{file = string(), file_size_limit = <a href="#type-pos_integer_64bit">pos_integer_64bit()</a>, compression = 0..9, checksum = undefined | <a href="#type-checksum_algorithms">checksum_algorithms()</a>, checksum_size = <a href="#type-pos_integer_64bit">pos_integer_64bit()</a>, position = non_neg_integer(), chunks = #{<a href="deps/cloudi_core/doc/cloudi_service.html#type-trans_id">cloudi_service:trans_id()</a> := #chunk{size = <a href="#type-pos_integer_64bit">pos_integer_64bit()</a>, position = <a href="#type-non_neg_integer_64bit">non_neg_integer_64bit()</a>, request = <a href="cloudi_service_queue.html#type-request">cloudi_service_queue:request()</a> | undefined, retries = non_neg_integer()}}, chunks_free = [#chunk{size = <a href="#type-pos_integer_64bit">pos_integer_64bit()</a>, position = <a href="#type-non_neg_integer_64bit">non_neg_integer_64bit()</a>, request = <a href="cloudi_service_queue.html#type-request">cloudi_service_queue:request()</a> | undefined, retries = non_neg_integer()}]}</tt></p>
45 + <p><tt>state() = #state{file = string(), file_size_limit = <a href="#type-pos_integer_64bit">pos_integer_64bit()</a>, compression = 0..9, checksum = undefined | <a href="#type-checksum_algorithms">checksum_algorithms()</a>, checksum_size = <a href="#type-pos_integer_64bit">pos_integer_64bit()</a>, position = non_neg_integer(), chunks = #{<a href="deps/cloudi_core/doc/cloudi_service.html#type-trans_id">cloudi_service:trans_id()</a> := #chunk{size = <a href="#type-pos_integer_64bit">pos_integer_64bit()</a>, position = <a href="#type-non_neg_integer_64bit">non_neg_integer_64bit()</a>, request = <a href="doc/cloudi_service_queue.html#type-request">cloudi_service_queue:request()</a> | undefined, retries = non_neg_integer()}}, chunks_free = [#chunk{size = <a href="#type-pos_integer_64bit">pos_integer_64bit()</a>, position = <a href="#type-non_neg_integer_64bit">non_neg_integer_64bit()</a>, request = <a href="doc/cloudi_service_queue.html#type-request">cloudi_service_queue:request()</a> | undefined, retries = non_neg_integer()}]}</tt></p>
46 46
47 47
48 48 <h3 class="typedecl"><a name="type-update_function">update_function()</a></h3>
49 - <p><tt>update_function() = fun((<a href="cloudi_service_queue.html#type-request">cloudi_service_queue:request()</a>) -&gt; {<a href="deps/cloudi_core/doc/cloudi_service.html#type-trans_id">cloudi_service:trans_id()</a>, <a href="cloudi_service_queue.html#type-request">cloudi_service_queue:request()</a>} | undefined)</tt></p>
49 + <p><tt>update_function() = fun((<a href="doc/cloudi_service_queue.html#type-request">cloudi_service_queue:request()</a>) -&gt; {<a href="deps/cloudi_core/doc/cloudi_service.html#type-trans_id">cloudi_service:trans_id()</a>, <a href="doc/cloudi_service_queue.html#type-request">cloudi_service_queue:request()</a>} | undefined)</tt></p>
50 50
51 51
52 52 <h2><a name="index">Function Index</a></h2>
  @@ -66,61 +66,61 @@
66 66
67 67 <h3 class="function"><a name="erase-2">erase/2</a></h3>
68 68 <div class="spec">
69 - <p><tt>erase(ChunkId::<a href="deps/cloudi_core/doc/cloudi_service.html#type-trans_id">cloudi_service:trans_id()</a>, State::#state{file = string(), file_size_limit = <a href="#type-pos_integer_64bit">pos_integer_64bit()</a>, compression = 0..9, checksum = undefined | <a href="#type-checksum_algorithms">checksum_algorithms()</a>, checksum_size = <a href="#type-pos_integer_64bit">pos_integer_64bit()</a>, position = non_neg_integer(), chunks = #{<a href="deps/cloudi_core/doc/cloudi_service.html#type-trans_id">cloudi_service:trans_id()</a> := #chunk{size = <a href="#type-pos_integer_64bit">pos_integer_64bit()</a>, position = <a href="#type-non_neg_integer_64bit">non_neg_integer_64bit()</a>, request = <a href="cloudi_service_queue.html#type-request">cloudi_service_queue:request()</a> | undefined, retries = non_neg_integer()}}, chunks_free = [#chunk{size = <a href="#type-pos_integer_64bit">pos_integer_64bit()</a>, position = <a href="#type-non_neg_integer_64bit">non_neg_integer_64bit()</a>, request = <a href="cloudi_service_queue.html#type-request">cloudi_service_queue:request()</a> | undefined, retries = non_neg_integer()}]}) -&gt; {<a href="cloudi_service_queue.html#type-request">cloudi_service_queue:request()</a>, #state{file = string(), file_size_limit = <a href="#type-pos_integer_64bit">pos_integer_64bit()</a>, compression = 0..9, checksum = undefined | <a href="#type-checksum_algorithms">checksum_algorithms()</a>, checksum_size = <a href="#type-pos_integer_64bit">pos_integer_64bit()</a>, position = non_neg_integer(), chunks = #{<a href="deps/cloudi_core/doc/cloudi_service.html#type-trans_id">cloudi_service:trans_id()</a> := #chunk{size = <a href="#type-pos_integer_64bit">pos_integer_64bit()</a>, position = <a href="#type-non_neg_integer_64bit">non_neg_integer_64bit()</a>, request = <a href="cloudi_service_queue.html#type-request">cloudi_service_queue:request()</a> | undefined, retries = non_neg_integer()}}, chunks_free = [#chunk{size = <a href="#type-pos_integer_64bit">pos_integer_64bit()</a>, position = <a href="#type-non_neg_integer_64bit">non_neg_integer_64bit()</a>, request = <a href="cloudi_service_queue.html#type-request">cloudi_service_queue:request()</a> | undefined, retries = non_neg_integer()}]}}</tt><br></p>
69 + <p><tt>erase(ChunkId::<a href="deps/cloudi_core/doc/cloudi_service.html#type-trans_id">cloudi_service:trans_id()</a>, State::#state{file = string(), file_size_limit = <a href="#type-pos_integer_64bit">pos_integer_64bit()</a>, compression = 0..9, checksum = undefined | <a href="#type-checksum_algorithms">checksum_algorithms()</a>, checksum_size = <a href="#type-pos_integer_64bit">pos_integer_64bit()</a>, position = non_neg_integer(), chunks = #{<a href="deps/cloudi_core/doc/cloudi_service.html#type-trans_id">cloudi_service:trans_id()</a> := #chunk{size = <a href="#type-pos_integer_64bit">pos_integer_64bit()</a>, position = <a href="#type-non_neg_integer_64bit">non_neg_integer_64bit()</a>, request = <a href="doc/cloudi_service_queue.html#type-request">cloudi_service_queue:request()</a> | undefined, retries = non_neg_integer()}}, chunks_free = [#chunk{size = <a href="#type-pos_integer_64bit">pos_integer_64bit()</a>, position = <a href="#type-non_neg_integer_64bit">non_neg_integer_64bit()</a>, request = <a href="doc/cloudi_service_queue.html#type-request">cloudi_service_queue:request()</a> | undefined, retries = non_neg_integer()}]}) -&gt; {<a href="doc/cloudi_service_queue.html#type-request">cloudi_service_queue:request()</a>, #state{file = string(), file_size_limit = <a href="#type-pos_integer_64bit">pos_integer_64bit()</a>, compression = 0..9, checksum = undefined | <a href="#type-checksum_algorithms">checksum_algorithms()</a>, checksum_size = <a href="#type-pos_integer_64bit">pos_integer_64bit()</a>, position = non_neg_integer(), chunks = #{<a href="deps/cloudi_core/doc/cloudi_service.html#type-trans_id">cloudi_service:trans_id()</a> := #chunk{size = <a href="#type-pos_integer_64bit">pos_integer_64bit()</a>, position = <a href="#type-non_neg_integer_64bit">non_neg_integer_64bit()</a>, request = <a href="doc/cloudi_service_queue.html#type-request">cloudi_service_queue:request()</a> | undefined, retries = non_neg_integer()}}, chunks_free = [#chunk{size = <a href="#type-pos_integer_64bit">pos_integer_64bit()</a>, position = <a href="#type-non_neg_integer_64bit">non_neg_integer_64bit()</a>, request = <a href="doc/cloudi_service_queue.html#type-request">cloudi_service_queue:request()</a> | undefined, retries = non_neg_integer()}]}}</tt><br></p>
70 70 <p> </p>
71 71 </div>
72 72
73 73 <h3 class="function"><a name="erase_retry-4">erase_retry/4</a></h3>
74 74 <div class="spec">
75 - <p><tt>erase_retry(ChunkId::<a href="deps/cloudi_core/doc/cloudi_service.html#type-trans_id">cloudi_service:trans_id()</a>, RetryMax::non_neg_integer(), RetryF::<a href="#type-retry_function">retry_function()</a>, State::#state{file = string(), file_size_limit = <a href="#type-pos_integer_64bit">pos_integer_64bit()</a>, compression = 0..9, checksum = undefined | <a href="#type-checksum_algorithms">checksum_algorithms()</a>, checksum_size = <a href="#type-pos_integer_64bit">pos_integer_64bit()</a>, position = non_neg_integer(), chunks = #{<a href="deps/cloudi_core/doc/cloudi_service.html#type-trans_id">cloudi_service:trans_id()</a> := #chunk{size = <a href="#type-pos_integer_64bit">pos_integer_64bit()</a>, position = <a href="#type-non_neg_integer_64bit">non_neg_integer_64bit()</a>, request = <a href="cloudi_service_queue.html#type-request">cloudi_service_queue:request()</a> | undefined, retries = non_neg_integer()}}, chunks_free = [#chunk{size = <a href="#type-pos_integer_64bit">pos_integer_64bit()</a>, position = <a href="#type-non_neg_integer_64bit">non_neg_integer_64bit()</a>, request = <a href="cloudi_service_queue.html#type-request">cloudi_service_queue:request()</a> | undefined, retries = non_neg_integer()}]}) -&gt; #state{file = string(), file_size_limit = <a href="#type-pos_integer_64bit">pos_integer_64bit()</a>, compression = 0..9, checksum = undefined | <a href="#type-checksum_algorithms">checksum_algorithms()</a>, checksum_size = <a href="#type-pos_integer_64bit">pos_integer_64bit()</a>, position = non_neg_integer(), chunks = #{<a href="deps/cloudi_core/doc/cloudi_service.html#type-trans_id">cloudi_service:trans_id()</a> := #chunk{size = <a href="#type-pos_integer_64bit">pos_integer_64bit()</a>, position = <a href="#type-non_neg_integer_64bit">non_neg_integer_64bit()</a>, request = <a href="cloudi_service_queue.html#type-request">cloudi_service_queue:request()</a> | undefined, retries = non_neg_integer()}}, chunks_free = [#chunk{size = <a href="#type-pos_integer_64bit">pos_integer_64bit()</a>, position = <a href="#type-non_neg_integer_64bit">non_neg_integer_64bit()</a>, request = <a href="cloudi_service_queue.html#type-request">cloudi_service_queue:request()</a> | undefined, retries = non_neg_integer()}]}</tt><br></p>
75 + <p><tt>erase_retry(ChunkId::<a href="deps/cloudi_core/doc/cloudi_service.html#type-trans_id">cloudi_service:trans_id()</a>, RetryMax::non_neg_integer(), RetryF::<a href="#type-retry_function">retry_function()</a>, State::#state{file = string(), file_size_limit = <a href="#type-pos_integer_64bit">pos_integer_64bit()</a>, compression = 0..9, checksum = undefined | <a href="#type-checksum_algorithms">checksum_algorithms()</a>, checksum_size = <a href="#type-pos_integer_64bit">pos_integer_64bit()</a>, position = non_neg_integer(), chunks = #{<a href="deps/cloudi_core/doc/cloudi_service.html#type-trans_id">cloudi_service:trans_id()</a> := #chunk{size = <a href="#type-pos_integer_64bit">pos_integer_64bit()</a>, position = <a href="#type-non_neg_integer_64bit">non_neg_integer_64bit()</a>, request = <a href="doc/cloudi_service_queue.html#type-request">cloudi_service_queue:request()</a> | undefined, retries = non_neg_integer()}}, chunks_free = [#chunk{size = <a href="#type-pos_integer_64bit">pos_integer_64bit()</a>, position = <a href="#type-non_neg_integer_64bit">non_neg_integer_64bit()</a>, request = <a href="doc/cloudi_service_queue.html#type-request">cloudi_service_queue:request()</a> | undefined, retries = non_neg_integer()}]}) -&gt; #state{file = string(), file_size_limit = <a href="#type-pos_integer_64bit">pos_integer_64bit()</a>, compression = 0..9, checksum = undefined | <a href="#type-checksum_algorithms">checksum_algorithms()</a>, checksum_size = <a href="#type-pos_integer_64bit">pos_integer_64bit()</a>, position = non_neg_integer(), chunks = #{<a href="deps/cloudi_core/doc/cloudi_service.html#type-trans_id">cloudi_service:trans_id()</a> := #chunk{size = <a href="#type-pos_integer_64bit">pos_integer_64bit()</a>, position = <a href="#type-non_neg_integer_64bit">non_neg_integer_64bit()</a>, request = <a href="doc/cloudi_service_queue.html#type-request">cloudi_service_queue:request()</a> | undefined, retries = non_neg_integer()}}, chunks_free = [#chunk{size = <a href="#type-pos_integer_64bit">pos_integer_64bit()</a>, position = <a href="#type-non_neg_integer_64bit">non_neg_integer_64bit()</a>, request = <a href="doc/cloudi_service_queue.html#type-request">cloudi_service_queue:request()</a> | undefined, retries = non_neg_integer()}]}</tt><br></p>
76 76 <p> </p>
77 77 </div>
78 78
79 79 <h3 class="function"><a name="fetch_keys-1">fetch_keys/1</a></h3>
80 80 <div class="spec">
81 - <p><tt>fetch_keys(State::#state{file = string(), file_size_limit = <a href="#type-pos_integer_64bit">pos_integer_64bit()</a>, compression = 0..9, checksum = undefined | <a href="#type-checksum_algorithms">checksum_algorithms()</a>, checksum_size = <a href="#type-pos_integer_64bit">pos_integer_64bit()</a>, position = non_neg_integer(), chunks = #{<a href="deps/cloudi_core/doc/cloudi_service.html#type-trans_id">cloudi_service:trans_id()</a> := #chunk{size = <a href="#type-pos_integer_64bit">pos_integer_64bit()</a>, position = <a href="#type-non_neg_integer_64bit">non_neg_integer_64bit()</a>, request = <a href="cloudi_service_queue.html#type-request">cloudi_service_queue:request()</a> | undefined, retries = non_neg_integer()}}, chunks_free = [#chunk{size = <a href="#type-pos_integer_64bit">pos_integer_64bit()</a>, position = <a href="#type-non_neg_integer_64bit">non_neg_integer_64bit()</a>, request = <a href="cloudi_service_queue.html#type-request">cloudi_service_queue:request()</a> | undefined, retries = non_neg_integer()}]}) -&gt; [<a href="deps/cloudi_core/doc/cloudi_service.html#type-trans_id">cloudi_service:trans_id()</a>]</tt><br></p>
81 + <p><tt>fetch_keys(State::#state{file = string(), file_size_limit = <a href="#type-pos_integer_64bit">pos_integer_64bit()</a>, compression = 0..9, checksum = undefined | <a href="#type-checksum_algorithms">checksum_algorithms()</a>, checksum_size = <a href="#type-pos_integer_64bit">pos_integer_64bit()</a>, position = non_neg_integer(), chunks = #{<a href="deps/cloudi_core/doc/cloudi_service.html#type-trans_id">cloudi_service:trans_id()</a> := #chunk{size = <a href="#type-pos_integer_64bit">pos_integer_64bit()</a>, position = <a href="#type-non_neg_integer_64bit">non_neg_integer_64bit()</a>, request = <a href="doc/cloudi_service_queue.html#type-request">cloudi_service_queue:request()</a> | undefined, retries = non_neg_integer()}}, chunks_free = [#chunk{size = <a href="#type-pos_integer_64bit">pos_integer_64bit()</a>, position = <a href="#type-non_neg_integer_64bit">non_neg_integer_64bit()</a>, request = <a href="doc/cloudi_service_queue.html#type-request">cloudi_service_queue:request()</a> | undefined, retries = non_neg_integer()}]}) -&gt; [<a href="deps/cloudi_core/doc/cloudi_service.html#type-trans_id">cloudi_service:trans_id()</a>]</tt><br></p>
82 82 <p> </p>
83 83 </div>
84 84
85 85 <h3 class="function"><a name="new-5">new/5</a></h3>
86 86 <div class="spec">
87 - <p><tt>new(FilePath::string(), FileSizeLimit::1024..18446744073709551615, Compression::0..9, Checksum::undefined | <a href="#type-checksum_algorithms">checksum_algorithms()</a>, RetryF::<a href="#type-retry_function">retry_function()</a>) -&gt; #state{file = string(), file_size_limit = <a href="#type-pos_integer_64bit">pos_integer_64bit()</a>, compression = 0..9, checksum = undefined | <a href="#type-checksum_algorithms">checksum_algorithms()</a>, checksum_size = <a href="#type-pos_integer_64bit">pos_integer_64bit()</a>, position = non_neg_integer(), chunks = #{<a href="deps/cloudi_core/doc/cloudi_service.html#type-trans_id">cloudi_service:trans_id()</a> := #chunk{size = <a href="#type-pos_integer_64bit">pos_integer_64bit()</a>, position = <a href="#type-non_neg_integer_64bit">non_neg_integer_64bit()</a>, request = <a href="cloudi_service_queue.html#type-request">cloudi_service_queue:request()</a> | undefined, retries = non_neg_integer()}}, chunks_free = [#chunk{size = <a href="#type-pos_integer_64bit">pos_integer_64bit()</a>, position = <a href="#type-non_neg_integer_64bit">non_neg_integer_64bit()</a>, request = <a href="cloudi_service_queue.html#type-request">cloudi_service_queue:request()</a> | undefined, retries = non_neg_integer()}]}</tt><br></p>
87 + <p><tt>new(FilePath::string(), FileSizeLimit::1024..18446744073709551615, Compression::0..9, Checksum::undefined | <a href="#type-checksum_algorithms">checksum_algorithms()</a>, RetryF::<a href="#type-retry_function">retry_function()</a>) -&gt; #state{file = string(), file_size_limit = <a href="#type-pos_integer_64bit">pos_integer_64bit()</a>, compression = 0..9, checksum = undefined | <a href="#type-checksum_algorithms">checksum_algorithms()</a>, checksum_size = <a href="#type-pos_integer_64bit">pos_integer_64bit()</a>, position = non_neg_integer(), chunks = #{<a href="deps/cloudi_core/doc/cloudi_service.html#type-trans_id">cloudi_service:trans_id()</a> := #chunk{size = <a href="#type-pos_integer_64bit">pos_integer_64bit()</a>, position = <a href="#type-non_neg_integer_64bit">non_neg_integer_64bit()</a>, request = <a href="doc/cloudi_service_queue.html#type-request">cloudi_service_queue:request()</a> | undefined, retries = non_neg_integer()}}, chunks_free = [#chunk{size = <a href="#type-pos_integer_64bit">pos_integer_64bit()</a>, position = <a href="#type-non_neg_integer_64bit">non_neg_integer_64bit()</a>, request = <a href="doc/cloudi_service_queue.html#type-request">cloudi_service_queue:request()</a> | undefined, retries = non_neg_integer()}]}</tt><br></p>
88 88 <p> </p>
89 89 </div>
90 90
91 91 <h3 class="function"><a name="size-1">size/1</a></h3>
92 92 <div class="spec">
93 - <p><tt>size(State::#state{file = string(), file_size_limit = <a href="#type-pos_integer_64bit">pos_integer_64bit()</a>, compression = 0..9, checksum = undefined | <a href="#type-checksum_algorithms">checksum_algorithms()</a>, checksum_size = <a href="#type-pos_integer_64bit">pos_integer_64bit()</a>, position = non_neg_integer(), chunks = #{<a href="deps/cloudi_core/doc/cloudi_service.html#type-trans_id">cloudi_service:trans_id()</a> := #chunk{size = <a href="#type-pos_integer_64bit">pos_integer_64bit()</a>, position = <a href="#type-non_neg_integer_64bit">non_neg_integer_64bit()</a>, request = <a href="cloudi_service_queue.html#type-request">cloudi_service_queue:request()</a> | undefined, retries = non_neg_integer()}}, chunks_free = [#chunk{size = <a href="#type-pos_integer_64bit">pos_integer_64bit()</a>, position = <a href="#type-non_neg_integer_64bit">non_neg_integer_64bit()</a>, request = <a href="cloudi_service_queue.html#type-request">cloudi_service_queue:request()</a> | undefined, retries = non_neg_integer()}]}) -&gt; non_neg_integer()</tt><br></p>
93 + <p><tt>size(State::#state{file = string(), file_size_limit = <a href="#type-pos_integer_64bit">pos_integer_64bit()</a>, compression = 0..9, checksum = undefined | <a href="#type-checksum_algorithms">checksum_algorithms()</a>, checksum_size = <a href="#type-pos_integer_64bit">pos_integer_64bit()</a>, position = non_neg_integer(), chunks = #{<a href="deps/cloudi_core/doc/cloudi_service.html#type-trans_id">cloudi_service:trans_id()</a> := #chunk{size = <a href="#type-pos_integer_64bit">pos_integer_64bit()</a>, position = <a href="#type-non_neg_integer_64bit">non_neg_integer_64bit()</a>, request = <a href="doc/cloudi_service_queue.html#type-request">cloudi_service_queue:request()</a> | undefined, retries = non_neg_integer()}}, chunks_free = [#chunk{size = <a href="#type-pos_integer_64bit">pos_integer_64bit()</a>, position = <a href="#type-non_neg_integer_64bit">non_neg_integer_64bit()</a>, request = <a href="doc/cloudi_service_queue.html#type-request">cloudi_service_queue:request()</a> | undefined, retries = non_neg_integer()}]}) -&gt; non_neg_integer()</tt><br></p>
94 94 <p> </p>
95 95 </div>
96 96
97 97 <h3 class="function"><a name="size_free-1">size_free/1</a></h3>
98 98 <div class="spec">
99 - <p><tt>size_free(State::#state{file = string(), file_size_limit = <a href="#type-pos_integer_64bit">pos_integer_64bit()</a>, compression = 0..9, checksum = undefined | <a href="#type-checksum_algorithms">checksum_algorithms()</a>, checksum_size = <a href="#type-pos_integer_64bit">pos_integer_64bit()</a>, position = non_neg_integer(), chunks = #{<a href="deps/cloudi_core/doc/cloudi_service.html#type-trans_id">cloudi_service:trans_id()</a> := #chunk{size = <a href="#type-pos_integer_64bit">pos_integer_64bit()</a>, position = <a href="#type-non_neg_integer_64bit">non_neg_integer_64bit()</a>, request = <a href="cloudi_service_queue.html#type-request">cloudi_service_queue:request()</a> | undefined, retries = non_neg_integer()}}, chunks_free = [#chunk{size = <a href="#type-pos_integer_64bit">pos_integer_64bit()</a>, position = <a href="#type-non_neg_integer_64bit">non_neg_integer_64bit()</a>, request = <a href="cloudi_service_queue.html#type-request">cloudi_service_queue:request()</a> | undefined, retries = non_neg_integer()}]}) -&gt; non_neg_integer()</tt><br></p>
99 + <p><tt>size_free(State::#state{file = string(), file_size_limit = <a href="#type-pos_integer_64bit">pos_integer_64bit()</a>, compression = 0..9, checksum = undefined | <a href="#type-checksum_algorithms">checksum_algorithms()</a>, checksum_size = <a href="#type-pos_integer_64bit">pos_integer_64bit()</a>, position = non_neg_integer(), chunks = #{<a href="deps/cloudi_core/doc/cloudi_service.html#type-trans_id">cloudi_service:trans_id()</a> := #chunk{size = <a href="#type-pos_integer_64bit">pos_integer_64bit()</a>, position = <a href="#type-non_neg_integer_64bit">non_neg_integer_64bit()</a>, request = <a href="doc/cloudi_service_queue.html#type-request">cloudi_service_queue:request()</a> | undefined, retries = non_neg_integer()}}, chunks_free = [#chunk{size = <a href="#type-pos_integer_64bit">pos_integer_64bit()</a>, position = <a href="#type-non_neg_integer_64bit">non_neg_integer_64bit()</a>, request = <a href="doc/cloudi_service_queue.html#type-request">cloudi_service_queue:request()</a> | undefined, retries = non_neg_integer()}]}) -&gt; non_neg_integer()</tt><br></p>
100 100 <p> </p>
101 101 </div>
102 102
103 103 <h3 class="function"><a name="store_end-3">store_end/3</a></h3>
104 104 <div class="spec">
105 - <p><tt>store_end(ChunkId::<a href="deps/cloudi_core/doc/cloudi_service.html#type-trans_id">cloudi_service:trans_id()</a>, Chunk::#chunk{size = <a href="#type-pos_integer_64bit">pos_integer_64bit()</a>, position = <a href="#type-non_neg_integer_64bit">non_neg_integer_64bit()</a>, request = <a href="cloudi_service_queue.html#type-request">cloudi_service_queue:request()</a> | undefined, retries = non_neg_integer()}, State::#state{file = string(), file_size_limit = <a href="#type-pos_integer_64bit">pos_integer_64bit()</a>, compression = 0..9, checksum = undefined | <a href="#type-checksum_algorithms">checksum_algorithms()</a>, checksum_size = <a href="#type-pos_integer_64bit">pos_integer_64bit()</a>, position = non_neg_integer(), chunks = #{<a href="deps/cloudi_core/doc/cloudi_service.html#type-trans_id">cloudi_service:trans_id()</a> := #chunk{size = <a href="#type-pos_integer_64bit">pos_integer_64bit()</a>, position = <a href="#type-non_neg_integer_64bit">non_neg_integer_64bit()</a>, request = <a href="cloudi_service_queue.html#type-request">cloudi_service_queue:request()</a> | undefined, retries = non_neg_integer()}}, chunks_free = [#chunk{size = <a href="#type-pos_integer_64bit">pos_integer_64bit()</a>, position = <a href="#type-non_neg_integer_64bit">non_neg_integer_64bit()</a>, request = <a href="cloudi_service_queue.html#type-request">cloudi_service_queue:request()</a> | undefined, retries = non_neg_integer()}]}) -&gt; #state{file = string(), file_size_limit = <a href="#type-pos_integer_64bit">pos_integer_64bit()</a>, compression = 0..9, checksum = undefined | <a href="#type-checksum_algorithms">checksum_algorithms()</a>, checksum_size = <a href="#type-pos_integer_64bit">pos_integer_64bit()</a>, position = non_neg_integer(), chunks = #{<a href="deps/cloudi_core/doc/cloudi_service.html#type-trans_id">cloudi_service:trans_id()</a> := #chunk{size = <a href="#type-pos_integer_64bit">pos_integer_64bit()</a>, position = <a href="#type-non_neg_integer_64bit">non_neg_integer_64bit()</a>, request = <a href="cloudi_service_queue.html#type-request">cloudi_service_queue:request()</a> | undefined, retries = non_neg_integer()}}, chunks_free = [#chunk{size = <a href="#type-pos_integer_64bit">pos_integer_64bit()</a>, position = <a href="#type-non_neg_integer_64bit">non_neg_integer_64bit()</a>, request = <a href="cloudi_service_queue.html#type-request">cloudi_service_queue:request()</a> | undefined, retries = non_neg_integer()}]}</tt><br></p>
105 + <p><tt>store_end(ChunkId::<a href="deps/cloudi_core/doc/cloudi_service.html#type-trans_id">cloudi_service:trans_id()</a>, Chunk::#chunk{size = <a href="#type-pos_integer_64bit">pos_integer_64bit()</a>, position = <a href="#type-non_neg_integer_64bit">non_neg_integer_64bit()</a>, request = <a href="doc/cloudi_service_queue.html#type-request">cloudi_service_queue:request()</a> | undefined, retries = non_neg_integer()}, State::#state{file = string(), file_size_limit = <a href="#type-pos_integer_64bit">pos_integer_64bit()</a>, compression = 0..9, checksum = undefined | <a href="#type-checksum_algorithms">checksum_algorithms()</a>, checksum_size = <a href="#type-pos_integer_64bit">pos_integer_64bit()</a>, position = non_neg_integer(), chunks = #{<a href="deps/cloudi_core/doc/cloudi_service.html#type-trans_id">cloudi_service:trans_id()</a> := #chunk{size = <a href="#type-pos_integer_64bit">pos_integer_64bit()</a>, position = <a href="#type-non_neg_integer_64bit">non_neg_integer_64bit()</a>, request = <a href="doc/cloudi_service_queue.html#type-request">cloudi_service_queue:request()</a> | undefined, retries = non_neg_integer()}}, chunks_free = [#chunk{size = <a href="#type-pos_integer_64bit">pos_integer_64bit()</a>, position = <a href="#type-non_neg_integer_64bit">non_neg_integer_64bit()</a>, request = <a href="doc/cloudi_service_queue.html#type-request">cloudi_service_queue:request()</a> | undefined, retries = non_neg_integer()}]}) -&gt; #state{file = string(), file_size_limit = <a href="#type-pos_integer_64bit">pos_integer_64bit()</a>, compression = 0..9, checksum = undefined | <a href="#type-checksum_algorithms">checksum_algorithms()</a>, checksum_size = <a href="#type-pos_integer_64bit">pos_integer_64bit()</a>, position = non_neg_integer(), chunks = #{<a href="deps/cloudi_core/doc/cloudi_service.html#type-trans_id">cloudi_service:trans_id()</a> := #chunk{size = <a href="#type-pos_integer_64bit">pos_integer_64bit()</a>, position = <a href="#type-non_neg_integer_64bit">non_neg_integer_64bit()</a>, request = <a href="doc/cloudi_service_queue.html#type-request">cloudi_service_queue:request()</a> | undefined, retries = non_neg_integer()}}, chunks_free = [#chunk{size = <a href="#type-pos_integer_64bit">pos_integer_64bit()</a>, position = <a href="#type-non_neg_integer_64bit">non_neg_integer_64bit()</a>, request = <a href="doc/cloudi_service_queue.html#type-request">cloudi_service_queue:request()</a> | undefined, retries = non_neg_integer()}]}</tt><br></p>
106 106 <p> </p>
107 107 </div>
108 108
109 109 <h3 class="function"><a name="store_fail-2">store_fail/2</a></h3>
110 110 <div class="spec">
111 - <p><tt>store_fail(Chunk::#chunk{size = <a href="#type-pos_integer_64bit">pos_integer_64bit()</a>, position = <a href="#type-non_neg_integer_64bit">non_neg_integer_64bit()</a>, request = <a href="cloudi_service_queue.html#type-request">cloudi_service_queue:request()</a> | undefined, retries = non_neg_integer()}, State::#state{file = string(), file_size_limit = <a href="#type-pos_integer_64bit">pos_integer_64bit()</a>, compression = 0..9, checksum = undefined | <a href="#type-checksum_algorithms">checksum_algorithms()</a>, checksum_size = <a href="#type-pos_integer_64bit">pos_integer_64bit()</a>, position = non_neg_integer(), chunks = #{<a href="deps/cloudi_core/doc/cloudi_service.html#type-trans_id">cloudi_service:trans_id()</a> := #chunk{size = <a href="#type-pos_integer_64bit">pos_integer_64bit()</a>, position = <a href="#type-non_neg_integer_64bit">non_neg_integer_64bit()</a>, request = <a href="cloudi_service_queue.html#type-request">cloudi_service_queue:request()</a> | undefined, retries = non_neg_integer()}}, chunks_free = [#chunk{size = <a href="#type-pos_integer_64bit">pos_integer_64bit()</a>, position = <a href="#type-non_neg_integer_64bit">non_neg_integer_64bit()</a>, request = <a href="cloudi_service_queue.html#type-request">cloudi_service_queue:request()</a> | undefined, retries = non_neg_integer()}]}) -&gt; #state{file = string(), file_size_limit = <a href="#type-pos_integer_64bit">pos_integer_64bit()</a>, compression = 0..9, checksum = undefined | <a href="#type-checksum_algorithms">checksum_algorithms()</a>, checksum_size = <a href="#type-pos_integer_64bit">pos_integer_64bit()</a>, position = non_neg_integer(), chunks = #{<a href="deps/cloudi_core/doc/cloudi_service.html#type-trans_id">cloudi_service:trans_id()</a> := #chunk{size = <a href="#type-pos_integer_64bit">pos_integer_64bit()</a>, position = <a href="#type-non_neg_integer_64bit">non_neg_integer_64bit()</a>, request = <a href="cloudi_service_queue.html#type-request">cloudi_service_queue:request()</a> | undefined, retries = non_neg_integer()}}, chunks_free = [#chunk{size = <a href="#type-pos_integer_64bit">pos_integer_64bit()</a>, position = <a href="#type-non_neg_integer_64bit">non_neg_integer_64bit()</a>, request = <a href="cloudi_service_queue.html#type-request">cloudi_service_queue:request()</a> | undefined, retries = non_neg_integer()}]}</tt><br></p>
111 + <p><tt>store_fail(Chunk::#chunk{size = <a href="#type-pos_integer_64bit">pos_integer_64bit()</a>, position = <a href="#type-non_neg_integer_64bit">non_neg_integer_64bit()</a>, request = <a href="doc/cloudi_service_queue.html#type-request">cloudi_service_queue:request()</a> | undefined, retries = non_neg_integer()}, State::#state{file = string(), file_size_limit = <a href="#type-pos_integer_64bit">pos_integer_64bit()</a>, compression = 0..9, checksum = undefined | <a href="#type-checksum_algorithms">checksum_algorithms()</a>, checksum_size = <a href="#type-pos_integer_64bit">pos_integer_64bit()</a>, position = non_neg_integer(), chunks = #{<a href="deps/cloudi_core/doc/cloudi_service.html#type-trans_id">cloudi_service:trans_id()</a> := #chunk{size = <a href="#type-pos_integer_64bit">pos_integer_64bit()</a>, position = <a href="#type-non_neg_integer_64bit">non_neg_integer_64bit()</a>, request = <a href="doc/cloudi_service_queue.html#type-request">cloudi_service_queue:request()</a> | undefined, retries = non_neg_integer()}}, chunks_free = [#chunk{size = <a href="#type-pos_integer_64bit">pos_integer_64bit()</a>, position = <a href="#type-non_neg_integer_64bit">non_neg_integer_64bit()</a>, request = <a href="doc/cloudi_service_queue.html#type-request">cloudi_service_queue:request()</a> | undefined, retries = non_neg_integer()}]}) -&gt; #state{file = string(), file_size_limit = <a href="#type-pos_integer_64bit">pos_integer_64bit()</a>, compression = 0..9, checksum = undefined | <a href="#type-checksum_algorithms">checksum_algorithms()</a>, checksum_size = <a href="#type-pos_integer_64bit">pos_integer_64bit()</a>, position = non_neg_integer(), chunks = #{<a href="deps/cloudi_core/doc/cloudi_service.html#type-trans_id">cloudi_service:trans_id()</a> := #chunk{size = <a href="#type-pos_integer_64bit">pos_integer_64bit()</a>, position = <a href="#type-non_neg_integer_64bit">non_neg_integer_64bit()</a>, request = <a href="doc/cloudi_service_queue.html#type-request">cloudi_service_queue:request()</a> | undefined, retries = non_neg_integer()}}, chunks_free = [#chunk{size = <a href="#type-pos_integer_64bit">pos_integer_64bit()</a>, position = <a href="#type-non_neg_integer_64bit">non_neg_integer_64bit()</a>, request = <a href="doc/cloudi_service_queue.html#type-request">cloudi_service_queue:request()</a> | undefined, retries = non_neg_integer()}]}</tt><br></p>
112 112 <p> </p>
113 113 </div>
114 114
115 115 <h3 class="function"><a name="store_start-2">store_start/2</a></h3>
116 116 <div class="spec">
117 - <p><tt>store_start(ChunkRequest::<a href="cloudi_service_queue.html#type-request">cloudi_service_queue:request()</a>, State::#state{file = string(), file_size_limit = <a href="#type-pos_integer_64bit">pos_integer_64bit()</a>, compression = 0..9, checksum = undefined | <a href="#type-checksum_algorithms">checksum_algorithms()</a>, checksum_size = <a href="#type-pos_integer_64bit">pos_integer_64bit()</a>, position = non_neg_integer(), chunks = #{<a href="deps/cloudi_core/doc/cloudi_service.html#type-trans_id">cloudi_service:trans_id()</a> := #chunk{size = <a href="#type-pos_integer_64bit">pos_integer_64bit()</a>, position = <a href="#type-non_neg_integer_64bit">non_neg_integer_64bit()</a>, request = <a href="cloudi_service_queue.html#type-request">cloudi_service_queue:request()</a> | undefined, retries = non_neg_integer()}}, chunks_free = [#chunk{size = <a href="#type-pos_integer_64bit">pos_integer_64bit()</a>, position = <a href="#type-non_neg_integer_64bit">non_neg_integer_64bit()</a>, request = <a href="cloudi_service_queue.html#type-request">cloudi_service_queue:request()</a> | undefined, retries = non_neg_integer()}]}) -&gt; {#chunk{size = <a href="#type-pos_integer_64bit">pos_integer_64bit()</a>, position = <a href="#type-non_neg_integer_64bit">non_neg_integer_64bit()</a>, request = <a href="cloudi_service_queue.html#type-request">cloudi_service_queue:request()</a> | undefined, retries = non_neg_integer()}, #state{file = string(), file_size_limit = <a href="#type-pos_integer_64bit">pos_integer_64bit()</a>, compression = 0..9, checksum = undefined | <a href="#type-checksum_algorithms">checksum_algorithms()</a>, checksum_size = <a href="#type-pos_integer_64bit">pos_integer_64bit()</a>, position = non_neg_integer(), chunks = #{<a href="deps/cloudi_core/doc/cloudi_service.html#type-trans_id">cloudi_service:trans_id()</a> := #chunk{size = <a href="#type-pos_integer_64bit">pos_integer_64bit()</a>, position = <a href="#type-non_neg_integer_64bit">non_neg_integer_64bit()</a>, request = <a href="cloudi_service_queue.html#type-request">cloudi_service_queue:request()</a> | undefined, retries = non_neg_integer()}}, chunks_free = [#chunk{size = <a href="#type-pos_integer_64bit">pos_integer_64bit()</a>, position = <a href="#type-non_neg_integer_64bit">non_neg_integer_64bit()</a>, request = <a href="cloudi_service_queue.html#type-request">cloudi_service_queue:request()</a> | undefined, retries = non_neg_integer()}]}} | full</tt><br></p>
117 + <p><tt>store_start(ChunkRequest::<a href="doc/cloudi_service_queue.html#type-request">cloudi_service_queue:request()</a>, State::#state{file = string(), file_size_limit = <a href="#type-pos_integer_64bit">pos_integer_64bit()</a>, compression = 0..9, checksum = undefined | <a href="#type-checksum_algorithms">checksum_algorithms()</a>, checksum_size = <a href="#type-pos_integer_64bit">pos_integer_64bit()</a>, position = non_neg_integer(), chunks = #{<a href="deps/cloudi_core/doc/cloudi_service.html#type-trans_id">cloudi_service:trans_id()</a> := #chunk{size = <a href="#type-pos_integer_64bit">pos_integer_64bit()</a>, position = <a href="#type-non_neg_integer_64bit">non_neg_integer_64bit()</a>, request = <a href="doc/cloudi_service_queue.html#type-request">cloudi_service_queue:request()</a> | undefined, retries = non_neg_integer()}}, chunks_free = [#chunk{size = <a href="#type-pos_integer_64bit">pos_integer_64bit()</a>, position = <a href="#type-non_neg_integer_64bit">non_neg_integer_64bit()</a>, request = <a href="doc/cloudi_service_queue.html#type-request">cloudi_service_queue:request()</a> | undefined, retries = non_neg_integer()}]}) -&gt; {#chunk{size = <a href="#type-pos_integer_64bit">pos_integer_64bit()</a>, position = <a href="#type-non_neg_integer_64bit">non_neg_integer_64bit()</a>, request = <a href="doc/cloudi_service_queue.html#type-request">cloudi_service_queue:request()</a> | undefined, retries = non_neg_integer()}, #state{file = string(), file_size_limit = <a href="#type-pos_integer_64bit">pos_integer_64bit()</a>, compression = 0..9, checksum = undefined | <a href="#type-checksum_algorithms">checksum_algorithms()</a>, checksum_size = <a href="#type-pos_integer_64bit">pos_integer_64bit()</a>, position = non_neg_integer(), chunks = #{<a href="deps/cloudi_core/doc/cloudi_service.html#type-trans_id">cloudi_service:trans_id()</a> := #chunk{size = <a href="#type-pos_integer_64bit">pos_integer_64bit()</a>, position = <a href="#type-non_neg_integer_64bit">non_neg_integer_64bit()</a>, request = <a href="doc/cloudi_service_queue.html#type-request">cloudi_service_queue:request()</a> | undefined, retries = non_neg_integer()}}, chunks_free = [#chunk{size = <a href="#type-pos_integer_64bit">pos_integer_64bit()</a>, position = <a href="#type-non_neg_integer_64bit">non_neg_integer_64bit()</a>, request = <a href="doc/cloudi_service_queue.html#type-request">cloudi_service_queue:request()</a> | undefined, retries = non_neg_integer()}]}} | full</tt><br></p>
118 118 <p> </p>
119 119 </div>
120 120
121 121 <h3 class="function"><a name="update-3">update/3</a></h3>
122 122 <div class="spec">
123 - <p><tt>update(ChunkId::<a href="deps/cloudi_core/doc/cloudi_service.html#type-trans_id">cloudi_service:trans_id()</a>, UpdateF::<a href="#type-update_function">update_function()</a>, State::#state{file = string(), file_size_limit = <a href="#type-pos_integer_64bit">pos_integer_64bit()</a>, compression = 0..9, checksum = undefined | <a href="#type-checksum_algorithms">checksum_algorithms()</a>, checksum_size = <a href="#type-pos_integer_64bit">pos_integer_64bit()</a>, position = non_neg_integer(), chunks = #{<a href="deps/cloudi_core/doc/cloudi_service.html#type-trans_id">cloudi_service:trans_id()</a> := #chunk{size = <a href="#type-pos_integer_64bit">pos_integer_64bit()</a>, position = <a href="#type-non_neg_integer_64bit">non_neg_integer_64bit()</a>, request = <a href="cloudi_service_queue.html#type-request">cloudi_service_queue:request()</a> | undefined, retries = non_neg_integer()}}, chunks_free = [#chunk{size = <a href="#type-pos_integer_64bit">pos_integer_64bit()</a>, position = <a href="#type-non_neg_integer_64bit">non_neg_integer_64bit()</a>, request = <a href="cloudi_service_queue.html#type-request">cloudi_service_queue:request()</a> | undefined, retries = non_neg_integer()}]}) -&gt; {<a href="cloudi_service_queue.html#type-request">cloudi_service_queue:request()</a> | undefined, #state{file = string(), file_size_limit = <a href="#type-pos_integer_64bit">pos_integer_64bit()</a>, compression = 0..9, checksum = undefined | <a href="#type-checksum_algorithms">checksum_algorithms()</a>, checksum_size = <a href="#type-pos_integer_64bit">pos_integer_64bit()</a>, position = non_neg_integer(), chunks = #{<a href="deps/cloudi_core/doc/cloudi_service.html#type-trans_id">cloudi_service:trans_id()</a> := #chunk{size = <a href="#type-pos_integer_64bit">pos_integer_64bit()</a>, position = <a href="#type-non_neg_integer_64bit">non_neg_integer_64bit()</a>, request = <a href="cloudi_service_queue.html#type-request">cloudi_service_queue:request()</a> | undefined, retries = non_neg_integer()}}, chunks_free = [#chunk{size = <a href="#type-pos_integer_64bit">pos_integer_64bit()</a>, position = <a href="#type-non_neg_integer_64bit">non_neg_integer_64bit()</a>, request = <a href="cloudi_service_queue.html#type-request">cloudi_service_queue:request()</a> | undefined, retries = non_neg_integer()}]}}</tt><br></p>
123 + <p><tt>update(ChunkId::<a href="deps/cloudi_core/doc/cloudi_service.html#type-trans_id">cloudi_service:trans_id()</a>, UpdateF::<a href="#type-update_function">update_function()</a>, State::#state{file = string(), file_size_limit = <a href="#type-pos_integer_64bit">pos_integer_64bit()</a>, compression = 0..9, checksum = undefined | <a href="#type-checksum_algorithms">checksum_algorithms()</a>, checksum_size = <a href="#type-pos_integer_64bit">pos_integer_64bit()</a>, position = non_neg_integer(), chunks = #{<a href="deps/cloudi_core/doc/cloudi_service.html#type-trans_id">cloudi_service:trans_id()</a> := #chunk{size = <a href="#type-pos_integer_64bit">pos_integer_64bit()</a>, position = <a href="#type-non_neg_integer_64bit">non_neg_integer_64bit()</a>, request = <a href="doc/cloudi_service_queue.html#type-request">cloudi_service_queue:request()</a> | undefined, retries = non_neg_integer()}}, chunks_free = [#chunk{size = <a href="#type-pos_integer_64bit">pos_integer_64bit()</a>, position = <a href="#type-non_neg_integer_64bit">non_neg_integer_64bit()</a>, request = <a href="doc/cloudi_service_queue.html#type-request">cloudi_service_queue:request()</a> | undefined, retries = non_neg_integer()}]}) -&gt; {<a href="doc/cloudi_service_queue.html#type-request">cloudi_service_queue:request()</a> | undefined, #state{file = string(), file_size_limit = <a href="#type-pos_integer_64bit">pos_integer_64bit()</a>, compression = 0..9, checksum = undefined | <a href="#type-checksum_algorithms">checksum_algorithms()</a>, checksum_size = <a href="#type-pos_integer_64bit">pos_integer_64bit()</a>, position = non_neg_integer(), chunks = #{<a href="deps/cloudi_core/doc/cloudi_service.html#type-trans_id">cloudi_service:trans_id()</a> := #chunk{size = <a href="#type-pos_integer_64bit">pos_integer_64bit()</a>, position = <a href="#type-non_neg_integer_64bit">non_neg_integer_64bit()</a>, request = <a href="doc/cloudi_service_queue.html#type-request">cloudi_service_queue:request()</a> | undefined, retries = non_neg_integer()}}, chunks_free = [#chunk{size = <a href="#type-pos_integer_64bit">pos_integer_64bit()</a>, position = <a href="#type-non_neg_integer_64bit">non_neg_integer_64bit()</a>, request = <a href="doc/cloudi_service_queue.html#type-request">cloudi_service_queue:request()</a> | undefined, retries = non_neg_integer()}]}}</tt><br></p>
124 124 <p> </p>
125 125 </div>
126 126 <hr>
  @@ -22,5 +22,5 @@
22 22 {<<"name">>,<<"cloudi_core">>},
23 23 {<<"optional">>,false},
24 24 {<<"repository">>,<<"hexpm">>},
25 - {<<"requirement">>,<<">= 2.0.4">>}]]}.
26 - {<<"version">>,<<"2.0.4">>}.
25 + {<<"requirement">>,<<">= 2.0.5">>}]]}.
26 + {<<"version">>,<<"2.0.5">>}.
Loading more files…