executor

package
v0.1.40 Latest Latest
Warning

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

Go to latest
Published: Sep 13, 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