umgeher/leveled
0
Fork 0
Code Issues Pull requests Releases Activity Actions

Tidy set_status

Browse source
This commit is contained in:
Martin Sumner 2018-02-16 20:56:12 +00:00
parent 090e414b23
commit fa532fbd27
1 changed files with 8 additions and 16 deletions
Download patch file Download diff file Expand all files Collapse all files

24
src/leveled_codec.erl
View file

@ -450,14 +450,7 @@ idx_indexspecs(IndexSpecs, Bucket, Key, SQN, TTL) ->
). ).
gen_indexspec(Bucket, Key, IdxOp, IdxField, IdxTerm, SQN, TTL) -> gen_indexspec(Bucket, Key, IdxOp, IdxField, IdxTerm, SQN, TTL) ->
Status = Status = set_status(IdxOp, TTL),
case IdxOp of
add ->
{active, TTL};
remove ->
%% TODO: timestamps for delayed reaping
tomb
end,
case Bucket of case Bucket of
{all, RealBucket} -> {all, RealBucket} ->
{to_ledgerkey(?ALL_BUCKETS, {to_ledgerkey(?ALL_BUCKETS,
@ -476,18 +469,17 @@ gen_indexspec(Bucket, Key, IdxOp, IdxField, IdxTerm, SQN, TTL) ->
end. end.
gen_headspec(Bucket, Key, IdxOp, SubKey, Value, SQN, TTL) -> gen_headspec(Bucket, Key, IdxOp, SubKey, Value, SQN, TTL) ->
Status = Status = set_status(IdxOp, TTL),
case IdxOp of
add ->
{active, TTL};
remove ->
%% TODO: timestamps for delayed reaping
tomb
end,
K = to_ledgerkey(Bucket, {Key, SubKey}, ?HEAD_TAG), K = to_ledgerkey(Bucket, {Key, SubKey}, ?HEAD_TAG),
{K, {SQN, Status, segment_hash(K), Value}}. {K, {SQN, Status, segment_hash(K), Value}}.
set_status(add, TTL) ->
{active, TTL};
set_status(remove, _TTL) ->
%% TODO: timestamps for delayed reaping
tomb.
-spec aae_indexspecs(false|recent_aae(), -spec aae_indexspecs(false|recent_aae(),
any(), any(), any(), any(),
integer(), integer(), integer(), integer(),