plugin

Aug 31, 2026

Changes in this version

+ type PostBuildHook = pkgplugin.PostBuildHook

Jul 28, 2026

Changes in this version

+ const CategoryDynamic

+ const CategoryMixed

+ const CategoryStatic

+ var ErrGRPCNotImplemented = errors.New("plugin: gRPC not implemented yet")

+ var ErrMissingInitSymbol = errors.New("plugin: missing InitPlugin symbol")

+ var ErrPluginNameConflict = errors.New("plugin: name already registered")

+ var ErrPluginNotFound = fmt.Errorf("plugin: not found")

+ func HuanHome() string

+ func ShouldLoadInCategory(pluginCategory, mode string) bool

+ func SoFileName(name string) string

+ func ValidateConfig(name string, schema Schema, raw map[string]any) []string

+ func ValidateRawConfigs(registry *Registry, rawConfigs map[string]config.PluginConfig, ...) (errors, warnings []string)

+ type EventSubscriber interface

+ HandleEvent func(ctx context.Context, event eventbus.Event) error

+ SubscribedEvents func() []eventbus.EventType

+ type FieldSchema = pkgplugin.FieldSchema

+ type GRPCPlugin interface

+ Call func(ctx context.Context, method string, payload []byte) ([]byte, error)

+ Capability func() string

+ Health func(ctx context.Context) error

+ type GRPCStub struct

+ func NewGRPCStub(name, capability, address string) *GRPCStub

+ func (s *GRPCStub) Call(_ context.Context, _ string, _ []byte) ([]byte, error)

+ func (s *GRPCStub) Capability() string

+ func (s *GRPCStub) Health(_ context.Context) error

+ func (s *GRPCStub) Name() string

+ type LifecycleManager struct

+ func NewLifecycleManager(registry *Registry, loader *Loader, bus eventbus.EventBus) *LifecycleManager

+ func (m *LifecycleManager) List() []PluginInfo

+ func (m *LifecycleManager) Load(soPath string, pluginCfg map[string]any) (Plugin, error)

+ func (m *LifecycleManager) Reload(name string, newSO string, pluginCfg map[string]any) error

+ func (m *LifecycleManager) SetCapabilityDetector(fn func(Plugin) string)

+ func (m *LifecycleManager) Start(ctx context.Context) error

+ func (m *LifecycleManager) Stop()

+ func (m *LifecycleManager) Unload(name string) error

+ type Loader struct

+ func NewLoader(pluginDir string) *Loader

+ func (l *Loader) LoadPlugin(path string, pluginCfg map[string]any) (Plugin, error)

+ func (l *Loader) PluginDir() string

+ func (l *Loader) Resolve(soFile string) string

+ func (l *Loader) ScanAndLoad() ([]ScanAndLoadResult, error)

+ func (l *Loader) ScanAndLoadByCategory(pluginConfigs map[string]config.PluginConfig, categories ...string) ([]ScanAndLoadResult, error)

+ type MetadataProvider = pkgplugin.MetadataProvider

+ type PluginInfo struct

+ Author string

+ Capability string

+ Error string

+ License string

+ LoadedAt string

+ Name string

+ RepoURL string

+ Source string

+ Status string

+ Tags []string

+ Version string

+ type PluginInitFunc func(cfg map[string]any) (interface{}, error)

+ type PluginMeta = pkgplugin.PluginMeta

+ type PluginWatcher struct

+ func NewPluginWatcher(dir string, manager *LifecycleManager, logf func(string, ...any)) *PluginWatcher

+ func (w *PluginWatcher) Start(ctx context.Context) error

+ type ScanAndLoadResult struct

+ Path string

+ Plugin Plugin

+ type Schema = pkgplugin.Schema

+ type SchemaProvider = pkgplugin.SchemaProvider

Jun 13, 2026

Changes in this version

+ func Find[T any](r *Registry) []T

+ type Plugin interface

+ Name func() string

+ type Registry struct

+ func NewRegistry() *Registry

+ func (r *Registry) All() []Plugin

+ func (r *Registry) Get(name string) (Plugin, bool)

+ func (r *Registry) Names() []string

+ func (r *Registry) Register(p Plugin) error

+ func (r *Registry) SortedNames() []string