server

Apr 16, 2026

Changes in this version

type AdminHandlerConfig

+ ReloadFunc func()

Apr 15, 2026

Changes in this version

+ func AppContextMiddleware(appStore app.Store) func(http.Handler) http.Handler

+ func AppContextMiddlewareWithValidation(appStore app.Store) func(http.Handler) http.Handler

+ type AdminHandler struct

+ func NewAdminHandler(cfg AdminHandlerConfig) (*AdminHandler, error)

+ func (h *AdminHandler) ServeHTTP(w http.ResponseWriter, r *http.Request)

+ type AdminHandlerConfig struct

+ AdminKey string

+ AppManager *AppManager

+ AppStore app.Store

+ RootDir string

+ SessionService session.Service

+ TaskDeleter TaskDeleter

+ TaskQueue native.Queue

+ TokenIssuer *auth.TokenIssuer

+ VectorProvider vector.Provider

+ type AgentRuntime struct

+ Card *a2a.AgentCard

+ Executor *Executor

+ Visibility string

+ type AppInstance struct

+ Agents map[string]*AgentRuntime

+ Config *config.AppConfig

+ Runtime Runtime

+ type AppManager struct

+ func NewAppManager(store app.Store, factory RuntimeFactory, taskService task.Service, ...) *AppManager

+ func (m *AppManager) Close() error

+ func (m *AppManager) DocumentStores() map[string]*rag.DocumentStore

+ func (m *AppManager) GetAppConfig(ctx context.Context, appID string) (*config.AppConfig, error)

+ func (m *AppManager) GetRuntime(ctx context.Context, appID, agentName string) (*AgentRuntime, error)

+ func (m *AppManager) Invalidate(appID string)

+ func (m *AppManager) ListAgents(ctx context.Context, appID string) ([]*AgentRuntime, error)

+ func (m *AppManager) LookupWebhookInConfig(path string, cfg *config.AppConfig) (string, bool)

+ func (m *AppManager) Preload(ctx context.Context, appID string) error

+ func (m *AppManager) ResolveWebhook(ctx context.Context, path string) (appID, agentName string, err error)

+ func (m *AppManager) UnloadApp(ctx context.Context, appID string) error

+ type DynamicAgentHandler struct

+ func NewDynamicAgentHandler(appManager *AppManager, serverConfig *config.ServerConfig, ...) *DynamicAgentHandler

+ func (h *DynamicAgentHandler) ServeHTTP(w http.ResponseWriter, r *http.Request)

type HTTPServer

+ func (s *HTTPServer) Reload(newCfg *config.AppConfig, newAppManager *AppManager)

type HTTPServerOption

+ func WithAdminHandler(handler *AdminHandler) HTTPServerOption

+ func WithExecutionProvider(p execution.Provider) HTTPServerOption

+ func WithRateLimiter(limiter ratelimit.RateLimiter) HTTPServerOption

+ func WithSessionService(ss session.Service) HTTPServerOption

+ func WithUIHandler(handler http.Handler) HTTPServerOption

+ type QueuedRequestHandler struct

+ func NewQueuedRequestHandler(delegate a2asrv.RequestHandler, provider execution.Provider, ...) *QueuedRequestHandler

+ func (h *QueuedRequestHandler) OnCancelTask(ctx context.Context, params *a2a.TaskIDParams) (*a2a.Task, error)

+ func (h *QueuedRequestHandler) OnDeleteTaskPushConfig(ctx context.Context, params *a2a.DeleteTaskPushConfigParams) error

+ func (h *QueuedRequestHandler) OnGetExtendedAgentCard(ctx context.Context) (*a2a.AgentCard, error)

+ func (h *QueuedRequestHandler) OnGetTask(ctx context.Context, params *a2a.TaskQueryParams) (*a2a.Task, error)

+ func (h *QueuedRequestHandler) OnGetTaskPushConfig(ctx context.Context, params *a2a.GetTaskPushConfigParams) (*a2a.TaskPushConfig, error)

+ func (h *QueuedRequestHandler) OnListTaskPushConfig(ctx context.Context, params *a2a.ListTaskPushConfigParams) ([]*a2a.TaskPushConfig, error)

+ func (h *QueuedRequestHandler) OnResubscribeToTask(ctx context.Context, params *a2a.TaskIDParams) iter.Seq2[a2a.Event, error]

