Overview

• module A2A
  • class Agent

    DSL wrapper that collects operation handlers for an A2A agent.

    • class Handler

      Internal handler object produced by the #on DSL method.
    • class Context

      Execution context for handler blocks.
  • module Bindings
    • class JsonRpc

      Rack middleware implementing the A2A JSON-RPC 2.0 protocol binding.
    • class Rest

      Rack middleware implementing the A2A HTTP+JSON/REST protocol binding.
  • class Client

    Async-HTTP based A2A protocol client.

    • each

      JSON-RPC operations — each maps to a Proto operation name.

      • define_method
  • module Proto

    Parses the A2A protocol's .proto file to extract service operations

    • class Operation
    • class << self
  • module Schema

    Schema-validated A2A protocol objects, powered by json_schemer.

    • class Definition

      Base class for schema-validated A2A protocol objects.
    • class ValidationError

      Raised when a Definition instance fails schema validation.
    • class << self
  • class Server

    Rack application that exposes an A2A-compliant agent server.

    • class CancelTask
    • class CreateTaskPushNotificationConfig
    • class DeleteTaskPushNotificationConfig
    • class Dispatcher

      Routes incoming A2A operations to registered handler objects.
    • class Env

      Rack 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 Triage

      Rack middleware that resolves which A2A operation a request targets.
  • module SSE
    • class JsonRpcStream

      SSE stream that wraps each event in a JSON-RPC 2.0 response envelope.
    • class RestStream

      SSE stream for the HTTP+JSON/REST binding.
    • class Stream

      Async-native SSE body built on Protocol::HTTP::Body::Writable.
  • module Store
    • class Processor

      Async background task processor, modeled after async-job's Inline processor.
    • class PubSub

      Fiber-safe pub/sub for task update streaming.
    • class SQLite

      SQLite-backed task store with async pub/sub and webhook delivery.
    • class Webhooks

      Async webhook delivery for A2A push notifications.
  • class TaskStore

    In-memory task registry with pub/sub for streaming and webhook delivery.
• test
  • describe
    • it
      • Sync
  • each
    • it
  • it
    • each
• Provider