a2a

package

Go to main page

Versions in this module

v2

v2.13.0

Oct 8, 2026

Changes in this version

type Client

+ func (c *Client) ListTasksPage(ctx context.Context, params *ListTasksRequest) (*ListTasksResponse, error)

v2.12.1

Oct 3, 2026

v2.12.0

Oct 3, 2026

v2.11.0

Oct 1, 2026

Changes in this version

+ func IsJSONRPCBinding(binding string) bool

type Part

+ DataValue any

+ func (p Part) MarshalJSON() ([]byte, error)

type RPCError

+ Data any

type StreamEvent

+ Error error

type ToolBridge

+ func (b *ToolBridge) ShareCards(e *Executor)

v2.10.0

Oct 1, 2026

v2.9.1

Sep 30, 2026

v2.9.0

Sep 30, 2026

v2.8.0

Sep 29, 2026

Changes in this version

+ const AgentCardPath

+ const ErrCodeContentTypeNotSupported

+ const ErrCodeExtendedAgentCardNotConfigured

+ const ErrCodeExtensionSupportRequired

+ const ErrCodeInternal

+ const ErrCodeInvalidAgentResponse

+ const ErrCodeInvalidParams

+ const ErrCodeInvalidRequest

+ const ErrCodeMethodNotFound

+ const ErrCodeParse

+ const ErrCodePushNotificationNotSupported

+ const ErrCodeTaskNotCancelable

+ const ErrCodeTaskNotFound

+ const ErrCodeUnsupportedOperation

+ const ErrCodeVersionNotSupported

+ const HeaderVersion

+ const LegacyAgentCardPath

+ const MethodLegacyListTasks

+ const MethodLegacySubscribe

+ const MethodV03CancelTask

+ const MethodV03DeletePushNotificationConfig

+ const MethodV03GetExtendedCard

+ const MethodV03GetPushNotificationConfig

+ const MethodV03GetTask

+ const MethodV03ListPushNotificationConfig

+ const MethodV03Resubscribe

+ const MethodV03SendMessage

+ const MethodV03SendStreamingMessage

+ const MethodV03SetPushNotificationConfig

+ const MethodV1CancelTask

+ const MethodV1CreateTaskPushNotificationConfig

+ const MethodV1DeleteTaskPushNotificationConfig

+ const MethodV1GetExtendedAgentCard

+ const MethodV1GetTask

+ const MethodV1GetTaskPushNotificationConfig

+ const MethodV1ListTaskPushNotificationConfigs

+ const MethodV1ListTasks

+ const MethodV1SendMessage

+ const MethodV1SendStreamingMessage

+ const MethodV1SubscribeToTask

+ const ProtocolBindingJSONRPC

+ func LookupMethod(method string) (op Operation, v ProtocolVersion, ok bool)

+ type APIKeySecurityScheme struct

+ Description string

+ Location string

+ Name string

type AgentCard

+ SecurityRequirements []SecurityRequirement

+ SecuritySchemes map[string]SecurityScheme

+ func (card *AgentCard) PreferredVersion() ProtocolVersion

+ func (card *AgentCard) UnmarshalJSON(data []byte) error

type AgentInterface

+ Tenant string

type AgentSkill

+ SecurityRequirements []SecurityRequirement

type CancelTaskRequest

+ Tenant string

type Client

+ func (c *Client) ProtocolVersion() ProtocolVersion

+ func (c *Client) WaitForTask(ctx context.Context, task *Task) (*Task, error)

type ClientOption

+ func WithProtocolVersion(v ProtocolVersion) ClientOption

+ func WithRequestTimeout(d time.Duration) ClientOption

type GetTaskRequest

+ Tenant string

+ type HTTPAuthSecurityScheme struct

+ BearerFormat string

+ Description string

+ Scheme string

type ListTasksRequest

+ IncludeArtifacts bool

+ StatusTimestampAfter *time.Time