+ func (h *QueuedRequestHandler) OnSendMessage(ctx context.Context, params *a2a.MessageSendParams) (a2a.SendMessageResult, error)

+ func (h *QueuedRequestHandler) OnSendMessageStream(ctx context.Context, params *a2a.MessageSendParams) iter.Seq2[a2a.Event, error]

+ func (h *QueuedRequestHandler) OnSetTaskPushConfig(ctx context.Context, params *a2a.TaskPushConfig) (*a2a.TaskPushConfig, error)

+ type Runtime interface

+ Close func() error

+ DocumentStores func() map[string]*rag.DocumentStore

+ ListAgents func() []string

+ Notifier func() *notification.Notifier

+ RunnerConfig func(agentName string) (*runner.Config, error)

+ type RuntimeFactory func(ctx context.Context, appID string, cfg *config.AppConfig) (Runtime, error)

+ type TaskDeleter interface

+ DeleteByApp func(ctx context.Context, appName string) error

Dec 31, 2025

Changes in this version

type Executor

+ func (e *Executor) ResumeFromCheckpoint(ctx context.Context, state *checkpoint.State) error

Dec 29, 2025

Changes in this version

+ type DocumentStoreProvider interface

+ DocumentStores func() map[string]*rag.DocumentStore

type HTTPServer

+ func (s *HTTPServer) SetDocumentStoreProvider(p DocumentStoreProvider)

type HTTPServerOption

+ func WithDocumentStoreProvider(p DocumentStoreProvider) HTTPServerOption

Dec 27, 2025

Changes in this version

+ type DynamicRouter struct

+ func NewDynamicRouter(h http.Handler) *DynamicRouter

+ func (r *DynamicRouter) ServeHTTP(w http.ResponseWriter, req *http.Request)

+ func (r *DynamicRouter) Swap(h http.Handler)

type HTTPServer

+ func (s *HTTPServer) CreateA2AWebhookHandlers() map[string]*trigger.WebhookHandler

+ func (s *HTTPServer) GetAgentA2AInvoker() trigger.AgentInvoker

+ func (s *HTTPServer) GetTaskResultProvider() func(ctx context.Context, taskID string) (string, error)

Dec 25, 2025

Changes in this version

type ExecutorConfig

+ Notifier *notification.Notifier

type HTTPServerOption

+ func WithWebhookHandlers(handlers map[string]*trigger.WebhookHandler) HTTPServerOption

Dec 25, 2025

Changes in this version

type HTTPServer

+ func (s *HTTPServer) UpdateState(cfg *config.Config, executors map[string]*Executor, taskStore a2asrv.TaskStore, ...)

Dec 24, 2025

Changes in this version

type HTTPServer

+ func (s *HTTPServer) SetReloadFunc(fn func() error)

Dec 16, 2025

Changes in this version

+ type ApprovalResponse struct

+ Decision string

+ TaskID string

+ ToolCallID string

+ func ExtractApprovalResponse(msg *a2a.Message) *ApprovalResponse

+ type Executor struct

+ func NewExecutor(config ExecutorConfig) *Executor

+ func (e *Executor) Cancel(ctx context.Context, reqCtx *a2asrv.RequestContext, queue eventqueue.Queue) error

+ func (e *Executor) Execute(ctx context.Context, reqCtx *a2asrv.RequestContext, queue eventqueue.Queue) error

+ type ExecutorConfig struct

+ RunConfig agent.RunConfig

+ RunnerConfig runner.Config

+ TaskService task.Service

+ type HTTPServer struct

+ func NewHTTPServer(appCfg *config.Config, executors map[string]*Executor, ...) *HTTPServer

+ func (s *HTTPServer) Address() string

+ func (s *HTTPServer) GRPCAddress() string

+ func (s *HTTPServer) SetStudioMode(configPath string)

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

+ func (s *HTTPServer) Start(ctx context.Context) error

+ func (s *HTTPServer) UpdateExecutors(cfg *config.Config, executors map[string]*Executor)

+ type HTTPServerOption func(*HTTPServer)

+ func WithAuthValidator(validator auth.TokenValidator) HTTPServerOption

+ func WithObservability(obs *observability.Manager) HTTPServerOption

+ func WithTaskService(ts task.Service) HTTPServerOption

+ func WithTaskStore(store a2asrv.TaskStore) HTTPServerOption