adk_a2a_v1_client (erlang_adk v0.10.0)

View Source

Bounded outbound client for the A2A 1.0 JSON-RPC binding.

The client discovers and validates the Agent Card before selecting the first JSONRPC/1.0 interface. Authentication headers are obtained just-in-time from auth_fun; they are never retained in returned values or error terms.

Summary

Functions

cancel_task(Target, TaskId, Options)
create_push_config(Target, Config, Options)
delete_push_config(Target, TaskId, ConfigId, Options)
discover(Location)
discover(Location, Options0)
get_extended_card(Target, Options)
get_push_config(Target, TaskId, ConfigId, Options)
get_task(Target, TaskId, Options)
list_push_configs(Target, Params, Options)
list_tasks(Target, Params, Options)
send(Target, Message, Options)
send_stream(Target, Message, Options)
send_stream(Target, Message, Options, Callback)
subscribe(Target, TaskId, Options)
subscribe(Target, TaskId, Options, Callback)

Functions

cancel_task(Target, TaskId, Options)

-spec cancel_task(map() | binary() | string(), binary(), map()) -> {ok, map()} | {error, term()}.

create_push_config(Target, Config, Options)

-spec create_push_config(map() | binary() | string(), map(), map()) -> {ok, map()} | {error, term()}.

delete_push_config(Target, TaskId, ConfigId, Options)

-spec delete_push_config(map() | binary() | string(), binary(), binary(), map()) ->
                            {ok, map()} | {error, term()}.

discover(Location)

-spec discover(binary() | string()) -> {ok, map()} | {error, term()}.

discover(Location, Options0)

-spec discover(binary() | string(), map()) -> {ok, map()} | {error, term()}.

get_extended_card(Target, Options)

-spec get_extended_card(map() | binary() | string(), map()) -> {ok, map()} | {error, term()}.

get_push_config(Target, TaskId, ConfigId, Options)

-spec get_push_config(map() | binary() | string(), binary(), binary(), map()) ->
                         {ok, map()} | {error, term()}.

get_task(Target, TaskId, Options)

-spec get_task(map() | binary() | string(), binary(), map()) -> {ok, map()} | {error, term()}.

list_push_configs(Target, Params, Options)

-spec list_push_configs(map() | binary() | string(), map(), map()) -> {ok, map()} | {error, term()}.

list_tasks(Target, Params, Options)

-spec list_tasks(map() | binary() | string(), map(), map()) -> {ok, map()} | {error, term()}.

send(Target, Message, Options)

-spec send(map() | binary() | string(), map(), map()) -> {ok, map()} | {error, term()}.

send_stream(Target, Message, Options)

-spec send_stream(map() | binary() | string(), map(), map()) -> {ok, [map()]} | {error, term()}.

send_stream(Target, Message, Options, Callback)

-spec send_stream(map() | binary() | string(),
                  map(),
                  map(),
                  fun((map()) -> continue | stop | {error, term()})) ->
                     ok | {error, term()}.

subscribe(Target, TaskId, Options)

-spec subscribe(map() | binary() | string(), binary(), map()) -> {ok, [map()]} | {error, term()}.

subscribe(Target, TaskId, Options, Callback)

-spec subscribe(map() | binary() | string(),
                binary(),
                map(),
                fun((map()) -> continue | stop | {error, term()})) ->
                   ok | {error, term()}.