plugin

package

Go to main page

Versions in this module

v0

v0.2.2

Feb 24, 2026

v0.2.0

Feb 24, 2026

v0.1.9

Feb 24, 2026

v0.1.8

Feb 24, 2026

v0.1.7

Feb 24, 2026

Changes in this version

type BaseEnginePlugin

+ func (b *BaseEnginePlugin) ConfigTransformHooks() []ConfigTransformHook

+ type ConfigTransformHook struct

+ Hook func(cfg *config.WorkflowConfig) error

+ Name string

+ Priority int

type EnginePlugin

+ ConfigTransformHooks func() []ConfigTransformHook

type PluginLoader

+ func (l *PluginLoader) ConfigTransformHooks() []ConfigTransformHook

v0.1.6

Feb 24, 2026

v0.1.5

Feb 22, 2026

Changes in this version

+ type LicenseValidator interface

+ ValidatePlugin func(pluginName string) error

type PluginLoader

+ func (l *PluginLoader) SetLicenseValidator(v LicenseValidator)

+ func (l *PluginLoader) ValidateTier(manifest *PluginManifest) error

type PluginManifest

+ Tier PluginTier

+ type PluginTier string

+ const TierCommunity

+ const TierCore

+ const TierPremium

v0.1.1

Feb 22, 2026

v0.1.0

Feb 22, 2026

Changes in this version

+ func CheckVersion(version, constraint string) (bool, error)

+ func RegisterNativePluginFactory(f NativePluginFactory)

+ func SaveManifest(path string, manifest *PluginManifest) error

+ type APIHandler struct

+ func NewAPIHandler(registry *LocalRegistry, loader *dynamic.Loader) *APIHandler

+ func (h *APIHandler) RegisterRoutes(mux *http.ServeMux)

+ type BaseEnginePlugin struct

+ Manifest PluginManifest

+ func (b *BaseEnginePlugin) Capabilities() []capability.Contract

+ func (b *BaseEnginePlugin) EngineManifest() *PluginManifest

+ func (b *BaseEnginePlugin) ModuleFactories() map[string]ModuleFactory

+ func (b *BaseEnginePlugin) ModuleSchemas() []*schema.ModuleSchema

+ func (b *BaseEnginePlugin) StepFactories() map[string]StepFactory

+ func (b *BaseEnginePlugin) TriggerFactories() map[string]TriggerFactory

+ func (b *BaseEnginePlugin) WiringHooks() []WiringHook

+ func (b *BaseEnginePlugin) WorkflowHandlers() map[string]WorkflowHandlerFactory

+ type BaseNativePlugin struct

+ PluginDescription string

+ PluginName string

+ PluginVersion string

+ func (b *BaseNativePlugin) Dependencies() []PluginDependency

+ func (b *BaseNativePlugin) Description() string

+ func (b *BaseNativePlugin) Name() string

+ func (b *BaseNativePlugin) OnDisable(_ PluginContext) error

+ func (b *BaseNativePlugin) OnEnable(_ PluginContext) error

+ func (b *BaseNativePlugin) RegisterRoutes(_ *http.ServeMux)

+ func (b *BaseNativePlugin) UIPages() []UIPageDef

+ func (b *BaseNativePlugin) Version() string

+ type CapabilityDecl struct

+ Name string

+ Priority int

+ Role string

+ type CompositeRegistry struct

+ func NewCompositeRegistry(local *LocalRegistry, remote *RemoteRegistry) *CompositeRegistry

+ func (c *CompositeRegistry) CheckDependencies(manifest *PluginManifest) error

+ func (c *CompositeRegistry) Get(name string) (*PluginEntry, bool)

+ func (c *CompositeRegistry) Install(ctx context.Context, name, version string) error

+ func (c *CompositeRegistry) List() []*PluginEntry

+ func (c *CompositeRegistry) Local() *LocalRegistry

+ func (c *CompositeRegistry) Register(manifest *PluginManifest, component *dynamic.DynamicComponent, ...) error

+ func (c *CompositeRegistry) Remote() *RemoteRegistry

+ func (c *CompositeRegistry) Search(ctx context.Context, query string) ([]*PluginManifest, error)

+ func (c *CompositeRegistry) Unregister(name string) error

+ type Constraint struct

+ Op string

+ Version Semver

+ func ParseConstraint(s string) (*Constraint, error)

+ func (c *Constraint) Check(v Semver) bool

+ type Dependency struct

+ Constraint string

+ Name string

+ type EmbeddedWorkflow struct

+ Config *config.WorkflowConfig

+ ConfigYAML string

+ Description string

+ InputSchema map[string]schema.ConfigFieldDef

