pluginhost

package
v0.34.0 Latest Latest
Warning

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

 Go to latest Published: May 19, 2026 License: AGPL-3.0 Imports: 21 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func DefaultCatalogBundledSkillSpecs 

func DefaultCatalogBundledSkillSpecs() ([]pkgplugins.BundledSkillSpec, error)

DefaultCatalogBundledSkillSpecs loads the default plugin catalog into a throw-away host and returns all registered bundled skill specs, sorted by skill name then plugin ID.

func NewAuthService 

func NewAuthService(store auth.AuthStore) pkgplugins.Auth

func NewSkillStoreAdapter 

func NewSkillStoreAdapter(s skills.Store) pkgplugins.SkillStore

NewSkillStoreAdapter wraps an internal/skills.Store as a pkgplugins.SkillStore. The returned value also satisfies pkgplugins.KnowledgeStore when the underlying store implements skills.KnowledgeStore. Exported so that test code and CLI code can construct a typed adapter without depending on the unexported adapter type.

Types

type ChannelPlatform 

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

ChannelPlatform is a mutable host extension bag for managed channel runtimes.

func NewChannelRuntimeServices 

func NewChannelRuntimeServices() *ChannelPlatform

func (*ChannelPlatform) Handler 

func (s *ChannelPlatform) Handler() pkgchannel.Handler

func (*ChannelPlatform) Notifications 

func (s *ChannelPlatform) Notifications() pkgplugins.ChannelRegistry

func (*ChannelPlatform) ParentContext 

func (s *ChannelPlatform) ParentContext() context.Context

func (*ChannelPlatform) Set 

func (s *ChannelPlatform) Set(parent context.Context, handler pkgchannel.Handler, notifications pkgplugins.ChannelRegistry)

type ConfigBackend 

type ConfigBackend interface {
	Get(ctx context.Context, pluginID string) (pkgplugins.PluginState, error)
	Set(ctx context.Context, pluginID string, config map[string]any) error
	SetEnabled(ctx context.Context, pluginID string, enabled bool) error
}

ConfigBackend is the host-owned unscoped plugin config backend.

type Host 

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

func New 

func New(store config.Store, opts ...Option) *Host

func (*Host) AddAdmin 

func (h *Host) AddAdmin(reg pkgplugins.AdminSpec)

func (*Host) AddAfterToolResult 

func (h *Host) AddAfterToolResult(reg pkgplugins.AfterToolResultSpec)

func (*Host) AddBeforeRun 

func (h *Host) AddBeforeRun(reg pkgplugins.BeforeRunSpec)

func (*Host) AddBeforeToolCall 

func (h *Host) AddBeforeToolCall(reg pkgplugins.BeforeToolCallSpec)

func (*Host) AddBundledSkill 

func (h *Host) AddBundledSkill(spec pkgplugins.BundledSkillSpec)

func (*Host) AddChannel 

func (h *Host) AddChannel(reg pkgplugins.ChannelSpec)

func (*Host) AddHook 

func (h *Host) AddHook(reg pkgplugins.HookSpec)

func (*Host) AddPromptInventory 

func (h *Host) AddPromptInventory(reg pkgplugins.PromptInventorySpec)

func (*Host) AddProvider 

func (h *Host) AddProvider(reg pkgplugins.ProviderSpec)

func (*Host) AddRuntime 

func (h *Host) AddRuntime(reg pkgplugins.RuntimeSpec)

func (*Host) AddSessionEnv 

func (h *Host) AddSessionEnv(spec pkgplugins.SessionEnvSpec)

func (*Host) AddSystemPrompt 

func (h *Host) AddSystemPrompt(reg pkgplugins.SystemPromptSpec)

func (*Host) AddTool 

func (h *Host) AddTool(reg pkgplugins.ToolSpec)

func (*Host) AfterToolResult 

func (h *Host) AfterToolResult(ctx context.Context, build pkgplugins.AfterToolResultContext) (pkgplugins.AfterToolResult, error)

func (*Host) AllBundledSkillSpecs 

func (h *Host) AllBundledSkillSpecs() []pkgplugins.BundledSkillSpec

func (*Host) AllSessionEnvSpecs 

