MCPcopy Create free account

hub / github.com/ForestHubAI/edge-agents / functions

Functions2,454 in github.com/ForestHubAI/edge-agents

↓ 8 callersMethodError
()
go/api/engineapi/server.gen.go:61
↓ 8 callersMethodHealth
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 callersFunctionNewAgent
NewAgent creates a new Agent with the given name and applies any provided options.
go/llmproxy/agent/agent.go:37
↓ 8 callersFunctionWithInstructions
WithInstructions sets the Instructions field of the Agent.
go/llmproxy/agent/agent.go:49
↓ 8 callersFunctioncfgOf
(outputDir: string, p: Partial<DeployConfig> = {})
ts/workflow-cli/cli/deploy/write.test.ts:53
↓ 8 callersFunctionmf
mf is a terse MemoryFile builder for declarations and snapshots.
go/engine/memory/manager_test.go:20
↓ 8 callersFunctionmutate
* 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 callersMethodnextDelay
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 callersFunctionpassthroughFn
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 callersFunctionreqOf
(p: Partial<DeployRequirements> = {})
ts/workflow-cli/cli/deploy/write.test.ts:42
↓ 8 callersFunctionspecOf
(components: DeployComponent[] = [engineComponent()])
ts/workflow-cli/cli/deploy/write.test.ts:38
↓ 8 callersFunctiontmp
()
ts/workflow-cli/cli/deploy/write.test.ts:57
↓ 8 callersFunctionvarKey
(v: Variable)
ts/workflow-core/src/variable/operations.ts:16
↓ 7 callersMethodAddTransition
(port string, tr Transition)
go/engine/node.go:100
↓ 7 callersMethodCloseAll
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 callersFunctionNewManager
NewManager constructs a manager whose durable copy lives in dir. The directory is created lazily on Reconcile.
go/engine/memory/manager.go:73
↓ 7 callersMethodRead
Read returns the current content of the file identified by uid.
go/engine/memory/manager.go:144
↓ 7 callersMethodReconcile
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 callersFunctionagent
(id: string, model: string)
ts/workflow-core/src/deploy/requirements.test.ts:12
↓ 7 callersFunctionagentBase
(outputDeclarations: unknown[], availableVariables: Record<string, ReturnType<typeof makeDeclaredVar>> = {})
ts/workflow-core/src/diagnostics/diagnostics.test.ts:558
↓ 7 callersFunctionhardwareConflicts
(channels: HardwareChannel[], bindings: Record<string, HardwareBinding>)
ts/workflow-core/src/deploy/spec.ts:144
↓ 7 callersFunctionhw
(id: string, family: "gpio" | "serial")
ts/workflow-cli/cli/deploy/index.test.ts:26
↓ 7 callersFunctionisExpression
(value: unknown)
ts/workflow-core/src/expression/types.ts:31
↓ 7 callersFunctionmakeRes
()
ts/workflow-cli/server/fileBridge.test.ts:30
↓ 7 callersMethodmatches
matches reports whether an edge of the given polarity matches the trigger's configured filter.
go/engine/node/trigger/pinedge.go:61
↓ 7 callersMethodnext
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 callersFunctionparamKey
(p: ApiVariable)
ts/workflow-core/src/variable/operations.ts:74
↓ 7 callersFunctionparseChoiceToken
parseChoiceToken extracts the branch index from a choice_N token and verifies it is within range.
go/engine/node/agent.go:245
↓ 7 callersFunctionreadSchemaVersion
(doc: Record<string, unknown>)
ts/workflow-core/src/migration/migrate.ts:33
↓ 7 callersFunctionsection
(label: string, count = 0)
ts/workflow-cli/cli/deploy/prompts.ts:232
↓ 7 callersFunctiontrapExit
()
ts/workflow-cli/cli/deploy/index.test.ts:29
↓ 7 callersFunctionwriteSysfsString
(path, value string)
go/engine/driver/pwm_linux.go:158
↓ 6 callersMethodCast
Cast converts a value to the target data type.
go/engine/expr/value.go:120
↓ 6 callersMethodEmbeddingDimension
(model ModelID)
go/llmproxy/provider.go:43
↓ 6 callersFunctionNewLinearNode
NewLinearNode creates a new LinearNode
go/engine/node.go:95
↓ 6 callersFunctionNewTestRunner
NewTestRunner creates a new Runner with the given mock provider for testing purposes.
go/llmproxy/agent/runner_test.go:23
↓ 6 callersMethodRead
Read blocks until one line arrives (therefore takes context). Errors if another Read is in flight.
go/engine/driver/driver.go:75
↓ 6 callersMethodToolDescription
()
go/llmproxy/tools.go:73
↓ 6 callersMethodToolParams
()
go/llmproxy/tools.go:74
↓ 6 callersMethodapplyStructuredOutputs
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 callersMethodbuildResponseFormat
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 callersFunctionchoiceToken
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 callersFunctionclearRFselect
(canvasId: string)
ts/workflow-builder/src/stores/editorStore.ts:42
↓ 6 callersFunctioncompareValues
(a, b Value)
go/engine/expr/parser.go:395
↓ 6 callersFunctiondeclaredVarKey
(uid: string)
ts/workflow-core/src/variable/operations.ts:28
↓ 6 callersFunctiondeserialize
(workflow: Schemas["Workflow"])
ts/workflow-core/src/workflow/serialization.ts:88
↓ 6 callersFunctionfamilyMismatches
(channels: HardwareChannel[], bindings: Record<string, HardwareBinding>)
ts/workflow-core/src/deploy/spec.ts:164
↓ 6 callersFunctionfn
(over: Partial<FunctionDeclaration> = {})
ts/workflow-core/src/diagnostics/diagnostics.test.ts:855
↓ 6 callersFunctionisNodeUsedAsTool
(nodeId: string, nodeData: NodeData, edges: readonly Edge[])
ts/workflow-core/src/node/methods.ts:276
↓ 6 callersFunctionmakeNode
(type: string, args: Record<string, unknown>)
ts/workflow-core/src/node/serialization.test.ts:11
↓ 6 callersFunctionmode
(file: string)
ts/workflow-cli/cli/deploy/write.test.ts:59
↓ 6 callersFunctionnewEmbeddingTestServer
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 callersFunctionnewTestEmbeddingProvider
newTestEmbeddingProvider creates a Provider with a single embedding model pointing to the given server URL.
go/llmproxy/provider/selfhosted/provider_test.go:113
↓ 6 callersFunctionnewTestProvider
newTestProvider returns a MockProvider with default behavior for its ID.
go/llmproxy/client_test.go:17
↓ 6 callersFunctionnewTestSerialReceive
(id string, binding workflow.OutputBinding, incoming <-chan string)
go/engine/node/trigger/serialreceive_test.go:21
↓ 6 callersFunctionpartialFromFlags
(flags: RawFlags, fileValues: Partial<DeployConfig>)
ts/workflow-cli/cli/deploy/index.ts:109
↓ 6 callersFunctionretrieverBase
(outputBinding: unknown, availableVariables: Record<string, ReturnType<typeof makeDeclaredVar>> = {})
ts/workflow-core/src/diagnostics/diagnostics.test.ts:485
↓ 6 callersFunctionserialize
(state: Workflow)
ts/workflow-core/src/workflow/serialization.ts:35
↓ 6 callersFunctionserialize
(node: Node, isToolInput: boolean)
ts/workflow-core/src/node/serialization.ts:40
↓ 6 callersFunctionsidecarServiceName
(modelId: string)
ts/workflow-core/src/deploy/spec.ts:106
↓ 6 callersFunctionuniqueName
(desired: string, existing: Iterable<string>)
ts/workflow-builder/src/utils/resourceHelpers.ts:30
↓ 6 callersFunctionunwrapFromArgs
(value: FromArgs<T>, args: Record<string, unknown>)
ts/workflow-core/src/parameter/Parameter.ts:22
↓ 6 callersFunctionuseAvailableVariables
(canvasId: string = MAIN_CANVAS_ID)
ts/workflow-builder/src/hooks/useAvailableVariables.ts:18
↓ 5 callersFunctionApplyDeclaration
ApplyDeclaration stores a value into the scope according to the declaration mode.
go/engine/scope.go:119
↓ 5 callersMethodExecute
(ctx context.Context, scope *engine.Scope)
go/engine/node/functioncall.go:68
↓ 5 callersMethodExecute
(ctx context.Context, scope *engine.Scope)
go/engine/node/if.go:35
↓ 5 callersFunctionLastUserInput
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 callersFunctionNewIf
NewIf builds an If node.
go/engine/node/if.go:28
↓ 5 callersFunctionNewTicker
(id string, interval time.Duration)
go/engine/node/trigger/ticker.go:22
↓ 5 callersFunctionSlice
Slice maps a slice of type A to a slice of type B, passing pointers to mappingFunc
go/mapping/util.go:8
↓ 5 callersMethodTransitions
(port string)
go/engine/node.go:139
↓ 5 callersFunctionadd
(loaded: LoadedComponent)
ts/workflow-cli/cli/deploy/components.ts:176
↓ 5 callersFunctioncanvas
(nodes: Node[])
ts/workflow-core/src/deploy/requirements.test.ts:28
↓ 5 callersFunctionchannel
(id: string, type: Channel["type"], args: Record<string, unknown> = {})
ts/workflow-core/src/deploy/spec.test.ts:27
↓ 5 callersFunctionclearAllCanvasStores
()
ts/workflow-builder/src/stores/canvasStore.ts:240
↓ 5 callersFunctioncloseFamily
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 callersFunctioncomputeVariablesFromNodes
(nodes: NodeData[])
ts/workflow-core/src/workflow/serialization.ts:171
↓ 5 callersFunctionderiveRequirements
(workflow: Workflow)
ts/workflow-core/src/deploy/requirements.ts:106
↓ 5 callersFunctiondispatch
(action: Action)
ts/workflow-builder/src/hooks/use-toast.ts:86
↓ 5 callersFunctionengineConfigOf
(spec: Spec)
ts/workflow-core/src/deploy/spec.test.ts:22
↓ 5 callersFunctionenvFile
(cfg: DeployConfig)
ts/workflow-cli/cli/deploy/generate.ts:154
↓ 5 callersFunctionfileUrl
()
ts/workflow-cli/server/fileBridge.test.ts:80
↓ 5 callersFunctionflagsOf
(p: Partial<RawFlags> = {})
ts/workflow-cli/cli/deploy/index.test.ts:12
↓ 5 callersFunctiongetAllCanvasStores
()
ts/workflow-builder/src/stores/canvasStore.ts:224
↓ 5 callersFunctiongetCanvasStore
(canvasId: string)
ts/workflow-builder/src/stores/canvasStore.ts:192
↓ 5 callersFunctiongetReferencedCatalogModelIds
(workflow: Workflow)
ts/workflow-core/src/deploy/requirements.ts:22
↓ 5 callersFunctionhardwareAddressKey
(family: HardwareFamily, chipOrDevice: string, index?: number)
ts/workflow-core/src/deploy/spec.ts:130
↓ 5 callersFunctioninferType
* Recursively infer the type of an AST node
ts/workflow-core/src/expression/parser.ts:100
↓ 5 callersFunctionisEmpty
(value: unknown)
ts/workflow-core/src/parameter/Parameter.ts:182
↓ 5 callersFunctionllamaComponent
(overrides: Partial<DeployComponent> = {})
ts/workflow-cli/cli/deploy/generate.test.ts:40
↓ 5 callersFunctionlookup
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 callersFunctionmakeMemories
(memories: Memory[])
ts/workflow-core/src/diagnostics/__fixtures__/diagnosticFixtures.ts:117
↓ 5 callersFunctionmakeMemory
(overrides: Partial<Memory> = {})
ts/workflow-core/src/diagnostics/__fixtures__/diagnosticFixtures.ts:107
↓ 5 callersFunctionnewMockllmClient
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 callersFunctionnewTestPinEdge
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 callersFunctionnodeOutputVarKey
(nodeId: string, outputId: string)
ts/workflow-core/src/variable/operations.ts:38
↓ 5 callersMethodparseAddSub
()
go/engine/expr/parser.go:158
↓ 5 callersFunctionprinted
()
ts/workflow-cli/cli/deploy/prompts.test.ts:231
↓ 5 callersFunctionpromptCustomComponents
( preloaded: LoadedComponent[], )
ts/workflow-cli/cli/deploy/components.ts:168
↓ 5 callersFunctionreadSysfsFloat
(path string)
go/engine/driver/adc_linux.go:103
← previousnext →101–200 of 2,454, ranked by callers