Run starts all trigger goroutines and the state-runner loop. One iteration = one node execution or one event consumed. Runs indefinitely until ctx is

Get returns a value and a boolean if found

Run executes a workflow starting at the given agent. The agent runs in a loop until a final output is generated or the maximum number of turns is reac

write is the shared mutation path: lock, transform, size-check, persist locally, commit in-memory. The device write is the source of truth — if it fai

String returns a human-readable representation of the item, including its type. This is used to serialize the item as plain text if the model only sup

Set updates the value of a variable in the scope and notifies subscribers.

NewMainScope creates a scope for the main workflow, initialized with the given declared variables.

Close releases resources on shutdown. Runner calls this even if Setup failed partway, so implementations should guard nil fields.

Len returns number of entries

* Base options for a "neutral" node: real type "OnStartup" (no input ports, no tool ports, * no output warnings when paired with a non-Trigger synthe

newAgentNode builds an Agent node with a no-provider llmproxy client. The returned agent never invokes the runner during the tests below — only pure h

analyze folds v into the trigger's side-of-signal state and returns whether this crossing matches the configured direction. First event always seeds t

Eval evaluates an workflow.Expression against resolved references, returning a typed Value.

Do sends a request and decodes the JSON response into the provided 'out'. Pass a pointer as 'out' (e.g. &myStruct). If out is nil, the response body i

Apply runs the edge-type-specific side effect against the scope before the state machine moves on.

Next applies the outgoing transition's side effects (e.g. AgentTask prompt evaluation) against the scope and returns the target node ID. Returns State

* A required wire field the workflow may not have yet: drafts save on purpose, * and deserialize mirrors this with `??` fallbacks. serialize() emits

newTestThreshold constructs an OnThreshold against a fresh scope and returns the trigger plus the scope used to push values.

Wait blocks until the trigger fires or ctx cancels, then returns the event or error.

* Check if a type is numeric (int or float)

newTestChatProvider creates a Provider with a single chat model pointing to the given server URL.

NewClient constructs a Client backed by the shared httpclient.

ProviderID returns the unique identifier of the LLM provider.

Subscribe returns a buffered channel of messages matching filter. Each call creates a separate subscription with its own channel; sends are non-blocki

ToolName returns the name of the tool.

--- Test Helpers --- newTestServer creates an httptest server that handles /v1/models and /v1/chat/completions. The chatHandler is called for POST /v1

Call runs the function in a fresh FunctionScope and returns the computed return values keyed by return uid.

NewAlarm builds an Alarm from a "HH:MM" string and an optional list of day abbreviations ("mon", "tue", ...). Returns an error on malformed input.

NewFunctionCall builds a FunctionCall. Validates that every declared return has a matching output binding.

Outputs returns the output a node does actually emit (bindingMode = emit)

AvailableModels returns a list of supported models by the LLM service.