func (h *Host) AllSessionEnvSpecs() []pkgplugins.SessionEnvSpec

func (*Host) ApplyChannel 

func (h *Host) ApplyChannel(ctx context.Context, channel config.Channel) error

func (*Host) ApplyPlugin 

func (h *Host) ApplyPlugin(ctx context.Context, pluginID string) error

func (*Host) Auth 

func (h *Host) Auth() pkgplugins.Auth

Auth returns the injected auth service, if any.

func (*Host) BeforeRun 

func (h *Host) BeforeRun(ctx context.Context, build pkgplugins.BeforeRunContext) (pkgplugins.BeforeRunResult, error)

func (*Host) BeforeToolCall 

func (h *Host) BeforeToolCall(ctx context.Context, build pkgplugins.BeforeToolCallContext) (pkgplugins.BeforeToolCallResult, error)

func (*Host) BuildEnabledHooks 

func (h *Host) BuildEnabledHooks(ctx context.Context, bc pluginhooks.BuildContext) []hooks.HookPlugin

func (*Host) BuildEnabledTools 

func (h *Host) BuildEnabledTools(ctx context.Context, bc pkgplugins.ToolBuildContext) []tools.Tool

func (*Host) BuildProvider 

func (h *Host) BuildProvider(name string, stateConfig map[string]any) (providers.ProviderAdapter, error)

func (*Host) BuildStreamFunc added in v0.28.0 

func (h *Host) BuildStreamFunc(name string, stateConfig map[string]any) (providers.StreamFunc, error)

func (*Host) BundledSkillSpecs 

func (h *Host) BundledSkillSpecs(pluginID string) []pkgplugins.BundledSkillSpec

func (*Host) ChannelConfigured 

func (h *Host) ChannelConfigured(ctx context.Context, name string) bool

func (*Host) ChannelInstanceConfigured 

func (h *Host) ChannelInstanceConfigured(channel config.Channel) bool

func (*Host) ChannelRuntime 

func (h *Host) ChannelRuntime() pkgplugins.ChannelPlatform

ChannelRuntime returns the injected channel runtime service extension, if any.

func (*Host) Config 

func (h *Host) Config() ConfigBackend

func (*Host) ConfigSchema 

func (h *Host) ConfigSchema(pluginID string) map[string]any

func (*Host) DesiredState 

func (h *Host) DesiredState(ctx context.Context, pluginID string) (pkgplugins.PluginState, error)

func (*Host) HasConfig 

func (h *Host) HasConfig(pluginID string) bool

func (*Host) HasRuntime 

func (h *Host) HasRuntime(pluginID string) bool

func (*Host) HasStatus 

func (h *Host) HasStatus(pluginID string) bool

func (*Host) ListAdminVisiblePlugins 

func (h *Host) ListAdminVisiblePlugins(ctx context.Context) ([]pkgplugins.RegisteredPlugin, error)

func (*Host) ListChannels 

func (h *Host) ListChannels(ctx context.Context) ([]config.Channel, error)

func (*Host) ListProviderTypes 

func (h *Host) ListProviderTypes() []ProviderType

func (*Host) ListRegisteredPlugins 

func (h *Host) ListRegisteredPlugins() []pkgplugins.PluginInfo

func (*Host) LoadCatalog 

func (h *Host) LoadCatalog(catalog *pkgplugins.Catalog) error

func (*Host) LoadDefaultCatalog 

func (h *Host) LoadDefaultCatalog() error

func (*Host) Logger 

func (h *Host) Logger(pluginID string) *slog.Logger

func (*Host) ManagedPlugins 

func (h *Host) ManagedPlugins() []string

func (*Host) ManifestPluginPrompts 

func (h *Host) ManifestPluginPrompts() []pkgplugins.SystemPromptSection

func (*Host) Notifications 

func (h *Host) Notifications() pkgplugins.Notifier

Notifications returns the injected notification service, if any.

func (*Host) PluginsByKind 

func (h *Host) PluginsByKind(kind string) []string

func (*Host) PromptTools 

func (h *Host) PromptTools(ctx context.Context, pluginID string) ([]pkgplugins.PromptToolInfo, error)

func (*Host) RedactConfig 

func (h *Host) RedactConfig(pluginID string, raw map[string]any) map[string]any

