executor

package

v0.1.6 Latest Latest Go to latest Published: Apr 1, 2026 License: Apache-2.0 Imports: 39 Imported by: 2

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/viant/agently-core

Links

Open Source Insights

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 ¶

type Builder
- func NewBuilder() *Builder
type Runtime
- func (r *Runtime) DefaultModel() string
- func (r *Runtime) IsReady() bool

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) 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
	DAO               *datly.Service
	Conversation      conversation.Client
	Data              data.Service
	Registry          tool.Registry
	Core              *core.Service
	Agent             *agentsvc.Service
	MCPManager        *mcpmgr.Manager
	CancelRegistry    cancels.Registry
	ElicitationRouter elicrouter.ElicitationRouter
	Elicitation       *elicsvc.Service
	Streaming         streaming.Bus
	HotSwap           *hotswap.Manager
	Store             workspace.Store
	KnowledgeStore    workspace.KnowledgeStore
	StateStore        workspace.StateStore

	// 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

Source Files ¶

View all Source files

Directories ¶

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

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