adk_eval_service (erlang_adk v0.10.0)

View Source

Supervised, bounded evaluation-job service.

The service owns scheduling while an adk_eval_store owns immutable sets, lifecycle state, terminal results, and baselines. Runtime adapter handles remain only in this process and supervised task workers; they are never persisted. After a service restart, previously queued/running jobs are deterministically marked failed instead of being silently replayed.

Summary

Functions

cancel(Service, Scope, JobId)
capabilities(Service)
child_spec(Options)
code_change(OldVersion, State, Extra)
format_status(Status)
get_baseline(Service, Scope, Name)
get_set(Service, Scope, Id, Version)
handle_call(Request, From, State)
handle_cast(Message, State)
handle_info(Message, State0)
init(Options0)
list_jobs(Service, Scope, Options)
list_sets(Service, Scope, Options)
prune(Service, Scope, Options)
put_baseline(Service, Scope, Name, JobId)
result(Service, Scope, JobId)
start_link(Options)
status(Service, Scope, JobId)
stop(Service)
submit(Service, Scope, Request)
terminate(Reason, State)

Functions

cancel(Service, Scope, JobId)

-spec cancel(gen_server:server_ref(), adk_eval_store:scope(), binary()) -> ok | {error, term()}.

capabilities(Service)

-spec capabilities(gen_server:server_ref()) -> {ok, map()} | {error, term()}.

child_spec(Options)

-spec child_spec(map()) -> supervisor:child_spec().

code_change(OldVersion, State, Extra)

format_status(Status)

get_baseline(Service, Scope, Name)

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

get_set(Service, Scope, Id, Version)

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

handle_call(Request, From, State)

handle_cast(Message, State)

handle_info(Message, State0)

init(Options0)

list_jobs(Service, Scope, Options)

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

list_sets(Service, Scope, Options)

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

prune(Service, Scope, Options)

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

put_baseline(Service, Scope, Name, JobId)

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

result(Service, Scope, JobId)

-spec result(gen_server:server_ref(), adk_eval_store:scope(), binary()) -> {ok, map()} | {error, term()}.

start_link(Options)

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

status(Service, Scope, JobId)

-spec status(gen_server:server_ref(), adk_eval_store:scope(), binary()) -> {ok, map()} | {error, term()}.

stop(Service)

-spec stop(gen_server:server_ref()) -> ok.

submit(Service, Scope, Request)

-spec submit(gen_server:server_ref(), adk_eval_store:scope(), map()) -> {ok, map()} | {error, term()}.

terminate(Reason, State)