func (*Host) ReflectRuntime 

func (h *Host) ReflectRuntime() pkgplugins.ReflectPlatform

ReflectRuntime returns the injected reflect runtime service extension, if any.

func (*Host) RegisterBuiltinTools added in v0.33.0 

func (h *Host) RegisterBuiltinTools(mcpManager *mcptool.Manager)

RegisterBuiltinTools registers internal tools that use plugin host capabilities (admin config, status, runtime) without going through the global plugin catalog. Currently only MCP uses this for Web UI management.

func (*Host) RegisterManifestPlugins 

func (h *Host) RegisterManifestPlugins(m *manifestplugins.Manifest)

RegisterManifestPlugins registers plugins declared in a manifest. For each enabled plugin:

  • New plugins (not already Go-registered) are fully registered with ID, info, and session envs.
  • Existing plugins (already Go-registered) get manifest session envs registered so the manifest is the single source of truth for env injection. Go code should no longer call AddSessionEnv for manifest-declared env vars.

func (*Host) RegisterPluginID 

func (h *Host) RegisterPluginID(id string)

func (*Host) Runtime 

func (h *Host) Runtime() pkgplugins.RuntimeLookup

func (*Host) Scheduler 

func (h *Host) Scheduler() SchedulerBackend

Scheduler returns the injected scheduler backend, if any.

func (*Host) SessionEnvSpecs 

func (h *Host) SessionEnvSpecs(pluginID string) []pkgplugins.SessionEnvSpec

func (*Host) SessionPluginView 

func (h *Host) SessionPluginView(ctx context.Context) (pkgplugins.SessionPluginView, error)

SessionPluginView returns the enabled plugin-owned session env setup used by runner sessions plus the registered/enabled plugin IDs prompt builders may need for visibility-aware output.

func (*Host) SetAuthService 

func (h *Host) SetAuthService(service pkgplugins.Auth)

SetAuthService updates the auth service extension after host construction.

func (*Host) SetChannelRuntimeServices 

func (h *Host) SetChannelRuntimeServices(services pkgplugins.ChannelPlatform)

SetChannelRuntimeServices updates the channel runtime service extension after host construction.

func (*Host) SetEnabled 

func (h *Host) SetEnabled(ctx context.Context, pluginID string, enabled bool) error

func (*Host) SetInfo 

func (h *Host) SetInfo(info pkgplugins.PluginInfo)

func (*Host) SetNotificationService 

func (h *Host) SetNotificationService(service pkgplugins.Notifier)

SetNotificationService updates the notification service extension after host construction.

func (*Host) SetReflectRuntimeServices 

func (h *Host) SetReflectRuntimeServices(services pkgplugins.ReflectPlatform)

SetReflectRuntimeServices updates the reflect runtime service extension after host construction.

func (*Host) SetSchedulerService 

func (h *Host) SetSchedulerService(service SchedulerBackend)

SetSchedulerService updates the scheduler backend after host construction.

func (*Host) SetSkillStore 

func (h *Host) SetSkillStore(store skills.Store)

SetSkillStore updates the skill store after host construction.

func (*Host) SetStateStore 

func (h *Host) SetStateStore(store StateStoreBackend)

SetStateStore updates the plugin state backend after host construction.

func (*Host) SkillStore 

func (h *Host) SkillStore() skills.Store

SkillStore returns the injected skill store, if any.

func (*Host) StateStore 

func (h *Host) StateStore() StateStoreBackend

StateStore returns the injected plugin state backend, if any.

func (*Host) Status 

func (h *Host) Status(ctx context.Context, pluginID string) (any, error)

func (*Host) Stop 

func (h *Host) Stop(ctx context.Context) error

func (*Host) SystemPromptSections 

func (h *Host) SystemPromptSections(ctx context.Context, build pkgplugins.SystemPromptContext) ([]pkgplugins.SystemPromptSection, error)

func (*Host) ValidateConfig 

func (h *Host) ValidateConfig(pluginID string, raw map[string]any) error

func (*Host) ValidateRegistrations 

func (h *Host) ValidateRegistrations() error

type Option 

type Option func(*Host)

func WithAuthService 

func WithAuthService(service pkgplugins.Auth) Option