+ Tenant string

+ type MutualTLSSecurityScheme struct

+ Description string

+ type OAuth2SecurityScheme struct

+ Description string

+ Flows OAuthFlows

+ OAuth2MetadataURL string

+ type OAuthFlow struct

+ AuthorizationURL string

+ DeviceAuthorizationURL string

+ PKCERequired bool

+ RefreshURL string

+ Scopes map[string]string

+ TokenURL string

+ type OAuthFlows struct

+ AuthorizationCode *OAuthFlow

+ ClientCredentials *OAuthFlow

+ DeviceCode *OAuthFlow

+ Implicit *OAuthFlow

+ Password *OAuthFlow

+ type OpenIDConnectSecurityScheme struct

+ Description string

+ OpenIDConnectURL string

+ type Operation int

+ const OpCancelTask

+ const OpGetExtendedAgentCard

+ const OpGetTask

+ const OpListTasks

+ const OpPushNotificationConfig

+ const OpSendMessage

+ const OpSendStreamingMessage

+ const OpSubscribeToTask

+ const OpUnknown

type Part

+ func (p *Part) UnmarshalJSON(data []byte) error

+ type ProtocolVersion string

+ const ProtocolVersion03

+ const ProtocolVersion10

+ func ParseProtocolVersion(s string) (ProtocolVersion, error)

+ func (v ProtocolVersion) Method(op Operation) string

+ func (v ProtocolVersion) WireAgentCard(card *AgentCard) any

+ func (v ProtocolVersion) WireSendParams(req *SendMessageRequest) any

+ func (v ProtocolVersion) WireSendResult(task *Task) any

+ func (v ProtocolVersion) WireStreamEvent(event any) (any, error)

+ func (v ProtocolVersion) WireTask(task *Task) any

type Role

+ func (r *Role) UnmarshalJSON(data []byte) error

+ func (r Role) MarshalJSON() ([]byte, error)

+ func (r Role) V1Name() string

+ type SecurityRequirement struct

+ Schemes map[string][]string

+ func RequireScheme(name string, scopes ...string) SecurityRequirement

+ func (r *SecurityRequirement) UnmarshalJSON(data []byte) error

+ func (r SecurityRequirement) MarshalJSON() ([]byte, error)

+ type SecurityScheme struct

+ APIKey *APIKeySecurityScheme

+ HTTPAuth *HTTPAuthSecurityScheme

+ MutualTLS *MutualTLSSecurityScheme

+ OAuth2 *OAuth2SecurityScheme

+ OpenIDConnect *OpenIDConnectSecurityScheme

+ func (s *SecurityScheme) UnmarshalJSON(data []byte) error

type SendMessageConfiguration

+ ReturnImmediately bool

+ func (c *SendMessageConfiguration) WaitsForCompletion(v ProtocolVersion) bool

type SendMessageRequest

+ Tenant string

+ type SendMessageResponse struct

+ Message *Message

+ Task *Task

type StreamEvent

+ Message *Message

+ Task *Task

+ type StreamResponse struct

+ ArtifactUpdate *TaskArtifactUpdateEvent

+ Message *Message

+ StatusUpdate *TaskStatusUpdateEvent

+ Task *Task

type SubscribeTaskRequest

+ Tenant string

type TaskState

+ const TaskStateUnknown

+ func ParseTaskState(str string) (TaskState, error)

+ func (s TaskState) IsInterrupted() bool

+ func (s TaskState) IsTerminal() bool

+ func (s TaskState) V03Name() string

+ func (s TaskState) V1Name() string

v2.7.0

Sep 28, 2026

v2.6.0

Sep 22, 2026

v2.5.0

Sep 18, 2026

v2.4.0

Sep 18, 2026

v2.3.0

Sep 16, 2026

v2.2.1

Sep 14, 2026

v2.2.0

Sep 13, 2026

v2.1.0

Sep 12, 2026

