Current section

Files

Jump to
bravo src bravo@oset.erl
Raw

src/bravo@oset.erl

-module(bravo@oset).
-compile([no_auto_import, nowarn_unused_vars, nowarn_unused_function, nowarn_nomatch]).
-export([new/3, insert/2, insert_obj/2, lookup/2, delete/1]).
-export_type([o_set/0]).
-opaque o_set() :: {o_set, gleam@erlang@atom:atom_(), integer()}.
-spec new(binary(), integer(), bravo@etc:access()) -> {ok, o_set()} |
{error, gleam@option:option(bravo@error:erlang_error())}.
new(Name, Keypos, Access) ->
Atom = erlang:binary_to_atom(Name),
gleam@bool:guard(
Keypos < 1,
{error, none},
fun() ->
gleam@result:'try'(
begin
_pipe = bravo:try_new(Atom, [ordered_set, case Access of
public ->
public;
protected ->
protected;
private ->
private
end, named_table, {keypos, Keypos}, {write_concurrency,
auto}, {read_concurrency, true}, {decentralized_counters,
true}]),
gleam@result:map_error(_pipe, fun(E) -> {some, E} end)
end,
fun(A) -> {ok, {o_set, A, Keypos}} end
)
end
).
-spec insert(o_set(), list(any())) -> boolean().
insert(Oset, Objects) ->
bravo:try_insert(erlang:element(2, Oset), erlang:element(3, Oset), Objects).
-spec insert_obj(o_set(), list(bravo@object:object(any()))) -> boolean().
insert_obj(Oset, Objects) ->
_pipe = gleam@list:map(Objects, fun bravo@object:extract/1),
insert(Oset, _pipe).
-spec lookup(o_set(), any()) -> gleam@option:option(bravo@object:object(gleam@dynamic:dynamic_())).
lookup(Oset, Key) ->
case bravo:try_lookup(erlang:element(2, Oset), Key) of
[Res] ->
{some, bravo@object:new(Res)};
_ ->
none
end.
-spec delete(o_set()) -> boolean().
delete(Oset) ->
bravo:try_delete(erlang:element(2, Oset)).