Module ra_log_reader

Data Types

segment_ref()

segment_ref() = {From::ra_index(), To::ra_index(), File::string()}

state()

abstract datatype: state()

Function Index

close/1
fetch_term/2
handle_log_update/2
init/4
init/5
num_open_segments/1
read/3
read/4
segment_refs/1
update_first_index/2
update_segments/2

Function Details

close/1

close(X1::state()) -> ok

fetch_term/2

fetch_term(Idx::ra_index(), State0::state()) -> {ra_index(), state()}

handle_log_update/2

handle_log_update(X1::{ra_log_update, undefined | pid(), ra_index(), [segment_ref()]}, State::state()) -> state()

init/4

init(UId::ra_uid(), FirstIdx::ra_index(), MaxOpen::non_neg_integer(), SegRefs::[segment_ref()]) -> state()

init/5

init(UId::ra_uid(), FirstIdx::ra_index(), MaxOpen::non_neg_integer(), SegRefs::[segment_ref()], Counter::undefined | counters:counters_ref()) -> state()

num_open_segments/1

num_open_segments(X1::state()) -> non_neg_integer()

read/3

read(From::ra_index(), To::ra_index(), State::state()) -> {[log_entry()], NumRead::non_neg_integer(), state()}

read/4

read(From::ra_index(), To::ra_index(), State::state(), Entries::[log_entry()]) -> {[log_entry()], NumRead::non_neg_integer(), state()}

segment_refs/1

segment_refs(X1::state()) -> [segment_ref()]

update_first_index/2

update_first_index(Idx::ra_index(), State::state()) -> {state(), [segment_ref()]}

update_segments/2

update_segments(NewSegmentRefs::[segment_ref()], State::state()) -> state()


Generated by EDoc