Overview
-
module A2A-
class AgentDSL wrapper that collects operation handlers for an A2A agent.
-
class HandlerInternal handler object produced by the #on DSL method.
-
class ContextExecution context for handler blocks.
-
module Bindings-
class JsonRpcRack middleware implementing the A2A JSON-RPC 2.0 protocol binding.
-
class RestRack middleware implementing the A2A HTTP+JSON/REST protocol binding.
-
-
class ClientAsync-HTTP based A2A protocol client.
-
eachJSON-RPC operations — each maps to a Proto operation name.
-
module ProtoParses the A2A protocol's .proto file to extract service operations
-
module SchemaSchema-validated A2A protocol objects, powered by json_schemer.
-
class DefinitionBase class for schema-validated A2A protocol objects.
-
class ValidationErrorRaised when a Definition instance fails schema validation.
-
class << self
-
-
class ServerRack application that exposes an A2A-compliant agent server.
-
class CancelTask -
class CreateTaskPushNotificationConfig -
class DeleteTaskPushNotificationConfig -
class DispatcherRoutes incoming A2A operations to registered handler objects.
-
class EnvRack middleware that injects shared A2A context into the env.
-
class GetExtendedAgentCard -
class GetTask -
class GetTaskPushNotificationConfig -
class ListTaskPushNotificationConfigs -
class ListTasks -
class SendMessage -
class SendStreamingMessage -
class SubscribeToTask -
class TriageRack middleware that resolves which A2A operation a request targets.
-
-
module SSE-
class JsonRpcStreamSSE stream that wraps each event in a JSON-RPC 2.0 response envelope.
-
class RestStreamSSE stream for the HTTP+JSON/REST binding.
-
class StreamAsync-native SSE body built on Protocol::HTTP::Body::Writable.
-
-
module Store-
class ProcessorAsync background task processor, modeled after async-job's Inline processor.
-
class PubSubFiber-safe pub/sub for task update streaming.
-
class SQLiteSQLite-backed task store with async pub/sub and webhook delivery.
-
class WebhooksAsync webhook delivery for A2A push notifications.
-
-
class TaskStoreIn-memory task registry with pub/sub for streaming and webhook delivery.
-
-
test -
Provider