Embabel Agent Documentation/com.embabel.agent.a2a.server.support

Package-level declarations

Types

class A2AEndpointRegistrar(agentCardHandlers: List<AgentCardHandler>, requestMappingHandlerMapping: <Error class: unknown class>, objectMapper: <Error class: unknown class>)

Registers A2A endpoints for the agent-to-agent communication protocol. Each AgentCardHandler passed in results in the creation of a distinct endpoint with its own agent card.

A2AStreamingHandler

class A2AStreamingHandler(objectMapper: <Error class: unknown class>, taskStateManager: TaskStateManager)

Handles streaming functionality for A2A messages

AutonomyA2ARequestHandler

class AutonomyA2ARequestHandler(autonomy: Autonomy, agenticEventListener: AgenticEventListener, streamingHandler: A2AStreamingHandler) : A2ARequestHandler

Handle A2A messages according to the A2A protocol. Doesn't dictate mapping to URLs: a router or controller in front of this class must handle that.

EmbabelServerGoalsAgentCardHandler

class EmbabelServerGoalsAgentCardHandler(val path: String = DEFAULT_A2A_PATH, agentPlatform: AgentPlatform, a2ARequestHandler: A2ARequestHandler, goalFilter: GoalFilter) : AgentCardHandler, A2ARequestHandler

Expose one agent card for the whole server.

FromGoalsAgentSkillFactory

class FromGoalsAgentSkillFactory(goals: Set<Goal>) : AgentSkillFactory

Expose a skill for every goal defined in the agent platform.

GoalFilter

typealias GoalFilter = (Goal) -> Boolean

ResubscribeTaskRequest

data class ResubscribeTaskRequest(val jsonrpc: String = "2.0", val id: Any?, val method: String = METHOD, val params: <Error class: unknown class>)

Request to resubscribe to a task's streaming updates. This allows clients to resume receiving updates for a task after a connection interruption.

TaskStateManager

class TaskStateManager

Manages task state and history for streaming and resubscription support. Tracks active tasks, completed tasks, and their event history.

Properties

DEFAULT_A2A_PATH

const val DEFAULT_A2A_PATH: String

Functions

successResponseWith

fun <Error class: unknown class>.successResponseWith(result: <Error class: unknown class>): <Error class: unknown class>