Code
Hub
Workspaces
Following
Trending
Connect
MCP
copy
Create free account
hub
/
github.com/ForestHubAI/edge-agents
/ functions
Functions
2,454 in github.com/ForestHubAI/edge-agents
⨍
Functions
2,454
◇
Types & classes
941
↓ 8 callers
Method
Error
()
go/api/engineapi/server.gen.go:61
↓ 8 callers
Method
Health
Health verifies that the LLM service is available and responding. Returns an error if the service is unreachable or unhealthy.
go/llmproxy/provider.go:22
↓ 8 callers
Function
NewAgent
NewAgent creates a new Agent with the given name and applies any provided options.
go/llmproxy/agent/agent.go:37
↓ 8 callers
Function
WithInstructions
WithInstructions sets the Instructions field of the Agent.
go/llmproxy/agent/agent.go:49
↓ 8 callers
Function
cfgOf
(outputDir: string, p: Partial<DeployConfig> = {})
ts/workflow-cli/cli/deploy/write.test.ts:53
↓ 8 callers
Function
mf
mf is a terse MemoryFile builder for declarations and snapshots.
go/engine/memory/manager_test.go:20
↓ 8 callers
Function
mutate
* Apply an update to one function. `bumpVersion` is true for signature changes * (name/arguments/outputs declaration) so call sites detect staleness,
ts/workflow-builder/src/utils/functionOperations.ts:43
↓ 8 callers
Method
nextDelay
nextDelay returns the duration from now until the next matching fire time. Always strictly positive — if HH:MM has already passed today (or today is n
go/engine/node/trigger/alarm.go:85
↓ 8 callers
Function
passthroughFn
passthroughFn returns a Function with one Int arg "a" and one Int return "ret" where ret = a (passthrough). InitialState is idle so Function.Call eval
go/engine/node/functioncall_test.go:25
↓ 8 callers
Function
reqOf
(p: Partial<DeployRequirements> = {})
ts/workflow-cli/cli/deploy/write.test.ts:42
↓ 8 callers
Function
specOf
(components: DeployComponent[] = [engineComponent()])
ts/workflow-cli/cli/deploy/write.test.ts:38
↓ 8 callers
Function
tmp
()
ts/workflow-cli/cli/deploy/write.test.ts:57
↓ 8 callers
Function
varKey
(v: Variable)
ts/workflow-core/src/variable/operations.ts:16
↓ 7 callers
Method
AddTransition
(port string, tr Transition)
go/engine/node.go:100
↓ 7 callers
Method
CloseAll
CloseAll shuts down every driver. Returns the first error encountered; keeps going on failures so no handle leaks.
go/engine/driver/registry.go:90
↓ 7 callers
Function
NewManager
NewManager constructs a manager whose durable copy lives in dir. The directory is created lazily on Reconcile.
go/engine/memory/manager.go:73
↓ 7 callers
Method
Read
Read returns the current content of the file identified by uid.
go/engine/memory/manager.go:144
↓ 7 callers
Method
Reconcile
Reconcile converges the working copy to the files declared by the current deploy. Called from Builder.Build, so every deploy reconciles state (boot an
go/engine/memory/manager.go:89
↓ 7 callers
Function
agent
(id: string, model: string)
ts/workflow-core/src/deploy/requirements.test.ts:12
↓ 7 callers
Function
agentBase
(outputDeclarations: unknown[], availableVariables: Record<string, ReturnType<typeof makeDeclaredVar>> = {})
ts/workflow-core/src/diagnostics/diagnostics.test.ts:558
↓ 7 callers
Function
hardwareConflicts
(channels: HardwareChannel[], bindings: Record<string, HardwareBinding>)
ts/workflow-core/src/deploy/spec.ts:144
↓ 7 callers
Function
hw
(id: string, family: "gpio" | "serial")
ts/workflow-cli/cli/deploy/index.test.ts:26
↓ 7 callers
Function
isExpression
(value: unknown)
ts/workflow-core/src/expression/types.ts:31
↓ 7 callers
Function
makeRes
()
ts/workflow-cli/server/fileBridge.test.ts:30
↓ 7 callers
Method
matches
matches reports whether an edge of the given polarity matches the trigger's configured filter.
go/engine/node/trigger/pinedge.go:61
↓ 7 callers
Method
next
next resolves and applies the outgoing transition. `choice` is the model- emitted token ("choice_N") — consulted only when multiple branches exist, ig
go/engine/node/agent.go:212
↓ 7 callers
Function
paramKey
(p: ApiVariable)
ts/workflow-core/src/variable/operations.ts:74
↓ 7 callers
Function
parseChoiceToken
parseChoiceToken extracts the branch index from a choice_N token and verifies it is within range.
go/engine/node/agent.go:245
↓ 7 callers
Function
readSchemaVersion
(doc: Record<string, unknown>)
ts/workflow-core/src/migration/migrate.ts:33
↓ 7 callers
Function
section
(label: string, count = 0)
ts/workflow-cli/cli/deploy/prompts.ts:232
↓ 7 callers
Function
trapExit
()
ts/workflow-cli/cli/deploy/index.test.ts:29
↓ 7 callers
Function
writeSysfsString
(path, value string)
go/engine/driver/pwm_linux.go:158
↓ 6 callers
Method
Cast
Cast converts a value to the target data type.
go/engine/expr/value.go:120
↓ 6 callers
Method
EmbeddingDimension
(model ModelID)
go/llmproxy/provider.go:43
↓ 6 callers
Function
NewLinearNode
NewLinearNode creates a new LinearNode
go/engine/node.go:95
↓ 6 callers
Function
NewTestRunner
NewTestRunner creates a new Runner with the given mock provider for testing purposes.
go/llmproxy/agent/runner_test.go:23
↓ 6 callers
Method
Read
Read blocks until one line arrives (therefore takes context). Errors if another Read is in flight.
go/engine/driver/driver.go:75
↓ 6 callers
Method
ToolDescription
()
go/llmproxy/tools.go:73
↓ 6 callers
Method
ToolParams
()
go/llmproxy/tools.go:74
↓ 6 callers
Method
applyStructuredOutputs
applyStructuredOutputs extracts the answer + each declared output from the parsed JSON and routes each value to its destination. "answer" goes through
go/engine/node/agent.go:331
↓ 6 callers
Method
buildResponseFormat
buildResponseFormat constructs the JSON schema covering "answer", each declared output (keyed by name), and a "choice" enum for multi-branch agents. B
go/engine/node/agent.go:303
↓ 6 callers
Function
choiceToken
choiceToken is the opaque enum value placed in the response schema for the branch at index i. Kept short and stable so the model can reproduce it reli
go/engine/node/agent.go:241
↓ 6 callers
Function
clearRFselect
(canvasId: string)
ts/workflow-builder/src/stores/editorStore.ts:42
↓ 6 callers
Function
compareValues
(a, b Value)
go/engine/expr/parser.go:395
↓ 6 callers
Function
declaredVarKey
(uid: string)
ts/workflow-core/src/variable/operations.ts:28
↓ 6 callers
Function
deserialize
(workflow: Schemas["Workflow"])
ts/workflow-core/src/workflow/serialization.ts:88
↓ 6 callers
Function
familyMismatches
(channels: HardwareChannel[], bindings: Record<string, HardwareBinding>)
ts/workflow-core/src/deploy/spec.ts:164
↓ 6 callers
Function
fn
(over: Partial<FunctionDeclaration> = {})
ts/workflow-core/src/diagnostics/diagnostics.test.ts:855
↓ 6 callers
Function
isNodeUsedAsTool
(nodeId: string, nodeData: NodeData, edges: readonly Edge[])
ts/workflow-core/src/node/methods.ts:276
↓ 6 callers
Function
makeNode
(type: string, args: Record<string, unknown>)
ts/workflow-core/src/node/serialization.test.ts:11
↓ 6 callers
Function
mode
(file: string)
ts/workflow-cli/cli/deploy/write.test.ts:59
↓ 6 callers
Function
newEmbeddingTestServer
newEmbeddingTestServer creates an httptest server that handles /v1/models and /v1/embeddings. The embeddingHandler is called for POST /v1/embeddings.
go/llmproxy/provider/selfhosted/provider_test.go:69
↓ 6 callers
Function
newTestEmbeddingProvider
newTestEmbeddingProvider creates a Provider with a single embedding model pointing to the given server URL.
go/llmproxy/provider/selfhosted/provider_test.go:113
↓ 6 callers
Function
newTestProvider
newTestProvider returns a MockProvider with default behavior for its ID.
go/llmproxy/client_test.go:17
↓ 6 callers
Function
newTestSerialReceive
(id string, binding workflow.OutputBinding, incoming <-chan string)
go/engine/node/trigger/serialreceive_test.go:21
↓ 6 callers
Function
partialFromFlags
(flags: RawFlags, fileValues: Partial<DeployConfig>)
ts/workflow-cli/cli/deploy/index.ts:109
↓ 6 callers
Function
retrieverBase
(outputBinding: unknown, availableVariables: Record<string, ReturnType<typeof makeDeclaredVar>> = {})
ts/workflow-core/src/diagnostics/diagnostics.test.ts:485
↓ 6 callers
Function
serialize
(state: Workflow)
ts/workflow-core/src/workflow/serialization.ts:35
↓ 6 callers
Function
serialize
(node: Node, isToolInput: boolean)
ts/workflow-core/src/node/serialization.ts:40
↓ 6 callers
Function
sidecarServiceName
(modelId: string)
ts/workflow-core/src/deploy/spec.ts:106
↓ 6 callers
Function
uniqueName
(desired: string, existing: Iterable<string>)
ts/workflow-builder/src/utils/resourceHelpers.ts:30
↓ 6 callers
Function
unwrapFromArgs
(value: FromArgs<T>, args: Record<string, unknown>)
ts/workflow-core/src/parameter/Parameter.ts:22
↓ 6 callers
Function
useAvailableVariables
(canvasId: string = MAIN_CANVAS_ID)
ts/workflow-builder/src/hooks/useAvailableVariables.ts:18
↓ 5 callers
Function
ApplyDeclaration
ApplyDeclaration stores a value into the scope according to the declaration mode.
go/engine/scope.go:119
↓ 5 callers
Method
Execute
(ctx context.Context, scope *engine.Scope)
go/engine/node/functioncall.go:68
↓ 5 callers
Method
Execute
(ctx context.Context, scope *engine.Scope)
go/engine/node/if.go:35
↓ 5 callers
Function
LastUserInput
LastUserInput returns the last user-provided text from an Input. For InputString it returns the string itself; for InputItems it returns the last Inpu
go/llmproxy/input.go:49
↓ 5 callers
Function
NewIf
NewIf builds an If node.
go/engine/node/if.go:28
↓ 5 callers
Function
NewTicker
(id string, interval time.Duration)
go/engine/node/trigger/ticker.go:22
↓ 5 callers
Function
Slice
Slice maps a slice of type A to a slice of type B, passing pointers to mappingFunc
go/mapping/util.go:8
↓ 5 callers
Method
Transitions
(port string)
go/engine/node.go:139
↓ 5 callers
Function
add
(loaded: LoadedComponent)
ts/workflow-cli/cli/deploy/components.ts:176
↓ 5 callers
Function
canvas
(nodes: Node[])
ts/workflow-core/src/deploy/requirements.test.ts:28
↓ 5 callers
Function
channel
(id: string, type: Channel["type"], args: Record<string, unknown> = {})
ts/workflow-core/src/deploy/spec.test.ts:27
↓ 5 callers
Function
clearAllCanvasStores
()
ts/workflow-builder/src/stores/canvasStore.ts:240
↓ 5 callers
Function
closeFamily
closeFamily closes every driver in a map, draining it as it goes. Records the first Close error via firstErr; subsequent errors are dropped so all han
go/engine/driver/registry.go:114
↓ 5 callers
Function
computeVariablesFromNodes
(nodes: NodeData[])
ts/workflow-core/src/workflow/serialization.ts:171
↓ 5 callers
Function
deriveRequirements
(workflow: Workflow)
ts/workflow-core/src/deploy/requirements.ts:106
↓ 5 callers
Function
dispatch
(action: Action)
ts/workflow-builder/src/hooks/use-toast.ts:86
↓ 5 callers
Function
engineConfigOf
(spec: Spec)
ts/workflow-core/src/deploy/spec.test.ts:22
↓ 5 callers
Function
envFile
(cfg: DeployConfig)
ts/workflow-cli/cli/deploy/generate.ts:154
↓ 5 callers
Function
fileUrl
()
ts/workflow-cli/server/fileBridge.test.ts:80
↓ 5 callers
Function
flagsOf
(p: Partial<RawFlags> = {})
ts/workflow-cli/cli/deploy/index.test.ts:12
↓ 5 callers
Function
getAllCanvasStores
()
ts/workflow-builder/src/stores/canvasStore.ts:224
↓ 5 callers
Function
getCanvasStore
(canvasId: string)
ts/workflow-builder/src/stores/canvasStore.ts:192
↓ 5 callers
Function
getReferencedCatalogModelIds
(workflow: Workflow)
ts/workflow-core/src/deploy/requirements.ts:22
↓ 5 callers
Function
hardwareAddressKey
(family: HardwareFamily, chipOrDevice: string, index?: number)
ts/workflow-core/src/deploy/spec.ts:130
↓ 5 callers
Function
inferType
* Recursively infer the type of an AST node
ts/workflow-core/src/expression/parser.ts:100
↓ 5 callers
Function
isEmpty
(value: unknown)
ts/workflow-core/src/parameter/Parameter.ts:182
↓ 5 callers
Function
llamaComponent
(overrides: Partial<DeployComponent> = {})
ts/workflow-cli/cli/deploy/generate.test.ts:40
↓ 5 callers
Function
lookup
lookup returns the driver registered under id in the given typed map, or an error labelled with the family name.
go/engine/driver/registry.go:102
↓ 5 callers
Function
makeMemories
(memories: Memory[])
ts/workflow-core/src/diagnostics/__fixtures__/diagnosticFixtures.ts:117
↓ 5 callers
Function
makeMemory
(overrides: Partial<Memory> = {})
ts/workflow-core/src/diagnostics/__fixtures__/diagnosticFixtures.ts:107
↓ 5 callers
Function
newMockllmClient
newMockllmClient creates a new instance of mockllmClient. It also registers a testing interface on the mock and a cleanup function to assert the mocks
go/llmproxy/agent/mocks_test.go:16
↓ 5 callers
Function
newTestPinEdge
newTestPinEdge constructs an OnPinEdge wired to the given event channel. Bypasses NewOnPinEdge to avoid needing a real channel.GPIOInput.
go/engine/node/trigger/pinedge_test.go:35
↓ 5 callers
Function
nodeOutputVarKey
(nodeId: string, outputId: string)
ts/workflow-core/src/variable/operations.ts:38
↓ 5 callers
Method
parseAddSub
()
go/engine/expr/parser.go:158
↓ 5 callers
Function
printed
()
ts/workflow-cli/cli/deploy/prompts.test.ts:231
↓ 5 callers
Function
promptCustomComponents
( preloaded: LoadedComponent[], )
ts/workflow-cli/cli/deploy/components.ts:168
↓ 5 callers
Function
readSysfsFloat
(path string)
go/engine/driver/adc_linux.go:103
← previous
next →
101–200 of 2,454, ranked by callers