a2aserver

package module

Go to main page

Versions in this module

v1

v1.3.11

Mar 9, 2026

v1.3.10

Mar 8, 2026

Changes in this version

+ var ErrTooManySubscribers = fmt.Errorf("a2a: too many subscribers")

+ type HealthChecker interface

+ Check func(ctx context.Context) error

+ type HealthCheckerFunc func(ctx context.Context) error

+ func (f HealthCheckerFunc) Check(ctx context.Context) error

type Option

+ func WithHealthCheck(name string, checker HealthChecker) Option

v1.3.9

Mar 4, 2026

v1.3.8

Mar 4, 2026

Changes in this version

type EventKind

+ const EventClientTool

+ type PendingClientToolInfo struct

+ Args map[string]any

+ CallID string

+ ConsentMsg string

+ ToolName string

+ type ResumableConversation interface

+ RejectClientTool func(callID string, reason string)

+ Resume func(ctx context.Context) (SendResult, error)

+ ResumeStream func(ctx context.Context) <-chan StreamEvent

+ SendToolResult func(callID string, result any) error

type SendResult

+ HasPendingClientTools func() bool

+ PendingClientTools func() []PendingClientToolInfo

type StreamEvent

+ ClientTool *PendingClientToolInfo

v1.3.7

Mar 3, 2026

v1.3.6

Mar 3, 2026

v1.3.5

Mar 1, 2026

v1.3.4

Mar 1, 2026

v1.3.3

Mar 1, 2026

Changes in this version

+ var ErrInvalidTransition = errors.New("a2a: invalid state transition")

+ var ErrTaskAlreadyExists = errors.New("a2a: task already exists")

+ var ErrTaskNotFound = errors.New("a2a: task not found")

+ var ErrTaskTerminal = errors.New("a2a: task is in a terminal state")

+ type AgentCardProvider interface

+ AgentCard func(r *http.Request) (*a2a.AgentCard, error)

+ type Authenticator interface

+ Authenticate func(r *http.Request) error

+ type Conversation interface

+ Close func() error

+ Send func(ctx context.Context, message any) (SendResult, error)

+ type ConversationOpener func(contextID string) (Conversation, error)

+ type EventKind int

+ const EventDone

+ const EventMedia

+ const EventText

+ const EventToolCall

+ type InMemoryTaskStore struct

+ func NewInMemoryTaskStore() *InMemoryTaskStore

+ func (s *InMemoryTaskStore) AddArtifacts(taskID string, artifacts []a2a.Artifact) error

+ func (s *InMemoryTaskStore) Cancel(taskID string) error

+ func (s *InMemoryTaskStore) Create(taskID, contextID string) (*a2a.Task, error)

+ func (s *InMemoryTaskStore) EvictTerminal(cutoff time.Time) []string

+ func (s *InMemoryTaskStore) Get(taskID string) (*a2a.Task, error)

+ func (s *InMemoryTaskStore) List(contextID string, limit, offset int) ([]*a2a.Task, error)

+ func (s *InMemoryTaskStore) SetState(taskID string, state a2a.TaskState, msg *a2a.Message) error

+ type Option func(*Server)

+ func WithAuthenticator(auth Authenticator) Option

+ func WithCard(card *a2a.AgentCard) Option

+ func WithCardProvider(p AgentCardProvider) Option

+ func WithConversationTTL(d time.Duration) Option

+ func WithIdleTimeout(d time.Duration) Option

+ func WithMaxBodySize(n int64) Option

+ func WithPort(port int) Option

+ func WithReadTimeout(d time.Duration) Option

+ func WithTaskStore(store TaskStore) Option

+ func WithTaskTTL(d time.Duration) Option

+ func WithWriteTimeout(d time.Duration) Option

+ type SendResult interface

+ HasPendingTools func() bool

+ Parts func() []types.ContentPart

+ Text func() string

+ type Server struct

+ func NewServer(opener ConversationOpener, opts ...Option) *Server

+ func (s *Server) Handler() http.Handler

+ func (s *Server) ListenAndServe() error

+ func (s *Server) Serve(ln net.Listener) error

+ func (s *Server) Shutdown(ctx context.Context) error

+ type StaticCard struct

+ Card a2a.AgentCard

+ func (s *StaticCard) AgentCard(*http.Request) (*a2a.AgentCard, error)

+ type StreamEvent struct

+ Error error

+ Kind EventKind

+ Media *types.MediaContent

+ Text string

+ type StreamingConversation interface

+ Stream func(ctx context.Context, message any) <-chan StreamEvent

+ type TaskStore interface

+ AddArtifacts func(taskID string, artifacts []a2a.Artifact) error

+ Cancel func(taskID string) error

+ Create func(taskID, contextID string) (*a2a.Task, error)

+ EvictTerminal func(olderThan time.Time) []string

+ Get func(taskID string) (*a2a.Task, error)

+ List func(contextID string, limit, offset int) ([]*a2a.Task, error)

+ SetState func(taskID string, state a2a.TaskState, msg *a2a.Message) error

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