Module dev_process_cache.erl¶
A wrapper around the hb_cache module that provides a more convenient interface for reading the result of a process at a given slot or message ID.
Function Index¶
| find_latest_outputs/1* | Test for retrieving the latest computed output for a process. |
| first_with_path/4* | Find the latest assignment with the requested path suffix. |
| first_with_path/5* | |
| latest/2 | Retrieve the latest slot for a given process. |
| latest/3 | |
| latest/4 | |
| path/3* | Calculate the path of a result, given a process ID and a slot. |
| path/4* | |
| process_cache_suite_test_/0* | |
| read/2 | Read the result of a process at a given slot. |
| read/3 | |
| test_write_and_read_output/1* | Test for writing multiple computed outputs, then getting them by their slot number and by their signed and unsigned IDs. |
| write/4 | Write a process computation result to the cache. |
Function Details¶
find_latest_outputs/1 *¶
find_latest_outputs(Opts) -> any()
Test for retrieving the latest computed output for a process.
first_with_path/4 *¶
first_with_path(ProcID, RequiredPath, Slots, Opts) -> any()
Find the latest assignment with the requested path suffix.
first_with_path/5 *¶
first_with_path(ProcID, Required, Rest, Opts, Store) -> any()
latest/2¶
latest(ProcID, Opts) -> any()
Retrieve the latest slot for a given process. Optionally state a limit on the slot number to search for, as well as a required path that the slot must have.
latest/3¶
latest(ProcID, RequiredPath, Opts) -> any()
latest/4¶
latest(ProcID, RawRequiredPath, Limit, Opts) -> any()
path/3 *¶
path(ProcID, Ref, Opts) -> any()
Calculate the path of a result, given a process ID and a slot.
path/4 *¶
path(ProcID, Ref, PathSuffix, Opts) -> any()
process_cache_suite_test_/0 *¶
process_cache_suite_test_() -> any()
read/2¶
read(ProcID, Opts) -> any()
Read the result of a process at a given slot.
read/3¶
read(ProcID, SlotRef, Opts) -> any()
test_write_and_read_output/1 *¶
test_write_and_read_output(Opts) -> any()
Test for writing multiple computed outputs, then getting them by their slot number and by their signed and unsigned IDs.
write/4¶
write(ProcID, Slot, Msg, Opts) -> any()
Write a process computation result to the cache.