Help us shape the future of Go! Take the 2026 Go Developer Survey

executor

package
v0.1.56 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Sep 27, 2026 License: Apache-2.0 Imports: 62 Imported by: 2

Documentation

Overview

Package executor provides runtime composition for agently-core.

It assembles model/agent finders, tool registry, conversation and data services, workspace stores, MCP manager, and optional hotswap wiring into a single Runtime via Builder.

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type Builder

type Builder struct {
	// contains filtered or unexported fields
}

func NewBuilder

func NewBuilder() *Builder

func (*Builder) Build

func (b *Builder) Build(ctx context.Context) (*Runtime, error)

func (*Builder) WithAgentFinder

func (b *Builder) WithAgentFinder(v agentmodel.Finder) *Builder

func (*Builder) WithAgentLoader

func (b *Builder) WithAgentLoader(v agentmodel.Loader) *Builder

func (*Builder) WithAgentService

func (b *Builder) WithAgentService(v *agentsvc.Service) *Builder

func (*Builder) WithAugmenter

func (b *Builder) WithAugmenter(v *augmenter.Service) *Builder

func (*Builder) WithCancelRegistry

func (b *Builder) WithCancelRegistry(v cancels.Registry) *Builder

func (*Builder) WithConversation

func (b *Builder) WithConversation(v conversation.Client) *Builder

func (*Builder) WithCore

func (b *Builder) WithCore(v *core.Service) *Builder

func (*Builder) WithDAO

func (b *Builder) WithDAO(v *datly.Service) *Builder

func (*Builder) WithData

func (b *Builder) WithData(v data.Service) *Builder

func (*Builder) WithDefaults

func (b *Builder) WithDefaults(v *config.Defaults) *Builder

func (*Builder) WithElicitationRouter

func (b *Builder) WithElicitationRouter(v elicrouter.ElicitationRouter) *Builder

func (*Builder) WithEmbedderFinder

func (b *Builder) WithEmbedderFinder(v embedder.Finder) *Builder

func (*Builder) WithEmbedderLoader

func (b *Builder) WithEmbedderLoader(v *embedderloader.Service) *Builder

func (*Builder) WithHotSwap

func (b *Builder) WithHotSwap(enabled bool) *Builder

func (*Builder) WithKnowledgeStore

func (b *Builder) WithKnowledgeStore(v workspace.KnowledgeStore) *Builder

func (*Builder) WithMCPAuthRTProvider

func (b *Builder) WithMCPAuthRTProvider(v mcpmgr.AuthRTProvider) *Builder

func (*Builder) WithMCPCookieJarProvider

func (b *Builder) WithMCPCookieJarProvider(v mcpmgr.JarProvider) *Builder

func (*Builder) WithMCPManager

func (b *Builder) WithMCPManager(v *mcpmgr.Manager) *Builder

func (*Builder) WithMCPUserIDExtractor

func (b *Builder) WithMCPUserIDExtractor(v mcpmgr.UserIDExtractor) *Builder

func (*Builder) WithModelFinder

func (b *Builder) WithModelFinder(v llm.Finder) *Builder

func (*Builder) WithModelLoader

func (b *Builder) WithModelLoader(v *modelloader.Service) *Builder

func (*Builder) WithRegistry

func (b *Builder) WithRegistry(v tool.Registry) *Builder

func (*Builder) WithReportingService added in v0.1.14

func (b *Builder) WithReportingService(v *reportingsvc.Service) *Builder

func (*Builder) WithStateStore

func (b *Builder) WithStateStore(v workspace.StateStore) *Builder

func (*Builder) WithStore

func (b *Builder) WithStore(v workspace.Store) *Builder

func (*Builder) WithStreamPublisher

func (b *Builder) WithStreamPublisher(v modelcallctx.StreamPublisher) *Builder

func (*Builder) WithStreamingBus

func (b *Builder) WithStreamingBus(v streaming.Bus) *Builder

func (*Builder) WithTokenProvider

func (b *Builder) WithTokenProvider(v token.Provider) *Builder

type Runtime

type Runtime struct {
	Defaults *config.Defaults
	// AuthorizationTool is the workspace-configured MCP adapter for permitted
	// Forge views.
	AuthorizationTool   string
	AuthorizationPolicy *policy.Runtime
	DAO                 *datly.Service
	Conversation        conversation.Client
	Data                data.Service
	Registry            tool.Registry
	Core                *core.Service
	Augmenter           *augmenter.Service
	Agent               *agentsvc.Service
	MCPManager          *mcpmgr.Manager
	CancelRegistry      cancels.Registry
	ElicitationRouter   elicrouter.ElicitationRouter
	Elicitation         *elicsvc.Service
	Streaming           streaming.Bus
	HotSwap             *hotswap.Manager
	Skills              *skillsvc.Service
	SkillWatcher        *skillsvc.Watcher
	CallbackDispatch    *callbacksvc.Service
	Reporting           *reportingsvc.Service
	ReportRuns          *reportingrunsvc.Service
	ReportingWorker     *reportingsvc.Worker
	Store               workspace.Store
	KnowledgeStore      workspace.KnowledgeStore
	StateStore          workspace.StateStore
	// UIBridge is the single Forge UI service shared by browser RPC, agents,
	// and all UI-facing internal tools for this runtime.
	UIBridge *forgeuisvc.Service

	// AuthConfig holds the auth configuration when auth is enabled.
	AuthConfig *svcauth.Config
	// AuthMiddleware is the HTTP middleware that extracts auth from requests.
	AuthMiddleware func(http.Handler) http.Handler

	// TokenProvider manages auth token lifecycle (cache, refresh, persistence).
	TokenProvider token.Provider
}

func (*Runtime) DefaultModel

func (r *Runtime) DefaultModel() string

func (*Runtime) IsReady

func (r *Runtime) IsReady() bool

Directories

Path Synopsis
Package config defines executor-level defaults and tuning knobs.
Package config defines executor-level defaults and tuning knobs.

Jump to

Keyboard shortcuts

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