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

engine

package

Go to main page

Versions in this module

v1

v1.0.2

Jun 1, 2026

Changes in this version

type ExternalResources

+ Providers map[string]LLMProviderConfig

+ type LLMProviderConfig struct

+ APIKey string

+ Model string

+ URL string

+ type MemorySync interface

+ Hydrate func(ctx context.Context) ([]workflow.MemoryFile, error)

+ Push func(ctx context.Context, uid, content string) error

+ type Supervisor interface

+ Heartbeat func(ctx context.Context, address string) error

+ Register func(ctx context.Context, reg AgentRegistration) error

v1.0.1

May 29, 2026

Changes in this version

+ const PortCtrl

+ const PortFalse

+ const PortTrue

+ const SrcDeclared

+ const SrcFnArg

+ const StateIdle

+ const SubBufSize

+ func ApplyDeclaration(s *Scope, nodeID string, od workflow.OutputDeclaration, val expr.Value) error

+ func ApplyOutput(s *Scope, nodeID, slotID string, binding workflow.OutputBinding, ...) error

+ func FilterEmitted(raw map[string]workflow.DataType, bindings map[string]workflow.OutputBinding) map[string]workflow.DataType

+ func HeartbeatLoop(ctx context.Context, lc Lifecycle, address string, cfg RetryConfig)

+ func RegisterNodeOutputs(scp *Scope, em Emitter)

+ func RegisterWithRetry(ctx context.Context, lc Lifecycle, reg AgentRegistration, cfg RetryConfig)

+ type ADCConfig struct

+ Device string

+ type AgentRegistration struct

+ Address string

+ Error *string

+ Manifest *DeviceManifest

+ Status AgentStatus

+ type AgentStatus string

+ const StatusBootError

+ const StatusOnline

+ type BranchingNode struct

+ func NewBranchingNode(id string) BranchingNode

+ func (b *BranchingNode) AddTransition(port string, tr Transition) error

+ func (b *BranchingNode) ID() string

+ func (b *BranchingNode) Transitions(port string) []Transition

+ type BuildFunc func(ctx context.Context, wf *workflow.Workflow, dm DeploymentMapping, ...) (*Runner, error)

+ type DACConfig struct

+ Device string

+ type DeploymentMapping map[string]ResourceBinding

+ type DeviceManifest struct

+ ADCs map[string]ADCConfig

+ DACs map[string]DACConfig

+ GPIOs map[string]GPIOConfig

+ PWMs map[string]PWMConfig

+ Serials map[string]SerialConfig

+ type Emitter interface

+ Outputs func() map[string]workflow.DataType

+ type Engine struct

+ Builder BuildFunc

+ Secret string

+ func (e *Engine) Deploy(wf *workflow.Workflow, dm DeploymentMapping, ext *ExternalResources) error

+ func (e *Engine) IsRunning() bool

+ func (e *Engine) Stop()

+ type Event struct

+ Apply func(*Scope)

+ TargetState string

+ type Executable interface

+ Execute func(ctx context.Context, scope *Scope) (nextState string, err error)

+ type ExternalResources struct

+ MQTTs map[string]MQTTConnection

+ type Function struct

+ Actions map[string]Executable

+ DeclaredVars []workflow.Variable

+ Info workflow.FunctionInfo

+ InitialState string

+ OutputAssignments map[string]workflow.Expression

+ func (f *Function) Call(ctx context.Context, args map[string]expr.Value) (map[string]expr.Value, error)

+ type GPIOConfig struct

+ Chip string

+ type HasSetup interface

+ Setup func(ctx context.Context) error

+ type Lifecycle interface

+ Heartbeat func(ctx context.Context, address string) error

+ Register func(ctx context.Context, reg AgentRegistration) error

+ type LinearNode struct

+ func NewLinearNode(id string) LinearNode

+ func (b *LinearNode) AddTransition(port string, tr Transition) error

+ func (b *LinearNode) ID() string

+ func (b *LinearNode) Next(port string, scope *Scope) (string, error)

+ type LlmClient interface

+ Chat func(ctx context.Context, req *llmproxy.ChatRequest) (*llmproxy.ChatResponse, error)

+ type MQTTConnection struct

+ BrokerURL string

+ ClientID string

+ Password string

+ PublishPrefix string

+ SubscribePrefix string

+ Username string

+ Will *MQTTWill

+ type MQTTWill struct

+ Payload string

+ Qos int

+ Retain bool

+ Topic string

+ type MemoryStore interface

+ Snapshot func(ctx context.Context) ([]workflow.MemoryFile, error)

+ Upsert func(ctx context.Context, uid, content string) error

+ type MissingFieldError struct

+ Field string

+ NodeID string

+ func (e *MissingFieldError) Error() string

+ type PWMConfig struct

+ Chip string

+ type RAGQueryParams struct

+ CollectionID string

+ Query string

+ TopK int

+ type RAGQueryResult struct

+ ChunkID string

+ Content string

+ DocumentID string

+ Score float64

+ type ResourceBinding struct

+ Index *int

+ Ref string

+ type Retriever interface

+ QueryRAG func(ctx context.Context, params RAGQueryParams) ([]RAGQueryResult, error)

+ type RetryConfig struct

+ AttemptTimeout time.Duration

+ Interval time.Duration

+ type Runner struct

+ InitialState string

+ Nodes map[string]Executable

+ Scope *Scope

+ Transports TransportRegistry

+ Triggers map[string]Trigger

+ func (r *Runner) Run(ctx context.Context) error

+ type Scope struct

+ Conversation llmproxy.InputItems

+ Vars map[string]expr.Value

+ func NewFunctionScope(declaredVars []workflow.Variable, args map[string]expr.Value) (*Scope, error)

+ func NewMainScope(declaredVars []workflow.Variable) (*Scope, error)

+ func (s *Scope) GetConversation() llmproxy.InputItems

+ func (s *Scope) Resolve(ref workflow.Reference) (expr.Value, error)

+ func (s *Scope) Set(srcId, varId string, v expr.Value)

+ func (s *Scope) SetConversation(in llmproxy.Input)

+ func (s *Scope) Subscribe(srcId, varId string) <-chan expr.Value

+ type SerialConfig struct

+ Baud int

+ Port string

+ type ToolNode struct

+ func NewToolNode(id string) ToolNode

+ func (b *ToolNode) AddTransition(port string, _ Transition) error

+ func (b *ToolNode) ID() string

+ type ToolProvider interface

+ Tools func() ([]llmproxy.FunctionTool, error)

+ type Transition struct

+ Description *string

+ EdgeType workflow.EdgeType

+ Prompt *workflow.Expression

+ TargetID string

+ func (tr Transition) Apply(scope *Scope) error

+ type TransportRegistry interface

+ CloseAll func() error

+ type Trigger interface

+ Close func() error

+ Wait func(ctx context.Context) (Event, error)

+ type TriggerNode struct

+ func NewTriggerNode(id string) TriggerNode

+ func (b *TriggerNode) AddTransition(_ string, tr Transition) error

+ func (b *TriggerNode) ID() string

+ func (b *TriggerNode) Target() string

+ type Wirable interface

+ AddTransition func(port string, tr Transition) error

+ ID func() string