Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

workflow

package module

Go to main page

Versions in this module

v0

v0.1.9

Feb 24, 2026

v0.1.8

Feb 24, 2026

v0.1.7

Feb 24, 2026

v0.1.6

Feb 24, 2026

Changes in this version

type StdEngine

+ func (e *StdEngine) BuildFromApplicationConfig(appCfg *config.ApplicationConfig) error

v0.1.5

Feb 22, 2026

v0.1.1

Feb 22, 2026

v0.1.0

Feb 22, 2026

Changes in this version

+ type Engine interface

+ AddModuleType func(moduleType string, factory ModuleFactory)

+ BuildFromConfig func(cfg *config.WorkflowConfig) error

+ RegisterTrigger func(trigger module.Trigger)

+ RegisterWorkflowHandler func(handler WorkflowHandler)

+ Start func(ctx context.Context) error

+ Stop func(ctx context.Context) error

+ TriggerWorkflow func(ctx context.Context, workflowType string, action string, data map[string]any) error

+ type EngineBuilderFunc func(cfg *config.WorkflowConfig, logger *slog.Logger) (*StdEngine, modular.Application, error)

+ type ManagedEngine struct

+ App modular.Application

+ Engine *StdEngine

+ Error error

+ StartedAt time.Time

+ Status string

+ WorkflowID uuid.UUID

+ func (me *ManagedEngine) GetEngine() module.TriggerWorkflower

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

+ type PipelineAdder interface

+ AddPipeline func(name string, p *module.Pipeline)

+ type RoutePipelineSetter interface

+ SetRoutePipeline func(routePath string, pipeline *module.Pipeline)

+ type StartStopModule interface

+ Start func(ctx context.Context) error

+ Stop func(ctx context.Context) error

+ type StdEngine struct

+ func NewStdEngine(app modular.Application, logger modular.Logger) *StdEngine

+ func (e *StdEngine) AddModuleType(moduleType string, factory ModuleFactory)

+ func (e *StdEngine) AddStepType(stepType string, factory module.StepFactory)

+ func (e *StdEngine) App() modular.Application

+ func (e *StdEngine) BuildFromConfig(cfg *config.WorkflowConfig) error

+ func (e *StdEngine) GetApp() modular.Application

+ func (e *StdEngine) GetStepRegistry() *module.StepRegistry

+ func (e *StdEngine) LoadPlugin(p plugin.EnginePlugin) error

+ func (e *StdEngine) LoadedPlugins() []plugin.EnginePlugin

+ func (e *StdEngine) PluginLoader() *plugin.PluginLoader

+ func (e *StdEngine) RegisterTrigger(trigger module.Trigger)

+ func (e *StdEngine) RegisterTriggerConfigWrapper(triggerType string, wrapper plugin.TriggerConfigWrapperFunc)

+ func (e *StdEngine) RegisterTriggerType(triggerType string, triggerName string)

+ func (e *StdEngine) RegisterWorkflowHandler(handler WorkflowHandler)

+ func (e *StdEngine) SecretsResolver() *secrets.MultiResolver

+ func (e *StdEngine) SetDynamicLoader(loader *dynamic.Loader)

+ func (e *StdEngine) SetDynamicRegistry(registry *dynamic.ComponentRegistry)

+ func (e *StdEngine) SetPluginInstaller(installer *plugin.PluginInstaller)

+ func (e *StdEngine) SetPluginLoader(loader *plugin.PluginLoader)

+ func (e *StdEngine) Start(ctx context.Context) error

+ func (e *StdEngine) Stop(ctx context.Context) error

+ func (e *StdEngine) TriggerWorkflow(ctx context.Context, workflowType string, action string, data map[string]any) error

+ type WorkflowEngineManager struct

+ func NewWorkflowEngineManager(wfStore store.WorkflowStore, linkStore store.CrossWorkflowLinkStore, ...) *WorkflowEngineManager

+ func (m *WorkflowEngineManager) DeployWorkflow(ctx context.Context, workflowID uuid.UUID) error

+ func (m *WorkflowEngineManager) GetStatus(workflowID uuid.UUID) (*WorkflowStatus, error)

+ func (m *WorkflowEngineManager) ListActive() []WorkflowStatus

+ func (m *WorkflowEngineManager) ReloadWorkflow(ctx context.Context, workflowID uuid.UUID) error

+ func (m *WorkflowEngineManager) Router() *module.CrossWorkflowRouter

+ func (m *WorkflowEngineManager) StopAll(ctx context.Context) error

+ func (m *WorkflowEngineManager) StopWorkflow(ctx context.Context, workflowID uuid.UUID) error

+ type WorkflowHandler interface

+ CanHandle func(workflowType string) bool

+ ConfigureWorkflow func(app modular.Application, workflowConfig any) error

+ ExecuteWorkflow func(ctx context.Context, workflowType string, action string, data map[string]any) (map[string]any, error)

+ type WorkflowStatus struct

+ Error string

+ ModuleCount int

+ StartedAt time.Time

+ Status string

+ Uptime time.Duration

+ WorkflowID uuid.UUID