adk_eval_store_ets (erlang_adk v0.10.0)

View Source

Bounded in-memory implementation of adk_eval_store.

Summary

Functions

capabilities(Store)
code_change(OldVersion, State, Extra)
create_evaluation(Store, Scope, Set, Job)
create_job(Store, Scope, Job)
format_status(Status)
get_baseline(Store, Scope, Name)
get_job(Store, Scope, JobId)
get_set(Store, Scope, Id, Version)
handle_call(Request, From, State)
handle_cast(Message, State)
handle_continue(_, State0)
handle_info(Message, State)
init(Config)
list_jobs(Store, Scope, Options)
list_sets(Store, Scope, Options)
ownership_identity(Store)
prune(Store, Scope, Options)
put_baseline(Store, Scope, Name, JobId)
put_set(Store, Scope, Set)
recover_active(Store, Reason)
start_link(Config)
stop(Store)
terminate(Reason, State)
transition_job(Store, Scope, JobId, Expected, Phase, Patch)

Functions

capabilities(Store)

-spec capabilities(pid()) -> map().

code_change(OldVersion, State, Extra)

create_evaluation(Store, Scope, Set, Job)

-spec create_evaluation(pid(), adk_eval_store:scope(), map(), map()) -> {ok, map()} | {error, term()}.

create_job(Store, Scope, Job)

-spec create_job(pid(), adk_eval_store:scope(), map()) -> {ok, map()} | {error, term()}.

format_status(Status)

get_baseline(Store, Scope, Name)

-spec get_baseline(pid(), adk_eval_store:scope(), binary()) -> {ok, map()} | {error, term()}.

get_job(Store, Scope, JobId)

-spec get_job(pid(), adk_eval_store:scope(), binary()) -> {ok, map()} | {error, term()}.

get_set(Store, Scope, Id, Version)

-spec get_set(pid(), adk_eval_store:scope(), binary(), binary()) -> {ok, map()} | {error, term()}.

handle_call(Request, From, State)

handle_cast(Message, State)

handle_continue(_, State0)

handle_info(Message, State)

init(Config)

list_jobs(Store, Scope, Options)

-spec list_jobs(pid(), adk_eval_store:scope(), map()) -> {ok, map()} | {error, term()}.

list_sets(Store, Scope, Options)

-spec list_sets(pid(), adk_eval_store:scope(), map()) -> {ok, map()} | {error, term()}.

ownership_identity(Store)

-spec ownership_identity(term()) -> {ok, term()} | defer.

prune(Store, Scope, Options)

-spec prune(pid(), adk_eval_store:scope(), map()) -> {ok, map()} | {error, term()}.

put_baseline(Store, Scope, Name, JobId)

-spec put_baseline(pid(), adk_eval_store:scope(), binary(), binary()) -> {ok, map()} | {error, term()}.

put_set(Store, Scope, Set)

-spec put_set(pid(), adk_eval_store:scope(), map()) -> {ok, map()} | {error, term()}.

recover_active(Store, Reason)

-spec recover_active(pid(), binary()) -> {ok, non_neg_integer()} | {error, term()}.

start_link(Config)

-spec start_link(map()) -> gen_server:start_ret().

stop(Store)

-spec stop(pid()) -> ok.

terminate(Reason, State)

transition_job(Store, Scope, JobId, Expected, Phase, Patch)

-spec transition_job(pid(), adk_eval_store:scope(), binary(), [atom()], atom(), map()) ->
                        {ok, map()} | {error, term()}.