a2a

type AdapterEventMetaV1 struct {
	// RunID is the adaptor-assigned run identifier.
	RunID string `json:"run_id,omitempty"`
	// ThreadKey is the host-visible adaptor Thread key.
	ThreadKey string `json:"thread_key,omitempty"`
	// Sequence is the adaptor-assigned receive-order sequence.
	Sequence uint64 `json:"sequence,omitempty"`
	// Time is the adaptor event time formatted as RFC 3339 with nanoseconds.
	Time string `json:"time,omitempty"`
	// TurnID identifies the provider turn when available.
	TurnID string `json:"turn_id,omitempty"`
	// Source contains provider-reported coordinates when metadata exposure is
	// enabled.
	Source *AdapterEventSourceMetaV1 `json:"source,omitempty"`
}

type AdapterEventSourceMetaV1 struct {
	// RunID is the provider-reported run identifier.
	RunID string `json:"run_id,omitempty"`
	// ThreadID is the provider-reported thread identifier.
	ThreadID string `json:"thread_id,omitempty"`
	// TurnID is the provider-reported turn identifier.
	TurnID string `json:"turn_id,omitempty"`
	// Sequence is the provider-reported sequence.
	Sequence uint64 `json:"sequence,omitempty"`
	// Timestamp is the provider-reported time formatted as RFC 3339 with
	// nanoseconds.
	Timestamp string `json:"timestamp,omitempty"`
}

type AdapterStreamEnvelopeV1 struct {
	// Schema is always [AdapterStreamSchemaV1].
	Schema string `json:"schema"`
	// Event contains one projected adaptor Event.
	Event AdapterStreamEventV1 `json:"event"`
}

type AdapterStreamEventV1 struct {
	// Kind identifies the event shape, such as text.content, tool_call.result,
	// hitl.requested, or stream.dropped.
	Kind string `json:"kind"`
	// Sequence is the flattened event sequence retained for v1 wire
	// compatibility.
	Sequence uint64 `json:"sequence,omitempty"`
	// RunID is the flattened run identifier retained for v1 wire compatibility.
	RunID string `json:"run_id,omitempty"`
	// ThreadID is the flattened thread coordinate retained for v1 wire
	// compatibility. It prefers the host Thread key and otherwise carries the
	// provider lifecycle thread identifier.
	ThreadID string `json:"thread_id,omitempty"`
	// TurnID identifies the provider turn, when reported.
	TurnID string `json:"turn_id,omitempty"`
	// MessageID identifies a text or reasoning message.
	MessageID string `json:"message_id,omitempty"`
	// ToolCallID identifies a tool call or approval-associated tool call.
	ToolCallID string `json:"tool_call_id,omitempty"`
	// Name is the tool name for tool-call events.
	Name string `json:"name,omitempty"`
	// Delta contains incremental text or tool arguments.
	Delta string `json:"delta,omitempty"`
	// Args contains a complete structured tool argument snapshot when available.
	Args map[string]any `json:"args,omitempty"`
	// Result contains a structured tool result snapshot when available.
	Result map[string]any `json:"result,omitempty"`
	// Role identifies the text message role.
	Role string `json:"role,omitempty"`
	// Timestamp is the flattened RFC 3339 event time retained for v1 wire
	// compatibility.
	Timestamp string `json:"timestamp,omitempty"`
	// HITL contains the approval request or resolution payload.
	HITL map[string]any `json:"hitl,omitempty"`
	// Raw contains event-specific diagnostic fields, including Dropped details.
	Raw map[string]any `json:"raw,omitempty"`
	// Meta is the adaptor-owned event metadata envelope.
	Meta *AdapterEventMetaV1 `json:"meta,omitempty"`
}

type AgentCard struct {
	// Name is the human-readable agent name.
	Name string
	// Description explains the agent's purpose and supported use cases.
	Description string
	// URL is the default JSON-RPC endpoint and the fallback URL for interface
	// entries whose URL is empty.
	URL string
	// Version identifies the implementation version advertised by the agent.
	Version string
	// DocumentationURL points callers to human-readable agent documentation.
	DocumentationURL string
	// IconURL points callers to an icon representing the agent.
	IconURL string
	// Provider identifies the organization operating the agent, when known.
	Provider *Provider
	// Capabilities declares optional protocol behavior and extensions.
	Capabilities Capabilities
	// DefaultInputModes lists accepted media types. An empty slice defaults to
	// text/plain.
	DefaultInputModes []string
	// DefaultOutputModes lists produced media types. An empty slice defaults to
	// text/plain.
	DefaultOutputModes []string
	// Skills advertises the agent's supported tasks.
	Skills []Skill
	// Interfaces lists supported protocol endpoints. When empty, URL is exposed
	// as a single JSON-RPC interface.
	Interfaces []AgentInterface
	// SecuritySchemes declares named authentication schemes referenced by
	// Security.
	SecuritySchemes []SecurityScheme
	// Security lists alternative authentication requirements. Schemes within
	// one requirement are all required; separate entries are alternatives.
	Security []SecurityRequirement
}