v2.0.0

Sep 12, 2026

Changes in this version

+ const DefaultA2AInitialDelay

+ const DefaultA2AMaxDelay

+ const DefaultA2AMaxRetries

+ const DefaultClientTTL

+ const DefaultMaxClients

+ const DefaultSSEIdleTimeout

+ const MethodCancelTask

+ const MethodGetTask

+ const MethodListTasks

+ const MethodSendMessage

+ const MethodSendStreamingMessage

+ const MethodTaskSubscribe

+ var ErrSSEIdleTimeout = fmt.Errorf("a2a: SSE idle timeout exceeded")

+ func ExtractResponseParts(task *Task) []types.ContentPart

+ func ExtractResponseText(task *Task) string

+ func InferContentType(mediaType string) string

+ func MessageToMessage(msg *Message) (*types.Message, error)

+ func PartToContentPart(part *Part) (types.ContentPart, error)

+ func ReadSSE(ctx context.Context, r io.Reader, ch chan<- StreamEvent)

+ func ReadSSEWithIdleTimeout(ctx context.Context, r io.Reader, ch chan<- StreamEvent, ...)

+ type AgentCapabilities struct

+ ExtendedAgentCard bool

+ Extensions []AgentExtension

+ PushNotifications bool

+ Streaming bool

+ type AgentCard struct

+ Capabilities AgentCapabilities

+ DefaultInputModes []string

+ DefaultOutputModes []string

+ Description string

+ DocumentationURL string

+ IconURL string

+ Name string

+ Provider *AgentProvider

+ Skills []AgentSkill

+ SupportedInterfaces []AgentInterface

+ Version string

+ type AgentExtension struct

+ Description string

+ Required bool

+ URI string

+ type AgentInterface struct

+ ProtocolBinding string

+ ProtocolVersion string

+ URL string

+ type AgentProvider struct

+ Organization string

+ URL string

+ type AgentSkill struct

+ Description string

+ Examples []string

+ ID string

+ InputModes []string

+ Name string

+ OutputModes []string

+ Tags []string

+ type Artifact struct

+ ArtifactID string

+ Description string

+ Extensions []string

+ Metadata map[string]any

+ Name string

+ Parts []Part

+ func ContentPartsToArtifacts(parts []types.ContentPart) ([]Artifact, error)

+ type CancelTaskRequest struct

+ ID string

+ type Client struct

+ func NewClient(baseURL string, opts ...ClientOption) *Client

+ func (c *Client) CancelTask(ctx context.Context, taskID string) error

+ func (c *Client) Discover(ctx context.Context) (*AgentCard, error)

+ func (c *Client) GetTask(ctx context.Context, taskID string) (*Task, error)

+ func (c *Client) ListTasks(ctx context.Context, params *ListTasksRequest) ([]*Task, error)

+ func (c *Client) SendMessage(ctx context.Context, params *SendMessageRequest) (*Task, error)

+ func (c *Client) SendMessageStream(ctx context.Context, params *SendMessageRequest) (<-chan StreamEvent, error)

+ type ClientOption func(*Client)

+ func WithAuth(scheme, token string) ClientOption

+ func WithHTTPClient(hc *http.Client) ClientOption

+ func WithHeaders(headers map[string]string) ClientOption

+ func WithSSEIdleTimeout(d time.Duration) ClientOption

+ type Executor struct

+ func NewExecutor(opts ...ExecutorOption) *Executor

+ func (e *Executor) Close() error

+ func (e *Executor) Execute(ctx context.Context, descriptor *tools.ToolDescriptor, args json.RawMessage) (json.RawMessage, error)

+ func (e *Executor) ExecuteMultimodal(ctx context.Context, descriptor *tools.ToolDescriptor, args json.RawMessage) (json.RawMessage, []types.ContentPart, error)

+ func (e *Executor) Name() string

+ type ExecutorOption func(*Executor)