+ Name string

+ OutputSchema map[string]schema.ConfigFieldDef

+ type EnginePlugin interface

+ Capabilities func() []capability.Contract

+ EngineManifest func() *PluginManifest

+ ModuleFactories func() map[string]ModuleFactory

+ ModuleSchemas func() []*schema.ModuleSchema

+ StepFactories func() map[string]StepFactory

+ TriggerFactories func() map[string]TriggerFactory

+ WiringHooks func() []WiringHook

+ WorkflowHandlers func() map[string]WorkflowHandlerFactory

+ type EnginePluginManager struct

+ func NewEnginePluginManager(capReg *capability.Registry, schemaReg *schema.ModuleSchemaRegistry) *EnginePluginManager

+ func (m *EnginePluginManager) Disable(name string) error

+ func (m *EnginePluginManager) Enable(name string) error

+ func (m *EnginePluginManager) Get(name string) (EnginePlugin, bool)

+ func (m *EnginePluginManager) IsEnabled(name string) bool

+ func (m *EnginePluginManager) List() []EnginePlugin

+ func (m *EnginePluginManager) Loader() *PluginLoader

+ func (m *EnginePluginManager) Register(p EnginePlugin) error

+ func (m *EnginePluginManager) ResolveWorkflowDependencies(cfg *config.WorkflowConfig) error

+ type LocalRegistry struct

+ func NewLocalRegistry() *LocalRegistry

+ func (r *LocalRegistry) CheckDependencies(manifest *PluginManifest) error

+ func (r *LocalRegistry) Get(name string) (*PluginEntry, bool)

+ func (r *LocalRegistry) List() []*PluginEntry

+ func (r *LocalRegistry) Register(manifest *PluginManifest, component *dynamic.DynamicComponent, ...) error

+ func (r *LocalRegistry) ScanDirectory(dir string, loader *dynamic.Loader) ([]*PluginEntry, error)

+ func (r *LocalRegistry) Unregister(name string) error

+ type MissingCapabilitiesError struct

+ Missing []string

+ func (e *MissingCapabilitiesError) Error() string

+ type ModuleFactory func(name string, config map[string]any) modular.Module

+ type NativeHandler struct

+ func NewNativeHandler(manager *PluginManager) *NativeHandler

+ func (h *NativeHandler) ServeHTTP(w http.ResponseWriter, r *http.Request)

+ type NativePlugin interface

+ Dependencies func() []PluginDependency

+ Description func() string

+ Name func() string

+ OnDisable func(ctx PluginContext) error

+ OnEnable func(ctx PluginContext) error

+ RegisterRoutes func(mux *http.ServeMux)

+ UIPages func() []UIPageDef

+ Version func() string

+ func BuiltinNativePlugins(db *sql.DB, deps map[string]any) []NativePlugin

+ type NativePluginFactory func(db *sql.DB, deps map[string]any) NativePlugin

+ type NativePluginProvider interface

+ NativePlugins func(ctx PluginContext) []NativePlugin

+ type PipelineTriggerConfigProvider interface

+ PipelineTriggerConfigWrappers func() map[string]TriggerConfigWrapperFunc

+ type PluginContext struct

+ App interface{}

+ DB *sql.DB

+ DataDir string

+ Logger *slog.Logger

+ type PluginDependency struct

+ MinVersion string

+ Name string

+ type PluginEntry struct

+ Component *dynamic.DynamicComponent

+ Manifest *PluginManifest

+ SourceDir string

+ type PluginInfo struct

+ Dependencies []PluginDependency

+ Description string

+ DisabledAt string

+ Enabled bool

+ EnabledAt string

+ Name string

+ UIPages []UIPageDef

+ Version string

+ type PluginInstaller struct

+ func NewPluginInstaller(remoteReg *RemoteRegistry, localReg *LocalRegistry, loader *dynamic.Loader, ...) *PluginInstaller

+ func (i *PluginInstaller) Install(ctx context.Context, name, version string) error

+ func (i *PluginInstaller) InstallDir() string

+ func (i *PluginInstaller) InstallFromBundle(bundlePath string) error

+ func (i *PluginInstaller) IsInstalled(name string) bool

+ func (i *PluginInstaller) ScanInstalled() ([]*PluginEntry, error)

+ func (i *PluginInstaller) Uninstall(name string) error

+ type PluginLoader struct

+ func NewPluginLoader(capReg *capability.Registry, schemaReg *schema.ModuleSchemaRegistry) *PluginLoader

+ func (l *PluginLoader) CapabilityRegistry() *capability.Registry

+ func (l *PluginLoader) LoadPlugin(p EnginePlugin) error