type AgentInterface struct {
	// URL is the endpoint for this interface. An empty value falls back to
	// AgentCard.URL.
	URL string
	// ProtocolBinding is the A2A transport protocol identifier. An empty value
	// defaults to JSON-RPC.
	ProtocolBinding string
	// Tenant identifies a tenant-specific endpoint, when applicable.
	Tenant string
	// ProtocolVersion overrides the A2A protocol version for this interface.
	ProtocolVersion string
}

type ArtifactSpec struct {
	// ID is the artifact identifier. When empty, Name is used; at least one of
	// ID and Name must be non-empty.
	ID string
	// Name is the artifact's machine-readable name.
	Name string
	// Description explains the artifact to callers.
	Description string
	// Parts contains the artifact content in source order.
	Parts []Part
	// Extensions contains extension URIs used by the artifact.
	Extensions []string
	// Metadata contains artifact-level A2A metadata.
	Metadata map[string]any
}

type BuiltResult struct {
	// StatusText overrides the final completed status message. Nil preserves
	// Result.Text; a pointer to an empty string deliberately emits empty text.
	StatusText *string
	// ReplaceDefaultArtifacts suppresses the bridge-owned terminal artifact.
	ReplaceDefaultArtifacts bool
	// Artifacts contains custom terminal artifacts in emission order.
	Artifacts []ArtifactSpec
}

type Capabilities struct {
	// Streaming controls SendStreamingMessage support.
	Streaming CapabilityMode
	// PushNotifications advertises push-notification support. Enabling it
	// requires matching [PushNotificationSupport] in [ServerOptions].
	PushNotifications bool
	// ExtendedAgentCard advertises the authenticated extended-card endpoint.
	// Enabling it requires matching [ExtendedAgentCardSupport] in
	// [ServerOptions].
	ExtendedAgentCard bool
	// Extensions declares additional protocol extensions. NewServer always
	// appends the bridge's adapter.stream.v1 extension.
	Extensions []Extension
}

type CapabilityMode uint8

type DiagnosticsPolicy struct {
	// IncludeMetadata exposes Result metadata, RunError details, and provider
	// source coordinates on streamed events.
	IncludeMetadata bool
	// IncludeUsage exposes observed token usage. Unobserved usage remains
	// omitted; an observed zero value is preserved.
	IncludeUsage bool
	// IncludeProviderResult exposes the provider's validated terminal payload.
	IncludeProviderResult bool
	// IncludeTranscript exposes normalized transcript entries.
	IncludeTranscript bool
	// IncludeRawStreams exposes captured process stdout and stderr.
	IncludeRawStreams bool
	// IncludeHITLPayloads exposes structured approval request details and
	// choices.
	IncludeHITLPayloads bool
	// IncludeHITLRaw exposes raw approval data carried by approval notices.
	IncludeHITLRaw bool
}

type EphemeralTaskStoreOptions struct {
	// MaxTasks is the maximum retained task count. Oldest tasks are evicted
	// first when the limit is exceeded.
	MaxTasks int
	// TTL is the maximum time since the latest update before a task expires.
	TTL time.Duration
}

type ExposurePolicy struct {
	// IncludeReasoning exposes thinking events in streaming status updates.
	IncludeReasoning bool
	// IncludeToolCalls exposes tool-call and tool-result events in streaming
	// status updates.
	IncludeToolCalls bool
	// IncludeHITL exposes approval lifecycle events. Approval payloads remain
	// gated by Diagnostics.
	IncludeHITL bool

	// Diagnostics controls additional, sanitized diagnostic fields.
	Diagnostics DiagnosticsPolicy
}

type ExtendedAgentCardProvider interface {
	// ExtendedCard returns the Agent Card visible to the request's tenant.
	ExtendedCard(ctx context.Context, req ExtendedAgentCardRequest) (AgentCard, error)
}

type ExtendedAgentCardProviderFunc func(context.Context, ExtendedAgentCardRequest) (AgentCard, error)

type ExtendedAgentCardRequest struct {
	// Tenant is the tenant identifier from the A2A request, when present.
	Tenant string
}

type ExtendedAgentCardSupport struct {
	// Static is the same extended card for every authenticated caller.
	Static *AgentCard
	// Provider builds an extended card for each request.
	Provider ExtendedAgentCardProvider
}

type Extension struct {
	// URI is the globally unique extension identifier.
	URI string
	// Description explains the extension to clients.
	Description string
	// Required reports whether clients must understand the extension to
	// interact with the agent.
	Required bool
	// Params contains extension-specific, JSON-compatible parameters.
	Params map[string]any
}

type InboundRequest struct {
	// TaskID is the A2A task identifier.
	TaskID string
	// ContextID is the A2A conversation context identifier.
	ContextID string
	// Message is the submitted user message.
	Message Message
	// Metadata contains request-level A2A metadata.
	Metadata map[string]any
}

