adk_memory_sharded (erlang_adk v0.7.0)

View Source

Bounded exact-user-scope version-2 memory adapter.

Each {user, App, User} principal is assigned one supervised adapter process. The default is volatile ETS; adk_memory_mnesia may be selected for durable storage while retaining independent per-scope call execution.

Summary

Functions

add_entry(Handle, Scope, Input, Options)
add_entry(Handle, Scope, Input, Options, CallOptions)
add_events(Handle, Scope, SessionId, Events, Options)
add_events(Handle, Scope, SessionId, Events, Options, CallOptions)
add_session_to_memory(Handle, Scope, SessionId, Events, Options)
capabilities(Handle)
delete_entry(Handle, Scope, Id)
delete_entry(Handle, Scope, Id, CallOptions)
delete_session(Handle, Scope, SessionId)
delete_session(Handle, Scope, SessionId, CallOptions)
delete_user(Handle, Scope)
delete_user(Handle, Scope, CallOptions)
search(Handle, Scope, Query, Options)
search(Handle, Scope, Query, Options, CallOptions)
start_link(Config)
status(Handle)
stop(Handle)

Functions

add_entry(Handle, Scope, Input, Options)

-spec add_entry(term(), adk_memory_service:scope(), adk_memory_service:entry_input(), map()) ->
                   {ok, adk_memory_service:entry()} | {error, term()}.

add_entry(Handle, Scope, Input, Options, CallOptions)

-spec add_entry(term(),
                adk_memory_service:scope(),
                adk_memory_service:entry_input(),
                map(),
                adk_memory_service:call_options()) ->
                   {ok, adk_memory_service:entry()} | {error, term()}.

add_events(Handle, Scope, SessionId, Events, Options)

-spec add_events(term(), adk_memory_service:scope(), binary(), [adk_event:event()], map()) ->
                    {ok, adk_memory_service:ingest_result()} | {error, term()}.

add_events(Handle, Scope, SessionId, Events, Options, CallOptions)

-spec add_events(term(),
                 adk_memory_service:scope(),
                 binary(),
                 [adk_event:event()],
                 map(),
                 adk_memory_service:call_options()) ->
                    {ok, adk_memory_service:ingest_result()} | {error, term()}.

add_session_to_memory(Handle, Scope, SessionId, Events, Options)

-spec add_session_to_memory(term(), adk_memory_service:scope(), binary(), [adk_event:event()], map()) ->
                               {ok, adk_memory_service:ingest_result()} | {error, term()}.

capabilities(Handle)

-spec capabilities(term()) -> map() | {error, term()}.

delete_entry(Handle, Scope, Id)

-spec delete_entry(term(), adk_memory_service:scope(), binary()) -> ok | {error, term()}.

delete_entry(Handle, Scope, Id, CallOptions)

-spec delete_entry(term(), adk_memory_service:scope(), binary(), adk_memory_service:call_options()) ->
                      ok | {error, term()}.

delete_session(Handle, Scope, SessionId)

-spec delete_session(term(), adk_memory_service:scope(), binary()) -> ok | {error, term()}.

delete_session(Handle, Scope, SessionId, CallOptions)

-spec delete_session(term(), adk_memory_service:scope(), binary(), adk_memory_service:call_options()) ->
                        ok | {error, term()}.

delete_user(Handle, Scope)

-spec delete_user(term(), adk_memory_service:scope()) -> ok | {error, term()}.

delete_user(Handle, Scope, CallOptions)

-spec delete_user(term(), adk_memory_service:scope(), adk_memory_service:call_options()) ->
                     ok | {error, term()}.

search(Handle, Scope, Query, Options)

-spec search(term(), adk_memory_service:scope(), adk_memory_service:query(), map()) ->
                {ok, [adk_memory_service:hit()]} | {error, term()}.

search(Handle, Scope, Query, Options, CallOptions)

-spec search(term(),
             adk_memory_service:scope(),
             adk_memory_service:query(),
             map(),
             adk_memory_service:call_options()) ->
                {ok, [adk_memory_service:hit()]} | {error, term()}.

start_link(Config)

-spec start_link(map()) -> {ok, adk_scope_shard_router:handle()} | {error, term()}.

status(Handle)

-spec status(term()) -> {ok, map()} | {error, term()}.

stop(Handle)

-spec stop(term()) -> ok | {error, term()}.