+ func (l *PluginLoader) LoadPlugins(plugins []EnginePlugin) error

+ func (l *PluginLoader) LoadedPlugins() []EnginePlugin

+ func (l *PluginLoader) ModuleFactories() map[string]ModuleFactory

+ func (l *PluginLoader) StepFactories() map[string]StepFactory

+ func (l *PluginLoader) TriggerFactories() map[string]TriggerFactory

+ func (l *PluginLoader) WiringHooks() []WiringHook

+ func (l *PluginLoader) WorkflowHandlerFactories() map[string]WorkflowHandlerFactory

+ type PluginManager struct

+ func NewPluginManager(db *sql.DB, logger *slog.Logger) *PluginManager

+ func (pm *PluginManager) AllPlugins() []PluginInfo

+ func (pm *PluginManager) Disable(name string) error

+ func (pm *PluginManager) Enable(name string) error

+ func (pm *PluginManager) EnabledPlugins() []NativePlugin

+ func (pm *PluginManager) IsEnabled(name string) bool

+ func (pm *PluginManager) Register(p NativePlugin) error

+ func (pm *PluginManager) RestoreState() error

+ func (pm *PluginManager) ServeHTTP(w http.ResponseWriter, r *http.Request)

+ func (pm *PluginManager) SetContext(ctx PluginContext)

+ type PluginManifest struct

+ Author string

+ Capabilities []CapabilityDecl

+ Contract *dynamic.FieldContract

+ Dependencies []Dependency

+ Description string

+ License string

+ ModuleTypes []string

+ Name string

+ Repository string

+ StepTypes []string

+ Tags []string

+ TriggerTypes []string

+ Version string

+ WiringHooks []string

+ WorkflowTypes []string

+ func LoadManifest(path string) (*PluginManifest, error)

+ func (m *PluginManifest) Validate() error

+ type PluginRegistry interface

+ CheckDependencies func(manifest *PluginManifest) error

+ Get func(name string) (*PluginEntry, bool)

+ List func() []*PluginEntry

+ Register func(manifest *PluginManifest, component *dynamic.DynamicComponent, ...) error

+ Unregister func(name string) error

+ type PluginWorkflowRegistry struct

+ func NewPluginWorkflowRegistry() *PluginWorkflowRegistry

+ func (r *PluginWorkflowRegistry) Get(qualifiedName string) (*EmbeddedWorkflow, bool)

+ func (r *PluginWorkflowRegistry) List() []string

+ func (r *PluginWorkflowRegistry) Register(pluginName string, wf EmbeddedWorkflow) error

+ func (r *PluginWorkflowRegistry) Unregister(pluginName string)

+ type RegistryHandler struct

+ func NewRegistryHandler(registry *CompositeRegistry) *RegistryHandler

+ func (h *RegistryHandler) RegisterRoutes(mux *http.ServeMux)

+ type RemoteRegistry struct

+ func NewRemoteRegistry(baseURL string, opts ...RemoteRegistryOption) *RemoteRegistry

+ func (r *RemoteRegistry) ClearCache()

+ func (r *RemoteRegistry) Download(ctx context.Context, name, version string) (io.ReadCloser, error)

+ func (r *RemoteRegistry) GetManifest(ctx context.Context, name, version string) (*PluginManifest, error)

+ func (r *RemoteRegistry) ListVersions(ctx context.Context, name string) ([]string, error)

+ func (r *RemoteRegistry) Search(ctx context.Context, query string) ([]*PluginManifest, error)

+ type RemoteRegistryOption func(*RemoteRegistry)

+ func WithCacheTTL(ttl time.Duration) RemoteRegistryOption

+ func WithHTTPClient(client *http.Client) RemoteRegistryOption

+ type Semver struct

+ Major int

+ Minor int

+ Patch int

+ func ParseSemver(v string) (Semver, error)

+ func (s Semver) Compare(other Semver) int

+ func (s Semver) String() string

+ type StepFactory func(name string, config map[string]any, app modular.Application) (any, error)

+ type TriggerConfigWrapperFunc func(pipelineName string, flatConfig map[string]any) map[string]any

+ type TriggerFactory func() any

+ type UIPageDef struct

+ APIEndpoint string

+ Category string

+ ID string

+ Icon string

+ Label string

+ Order int

+ RequiredPermission string

+ RequiredRole string

+ Template string

+ type WiringHook struct

+ Hook func(app modular.Application, cfg *config.WorkflowConfig) error

+ Name string

+ Priority int

+ type WorkflowHandlerFactory func() any

+ type WorkflowPlugin interface

+ EmbeddedWorkflows func() []EmbeddedWorkflow

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