WithAuthService injects the narrow auth directory available to plugins.

func WithChannelRuntimeServices 

func WithChannelRuntimeServices(services pkgplugins.ChannelPlatform) Option

WithChannelRuntimeServices injects the narrow services used by managed channel runtimes.

func WithNotificationService 

func WithNotificationService(service pkgplugins.Notifier) Option

WithNotificationService injects the narrow notification service available to plugins.

func WithReflectRuntimeServices 

func WithReflectRuntimeServices(services pkgplugins.ReflectPlatform) Option

WithReflectRuntimeServices injects the narrow services used by the reflect managed runtime.

func WithSchedulerService 

func WithSchedulerService(service SchedulerBackend) Option

WithSchedulerService injects the host scheduler backend available to plugins.

func WithSkillStore 

func WithSkillStore(store skills.Store) Option

WithSkillStore injects the skill store available to plugins.

func WithStateStore 

func WithStateStore(store StateStoreBackend) Option

WithStateStore injects the host plugin state backend available to plugins.

type ProviderType 

type ProviderType struct {
	ID         string
	Name       string
	DefaultURL string
}

type ReflectPlatform 

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

ReflectPlatform is a mutable host extension bag for the reflect managed runtime.

func NewReflectRuntimeServices 

func NewReflectRuntimeServices() *ReflectPlatform

func (*ReflectPlatform) BuildStreamFunc added in v0.28.0 

func (s *ReflectPlatform) BuildStreamFunc(api, apiKey, baseURL string) (providers.StreamFunc, error)

func (*ReflectPlatform) Memory 

func (s *ReflectPlatform) Memory() memory.Provider

func (*ReflectPlatform) ParentContext 

func (s *ReflectPlatform) ParentContext() context.Context

func (*ReflectPlatform) Set 

func (s *ReflectPlatform) Set(parent context.Context, mem memory.Provider, store config.Store, workspace string, buildStreamFunc func(api, apiKey, baseURL string) (providers.StreamFunc, error))

func (*ReflectPlatform) Store 

func (s *ReflectPlatform) Store() pkgplugins.ReflectStore

func (*ReflectPlatform) Workspace 

func (s *ReflectPlatform) Workspace() string

type RuntimeHost 

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

func NewRuntimeHost 

func NewRuntimeHost(host *Host) *RuntimeHost

func (*RuntimeHost) ApplyChannel 

func (h *RuntimeHost) ApplyChannel(ctx context.Context, channel config.Channel) error

func (*RuntimeHost) ApplyPlugin 

func (h *RuntimeHost) ApplyPlugin(ctx context.Context, pluginID string) error

func (*RuntimeHost) Get 

func (h *RuntimeHost) Get(pluginID string, runtimeName string) (pkgplugins.RuntimeHandle, bool)

func (*RuntimeHost) Lookup 

func (h *RuntimeHost) Lookup(pluginID string, runtimeName string) (pkgplugins.RuntimeHandle, bool)

func (*RuntimeHost) Snapshot 

func (h *RuntimeHost) Snapshot(ctx context.Context, pluginID string, runtimeName string) (pkgplugins.RuntimeStatus, error)

func (*RuntimeHost) Stop 

func (h *RuntimeHost) Stop(ctx context.Context) error

type SchedulerBackend 

type SchedulerBackend interface {
	ReconcilePluginJobs(ctx context.Context, pluginID string, jobs []pkgplugins.SchedulerJobSpec) error
	DeletePluginJobs(ctx context.Context, pluginID string) error
	DeletePluginJob(ctx context.Context, pluginID string, key string) error
	ListPluginJobs(ctx context.Context, pluginID string) ([]pkgplugins.SchedulerJob, error)
}

SchedulerBackend is the host-owned unscoped scheduler backend.

type StateStoreBackend 

type StateStoreBackend interface {
	Get(ctx context.Context, pluginID string, scope pkgplugins.StateScope, key string) (map[string]any, bool, error)
	Set(ctx context.Context, pluginID string, scope pkgplugins.StateScope, key string, value map[string]any) error
	Delete(ctx context.Context, pluginID string, scope pkgplugins.StateScope, key string) error
}

StateStoreBackend is the host-owned unscoped plugin state backend.

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.