type Message struct {
	// ID is the message identifier.
	ID string
	// Role is the A2A message role value.
	Role string
	// TaskID is the task associated with the message.
	TaskID string
	// ContextID is the conversation context associated with the message.
	ContextID string
	// Parts contains the message content in source order.
	Parts []Part
	// ReferenceTasks contains identifiers of tasks referenced by the message.
	ReferenceTasks []string
	// Extensions contains extension URIs used by the message.
	Extensions []string
	// Metadata contains message-level A2A metadata.
	Metadata map[string]any
}

type Part struct {
	// Kind identifies which payload field is active.
	Kind PartKind
	// Text contains a PartText payload.
	Text string
	// Raw contains a PartRaw payload.
	Raw []byte
	// Data contains a JSON-compatible PartData payload.
	Data any
	// URL contains a PartURL payload.
	URL string
	// MediaType identifies the payload's media type.
	MediaType string
	// Filename is the suggested file name for raw or URL payloads.
	Filename string
	// Metadata contains part-level A2A metadata.
	Metadata map[string]any
}

type PartKind string

type PromptBuilder func(ctx context.Context, req InboundRequest) (prompt string, opts []adaptor.CallOption, err error)

type Provider struct {
	// Organization is the provider's display name.
	Organization string
	// URL is the provider's website or information endpoint.
	URL string
}

type PushNotificationSupport struct {
	// Store persists caller push-notification configurations.
	Store push.ConfigStore
	// Sender delivers task updates to configured endpoints.
	Sender push.Sender
}

type ResultBuilder func(ctx context.Context, req InboundRequest, result *adaptor.Result) (BuiltResult, error)

type SecurityRequirement struct {
	// Schemes maps scheme names to required authorization scopes. Every scheme
	// in the map is required for this alternative.
	Schemes map[string][]string
}

type SecurityScheme struct {
	// Name is the identifier referenced by [SecurityRequirement]. Empty names
	// are omitted.
	Name string
	// Type selects the authentication scheme shape. Its zero value selects
	// SecurityHTTP.
	Type SecuritySchemeType
	// Description explains the authentication requirement to callers.
	Description string
	// Scheme is the HTTP authentication scheme. It defaults to Bearer for
	// SecurityHTTP.
	Scheme string
	// BearerFormat documents the bearer token format for SecurityHTTP.
	BearerFormat string
	// In is the API-key location for SecurityAPIKey. It defaults to header.
	In string
	// ParamName is the header, query, or cookie parameter name for
	// SecurityAPIKey.
	ParamName string
}

type SecuritySchemeType string

type Server struct {
	// contains filtered or unexported fields
}

type ServerOptions struct {
	// AgentCard is the public A2A identity of this server.
	AgentCard AgentCard

	// Session decides thread binding per inbound request. Nil uses Stateless.
	Session SessionBinding

	// Prompt, when set, replaces the default prompt extraction (the last
	// non-blank text part of the inbound message).
	Prompt PromptBuilder

	// Options are applied to every run at call scope. PromptBuilder options are
	// applied afterward.
	Options []adaptor.CallOption

	// ResultBuilder, when set, customizes successful terminal artifacts and
	// status text.
	ResultBuilder ResultBuilder

	// TaskLifecycle configures protocol task persistence and retention. Its zero
	// value uses an in-memory store retaining at most
	// DefaultEphemeralTaskLimit tasks for DefaultEphemeralTaskTTL.
	TaskLifecycle TaskLifecycleOptions

	// PushNotifications must be set exactly when the card enables the
	// capability; configuration is validated at construction.
	PushNotifications *PushNotificationSupport

	// ExtendedAgentCard must be set exactly when the card enables the
	// capability; configuration is validated at construction.
	ExtendedAgentCard *ExtendedAgentCardSupport

	// Exposure controls how much intermediate detail crosses the A2A
	// boundary. The zero value hides reasoning, tool calls, HITL traffic,
	// and all diagnostics.
	Exposure ExposurePolicy
}

type SessionBinding interface {
	// contains filtered or unexported methods
}

type Skill struct {
	// ID is the stable, machine-readable skill identifier.
	ID string
	// Name is the human-readable skill name.
	Name string
	// Description explains what the skill does.
	Description string
	// Tags are search and discovery labels.
	Tags []string
	// Examples contains representative prompts or use cases.
	Examples []string
	// InputModes overrides the Agent Card's default input modes for this skill.
	InputModes []string
	// OutputModes overrides the Agent Card's default output modes for this
	// skill.
	OutputModes []string
}

type TaskLifecycleOptions struct {
	// Store is a host-provided task store. When non-nil, it takes precedence
	// over Ephemeral.
	Store taskstore.Store
	// Ephemeral configures the default in-memory store used when Store is nil.
	// A nil value uses [DefaultEphemeralTaskLimit] and
	// [DefaultEphemeralTaskTTL].
	Ephemeral *EphemeralTaskStoreOptions
}