Versions in this module Expand all Collapse all v0 v0.4.0 Jul 25, 2026 Changes in this version + const ExecRecordPreviewBytes + const MaxBufferedResponseBytes + var ErrMCPForbidden = errors.New("mcp: access denied for target agent") + var ErrMCPUnauthenticated = errors.New("mcp: unauthenticated and target disallows public mcp") + func DiscoverMCPAuth(ctx context.Context, httpClient *http.Client, serverURL string) (*oauth.DiscoveryResult, error) + func DiscoverMCPTools(ctx context.Context, httpClient *http.Client, serverURL string, ...) ([]mcpToolInfo, string, error) + func ExtractCanonicalKeys(partsJSON []byte, agentID string) []string + func ExtractTextSummary(parts []wire.DisplayPart) string + func InjectAuth(req *http.Request, authInjectionJSON []byte, creds string) + func NewTOFUPinner(pool dbqPool) *dbqTOFUPinner + func PostToConversation(ctx context.Context, deps PostDeps, opts PostOpts) error + func PublishRunEvents(ctx context.Context, body io.ReadCloser, pubsub *realtime.PubSub, ...) (responseText string, newMessages []message.Message, tokensIn, tokensOut int32) + func PublishRunTerminal(ctx context.Context, pubsub *realtime.PubSub, agentID, runID uuid.UUID, ...) + func ResolveMediaPartsJSON(ctx context.Context, s3Client *storage.S3Client, logger *zap.Logger, ...) []byte + func ServeStoragePath(w http.ResponseWriter, r *http.Request, database *db.DB, s3 *storage.S3Client, ...) + func SynthesizeOrphanToolResults(ctx context.Context, q *dbq.Queries, runID uuid.UUID, status string, ...) + func ValidateSuspendedCheckpoint(checkpoint []byte) error + type BridgePartsDeliverer interface + SendParts func(ctx context.Context, bridgeID uuid.UUID, externalID string, ...) error + type Config struct + AgentBaseURL func(slug string) string + BridgeMgr BridgePartsDeliverer + Builder *builder.BuildService + DB *db.DB + Dispatcher *trigger.Dispatcher + Encryptor secrets.Store + ExecDialer ExecDialerService + Files *agentstoragesvc.Service + ForceInlineAttachments bool + HTTPNetwork *networkpolicy.Policy + JWTSecret string + LLMProxyURL string + Logger *zap.Logger + OAuthClient *oauth.Client + PubSub *realtime.PubSub + PublicURL string + S3 *storage.S3Client + Scheduler scheduleReconciler + type ExecDialerService interface + EvictCache func(id uuid.UUID) + Exec func(ctx context.Context, ep *dbq.AgentExecEndpoint, req execproxy.ExecRequest, ...) error + type Handler struct + func New(c Config) *Handler + func (h *Handler) AgentExec(w http.ResponseWriter, r *http.Request) + func (h *Handler) AgentHTTP(w http.ResponseWriter, r *http.Request) + func (h *Handler) CallMCPTool(ctx context.Context, agentID uuid.UUID, slug string, ...) (wire.MCPToolCallResponse, error) + func (h *Handler) CancelScheduledFire(w http.ResponseWriter, r *http.Request) + func (h *Handler) CreateRun(w http.ResponseWriter, r *http.Request) + func (h *Handler) CreateScheduledFire(w http.ResponseWriter, r *http.Request) + func (h *Handler) Embed(w http.ResponseWriter, r *http.Request) + func (h *Handler) GetCheckpoint(w http.ResponseWriter, r *http.Request) + func (h *Handler) GetEnvVarValue(w http.ResponseWriter, r *http.Request) + func (h *Handler) ImageGenerate(w http.ResponseWriter, r *http.Request) + func (h *Handler) LLMStream(w http.ResponseWriter, r *http.Request) + func (h *Handler) ListMCPTools(ctx context.Context, agentID uuid.UUID, slug string) (integrationservice.MCPTools, error) + func (h *Handler) ListScheduledFires(w http.ResponseWriter, r *http.Request) + func (h *Handler) MCPToolCall(w http.ResponseWriter, r *http.Request) + func (h *Handler) Print(w http.ResponseWriter, r *http.Request) + func (h *Handler) RequestConnection(ctx context.Context, agentID uuid.UUID, slug string, req wire.ProxyRequest) (integrationservice.ConnectionResult, error) + func (h *Handler) RunComplete(w http.ResponseWriter, r *http.Request) + func (h *Handler) RunExec(ctx context.Context, agentID uuid.UUID, slug string, req wire.ExecRequest) (integrationservice.ExecResult, error) + func (h *Handler) Seal(w http.ResponseWriter, r *http.Request) + func (h *Handler) Search(w http.ResponseWriter, r *http.Request) + func (h *Handler) ServiceProxy(w http.ResponseWriter, r *http.Request) + func (h *Handler) SessionAppend(w http.ResponseWriter, r *http.Request) + func (h *Handler) SessionCompact(w http.ResponseWriter, r *http.Request) + func (h *Handler) SessionLoad(w http.ResponseWriter, r *http.Request) + func (h *Handler) SpeechGenerate(w http.ResponseWriter, r *http.Request) + func (h *Handler) StorageCopy(w http.ResponseWriter, r *http.Request) + func (h *Handler) StorageDelete(w http.ResponseWriter, r *http.Request) + func (h *Handler) StorageInfo(w http.ResponseWriter, r *http.Request) + func (h *Handler) StorageList(w http.ResponseWriter, r *http.Request) + func (h *Handler) StorageLoad(w http.ResponseWriter, r *http.Request) + func (h *Handler) StorageShare(w http.ResponseWriter, r *http.Request) + func (h *Handler) StorageStore(w http.ResponseWriter, r *http.Request) + func (h *Handler) Sync(w http.ResponseWriter, r *http.Request) + func (h *Handler) TopicSubscribe(w http.ResponseWriter, r *http.Request) + func (h *Handler) TopicUnsubscribe(w http.ResponseWriter, r *http.Request) + func (h *Handler) Transcribe(w http.ResponseWriter, r *http.Request) + func (h *Handler) Unseal(w http.ResponseWriter, r *http.Request) + func (h *Handler) Upgrade(w http.ResponseWriter, r *http.Request) + func (h *Handler) UpsertEnvVar(w http.ResponseWriter, r *http.Request) + func (h *Handler) WebFetch(w http.ResponseWriter, r *http.Request) + type MCPPrincipal struct + CallerAgentID uuid.UUID + ClientID string + Kind MCPPrincipalKind + ParentRunID uuid.UUID + UserID uuid.UUID + type MCPPrincipalKind int + const MCPPrincipalAgent + const MCPPrincipalAnon + const MCPPrincipalOAuthClient + const MCPPrincipalUser + type MCPServer struct + func NewMCPServer(dispatcher *trigger.Dispatcher, pubsub *realtime.PubSub, logger *zap.Logger) *MCPServer + func (s *MCPServer) ServeHTTP(w http.ResponseWriter, r *http.Request, h *Handler) + func (s *MCPServer) ServePublicHTTP(w http.ResponseWriter, r *http.Request, h *Handler) + type ParentRunInfo struct + AgentID uuid.UUID + ChildAgentID uuid.UUID + ChildAgentSlug string + ChildRunID uuid.UUID + ConvID string + UserID string + type PostDeps struct + BridgeMgr BridgePartsDeliverer + DB *db.DB + Dispatcher *trigger.Dispatcher + Logger *zap.Logger + PubSub *realtime.PubSub + S3 *storage.S3Client + type PostOpts struct + AgentID uuid.UUID + ConversationID uuid.UUID + Ephemeral bool + LLMMessage string + Parts []wire.DisplayPart + Role string + RunID uuid.UUID + Source string + Text string + TriggerLLM bool v0.4.0-rc.59 Jul 25, 2026
Go to main page