+ func WithClientTTL(d time.Duration) ExecutorOption

+ func WithMaxClients(n int) ExecutorOption

+ func WithNoRetry() ExecutorOption

+ func WithRetryPolicy(policy RetryPolicy) ExecutorOption

+ type GetTaskRequest struct

+ HistoryLength *int

+ ID string

+ type HTTPStatusError struct

+ Method string

+ StatusCode int

+ func (e *HTTPStatusError) Error() string

+ type JSONRPCError struct

+ Code int

+ Data any

+ Message string

+ type JSONRPCRequest struct

+ ID any

+ JSONRPC string

+ Method string

+ Params json.RawMessage

+ type JSONRPCResponse struct

+ Error *JSONRPCError

+ ID any

+ JSONRPC string

+ Result json.RawMessage

+ type ListTasksRequest struct

+ ContextID string

+ HistoryLength *int

+ PageSize int

+ PageToken string

+ Status *TaskState

+ type ListTasksResponse struct

+ NextPageToken string

+ PageSize int

+ Tasks []Task

+ TotalSize int

+ type Message struct

+ ContextID string

+ Extensions []string

+ MessageID string

+ Metadata map[string]any

+ Parts []Part

+ ReferenceTaskIDs []string

+ Role Role

+ TaskID string

+ type Part struct

+ Data map[string]any

+ Filename string

+ MediaType string

+ Metadata map[string]any

+ Raw []byte

+ Text *string

+ URL *string

+ func ContentPartToA2APart(part types.ContentPart) (Part, error)

+ type RPCError struct

+ Code int

+ Message string

+ func (e *RPCError) Error() string

+ type RetryPolicy struct

+ InitialDelay time.Duration

+ MaxDelay time.Duration

+ MaxRetries int

+ func DefaultRetryPolicy() RetryPolicy

+ type Role string

+ const RoleAgent

+ const RoleUser

+ type SendMessageConfiguration struct

+ AcceptedOutputModes []string

+ Blocking bool

+ HistoryLength *int

+ type SendMessageRequest struct

+ Configuration *SendMessageConfiguration

+ Message Message

+ Metadata map[string]any

+ type StreamEvent struct

+ ArtifactUpdate *TaskArtifactUpdateEvent

+ StatusUpdate *TaskStatusUpdateEvent

+ type SubscribeTaskRequest struct

+ ID string

+ type Task struct

+ Artifacts []Artifact

+ ContextID string

+ History []Message

+ ID string

+ Metadata map[string]any

+ Status TaskStatus

+ type TaskArtifactUpdateEvent struct

+ Append bool

+ Artifact Artifact

+ ContextID string

+ LastChunk bool

+ Metadata map[string]any

+ TaskID string

+ type TaskState string

+ const TaskStateAuthRequired

+ const TaskStateCanceled

+ const TaskStateCompleted

+ const TaskStateFailed

+ const TaskStateInputRequired

+ const TaskStateRejected

+ const TaskStateSubmitted

+ const TaskStateWorking

+ func (s *TaskState) UnmarshalJSON(data []byte) error

+ func (s TaskState) MarshalJSON() ([]byte, error)

+ type TaskStatus struct

+ Message *Message

+ State TaskState

+ Timestamp *time.Time

+ type TaskStatusUpdateEvent struct

+ ContextID string

+ Metadata map[string]any

+ Status TaskStatus

+ TaskID string

+ type ToolBridge struct

+ func NewToolBridge(client *Client) *ToolBridge

+ func NewToolBridgeWithConfig(client *Client, cfg *tools.A2AConfig) *ToolBridge

+ func (b *ToolBridge) GetToolDescriptors() []*tools.ToolDescriptor

+ func (b *ToolBridge) RegisterAgent(ctx context.Context) ([]*tools.ToolDescriptor, error)

Other modules containing this package

github.com/AltairaLabs/PromptKit/runtime

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL