checkpoint() = ra_idxterm()
effect() = {monitor, process, snapshot_writer, pid()}
file_err() = ra_lib:file_err()
kind() = snapshot | checkpoint
meta() = snapshot_meta()
abstract datatype: state()
accept_chunk(Chunk::term(), Num::non_neg_integer(), ChunkFlag::chunk_flag(), State::state()) -> {ok, state()}
accepting(X1::state()) -> option(ra_idxterm())
begin_read(State::state(), Context::map()) -> {ok, Meta::meta(), ReadState} | {error, term()}
ReadState = term()
begin_snapshot(Meta::meta(), ReleaseCursorRef::term(), SnapKind::kind(), State::state()) -> {state(), [effect()]}
complete_snapshot(IdxTerm::ra_idxterm(), X2::kind(), State::state()) -> state()
context(X1::state(), Node::node()) -> map()
current(X1::state()) -> option(ra_idxterm())
current_snapshot_dir(X1::state()) -> option(file:filename())
delete(Dir, X2) -> any()
directory(X1::state(), X2::kind()) -> file:filename()
init(UId::ra_uid(), Module::module(), SnapshotsDir::file:filename(), CheckpointDir::file:filename(), Counter::undefined | counters:counters_ref(), MaxCheckpoints::pos_integer()) -> state()
init_ets() -> ok
last_index_for(UId::ra_uid()) -> option(ra_index())
latest_checkpoint(X1::state()) -> option(checkpoint())
pending(X1::state()) -> option({pid(), ra_idxterm(), kind()})
promote_checkpoint(Idx::ra_index(), State0::state()) -> {boolean(), State::state(), Effects::[effect()]}
read_chunk(ReadState, ChunkSizeBytes::non_neg_integer(), State::state()) -> {ok, Data::term(), {next, ReadState} | last} | {error, term()}
ReadState = term()
read_meta(Module::module(), Location::file:filename()) -> {ok, meta()} | {error, invalid_format | {invalid_version, integer()} | checksum_error | file_err() | term()}
recover(X1::state()) -> {ok, Meta::meta(), State::term()} | {error, no_current_snapshot} | {error, term()}
take_extra_checkpoints(State0::state()) -> {state(), [checkpoint()]}
take_older_checkpoints(Idx::ra_index(), State0::state()) -> {state(), [checkpoint()]}
Generated by EDoc