Versions in this module Expand all Collapse all v0 v0.1.5 Feb 22, 2026 Changes in this version + type ConfigField struct + DefaultValue string + Description string + Name string + Options []string + Required bool + Type string + type MessageAwareModule interface + SetMessagePublisher func(pub MessagePublisher) + SetMessageSubscriber func(sub MessageSubscriber) + type MessagePublisher interface + Publish func(topic string, payload []byte, metadata map[string]string) (messageID string, err error) + type MessageSubscriber interface + Subscribe func(topic string, handler func(payload []byte, metadata map[string]string) error) error + Unsubscribe func(topic string) error + type ModuleSchemaData struct + Category string + ConfigFields []ConfigField + Description string + Inputs []ServiceIO + Label string + Outputs []ServiceIO + Type string + type SchemaProvider interface + ModuleSchemas func() []ModuleSchemaData + type ServiceIO struct + Description string + Name string + Type string + type TriggerCallback func(action string, data map[string]any) error + type TriggerInstance interface + Start func(ctx context.Context) error + Stop func(ctx context.Context) error + type TriggerProvider interface + CreateTrigger func(typeName string, config map[string]any, cb TriggerCallback) (TriggerInstance, error) + TriggerTypes func() []string v0.1.1 Feb 22, 2026 Changes in this version + type UIProvider interface + UIManifest func() ext.UIManifest v0.1.0 Feb 22, 2026 Changes in this version + func Serve(provider PluginProvider) + type ModuleInstance interface + Init func() error + Start func(ctx context.Context) error + Stop func(ctx context.Context) error + type ModuleProvider interface + CreateModule func(typeName, name string, config map[string]any) (ModuleInstance, error) + ModuleTypes func() []string + type PluginManifest struct + Author string + Description string + Name string + Version string + type PluginProvider interface + Manifest func() PluginManifest + type StepInstance interface + Execute func(ctx context.Context, triggerData map[string]any, ...) (*StepResult, error) + type StepProvider interface + CreateStep func(typeName, name string, config map[string]any) (StepInstance, error) + StepTypes func() []string + type StepResult struct + Output map[string]any + StopPipeline bool
Go to main page