Versions in this module Expand all Collapse all v1 v1.2.0 Feb 15, 2026 v1.1.11 Feb 15, 2026 Changes in this version + const MethodCancelTask + const MethodGetTask + const MethodListTasks + const MethodSendMessage + const MethodSendStreamingMessage + const MethodTaskSubscribe + 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) + 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 + type Executor struct + func NewExecutor() *Executor + func (e *Executor) Execute(descriptor *tools.ToolDescriptor, args json.RawMessage) (json.RawMessage, error) + func (e *Executor) Name() string + type GetTaskRequest struct + HistoryLength *int + ID 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 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 (b *ToolBridge) GetToolDescriptors() []*tools.ToolDescriptor + func (b *ToolBridge) RegisterAgent(ctx context.Context) ([]*tools.ToolDescriptor, error)
Go to main page