server#

async baf.platforms.a2a.server.a2a_handler(request)[source]#

Handle the incoming HTTP request, from the agent_id, check if agent and platform are valid and the request to the http handler

async baf.platforms.a2a.server.add_peer(request)[source]#
baf.platforms.a2a.server.create_app(platform=None, registry=None)[source]#

Run the platform

async baf.platforms.a2a.server.get_agent_card_by_id(request)[source]#

Get the agent card by providing the corresponding agent’s agent id (agent id is provided as a parameter in request)

baf.platforms.a2a.server.get_agent_id_platform(request)[source]#

Get the platform which the agent is registered

async baf.platforms.a2a.server.get_list_of_agents(request)[source]#

Get list of agents present in the endpoint’s registry

async baf.platforms.a2a.server.get_task_status_in_agent(request)[source]#

Get list of tasks present in the platform/agent

async baf.platforms.a2a.server.list_peers(request)[source]#
async baf.platforms.a2a.server.sse_event_handler(request)[source]#

Handle the incoming SSE request, and stream the status continuously