Code
Hub
Workspaces
Following
Trending
Connect
MCP
copy
Create free account
hub
/
github.com/ruvnet/ruflo
/ functions
Functions
18,477 in github.com/ruvnet/ruflo
⨍
Functions
18,477
◇
Types & classes
6,101
↓ 5 callers
Function
memoryListAllKeys
(namespace)
plugins/ruflo-cost-tracker/scripts/_sessions.mjs:23
↓ 5 callers
Function
mergeDeep
* Deep merge utility
v3/@claude-flow/testing/src/fixtures/configurations.ts:446
↓ 5 callers
Function
mkResult
( success: boolean, entriesMigrated: number, sourceFormat: string, targetFormat: string, startMs: number,
v3/@claude-flow/memory/src/rvf-migration.ts:96
↓ 5 callers
Method
mobiusAdd
* Mobius addition in the Poincare ball. * * a +_M b = ((1 + 2c<a,b> + c||b||^2)a + (1 - c||a||^2)b) / (1 + 2c<a,b> + c^2||a||^2||b||^2) *
v3/@claude-flow/plugins/src/integrations/ruvector/hyperbolic.ts:620
↓ 5 callers
Function
mockExecFailure
(error: Error)
v3/plugins/gastown-bridge/tests/bridges.test.ts:280
↓ 5 callers
Function
mockFetchSequence
* Build a mock `fetch` that simulates a specific turn sequence. * * `sequence` is an array of stop_reasons. The mock returns `tool_use` * response
v3/@claude-flow/cli/src/benchmarks/gaia-agent-planning.smoke.ts:65
↓ 5 callers
Function
mockUrl
()
ruflo/src/ruvocal/src/lib/server/api/__tests__/conversations-id.spec.ts:18
↓ 5 callers
Function
mulberry32
(seed)
scripts/benchmark-intelligence.mjs:82
↓ 5 callers
Function
mulberry32
(seed)
plugins/ruflo-neural-trader/src/signed-attribution.mjs:218
↓ 5 callers
Function
observedComplexity
(iterations: number, n: number)
plugins/ruflo-graph-intelligence/src/infrastructure/solver-bridge.ts:274
↓ 5 callers
Function
ok
(payload: Record<string, unknown>)
v3/@claude-flow/cli/src/mcp-tools/browser-session-tools.ts:69
↓ 5 callers
Method
openUploadStream
( filename: string, options?: { metadata?: Record<string, unknown>; contentType?: string } )
ruflo/src/ruvocal/src/lib/server/database/rvf.ts:1020
↓ 5 callers
Function
openWithLineage
* Open (or create) a base memory file. When a lineage manifest exists at * `<file>.agenticow.json`, we load that to restore the COW chain (checkpoint
v3/@claude-flow/cli/src/mcp-tools/agenticow-tools.ts:106
↓ 5 callers
Function
parse
(argv: string[])
v3/@claude-flow/cli/__tests__/bug-cluster-2219-2226.test.ts:200
↓ 5 callers
Method
parseGuidanceFile
* Parse a guidance markdown file into rules
v3/@claude-flow/guidance/src/compiler.ts:131
↓ 5 callers
Function
parseResult
(result: MCPToolResult)
v3/plugins/quantum-optimizer/tests/validate.ts:10
↓ 5 callers
Function
parseResult
(result: MCPToolResult)
v3/plugins/hyperbolic-reasoning/tests/validate.ts:10
↓ 5 callers
Function
parseResult
(result: MCPToolResult)
v3/plugins/perf-optimizer/tests/validate.ts:10
↓ 5 callers
Function
pass
(msg)
scripts/smoke-agent-execute-providers.mjs:31
↓ 5 callers
Function
pass
(msg)
scripts/smoke-ruvllm-wasm-auto-init.mjs:38
↓ 5 callers
Function
pass
(msg)
v3/@claude-flow/memory/scripts/smoke-no-bsqlite.mjs:26
↓ 5 callers
Method
peers
Currently-reachable peer node ids (excludes self).
v3/@claude-flow/swarm/src/consensus/transport.ts:77
↓ 5 callers
Function
percentile
(sorted, p)
scripts/tune-ensemble-threshold.mjs:51
↓ 5 callers
Function
percentile
(arr: number[], p: number)
v3/@claude-flow/memory/benchmarks/longmemeval/harness.ts:174
↓ 5 callers
Function
poincareToEuclidean
( poincare: Float32Array | number[], config: HyperbolicConfig = {} )
v3/@claude-flow/embeddings/src/hyperbolic.ts:113
↓ 5 callers
Method
predict
* Predict the hardness class of a single GAIA question. * * Cold-start (untrained): returns medium with confidence=0.5.
v3/@claude-flow/cli/src/benchmarks/gaia-hardness/predictor.ts:245
↓ 5 callers
Method
predict
(input: Record<string, unknown>)
v3/@claude-flow/plugin-iot-cognitum/src/domain/services/sona-integration-service.ts:8
↓ 5 callers
Function
prepareRelease
( options: ReleaseOptions = {} )
v3/@claude-flow/deployment/src/release-manager.ts:375
↓ 5 callers
Method
previewRebalance
* Preview rebalance without applying changes
v3/@claude-flow/claims/src/application/load-balancer.ts:202
↓ 5 callers
Method
processBatch
* Process a batch of telemetry readings: run anomaly detection on each, * and return the results.
v3/@claude-flow/plugin-iot-cognitum/src/domain/services/telemetry-ingestion-service.ts:31
↓ 5 callers
Method
processPendingWorkers
* Process pending workers queue * * When executeWorkerWithConcurrencyControl defers a worker (returns null), * we break immediately to avoid
v3/@claude-flow/cli/src/services/worker-daemon.ts:638
↓ 5 callers
Function
publishToNpm
( options: PublishOptions = {} )
v3/@claude-flow/deployment/src/publisher.ts:246
↓ 5 callers
Method
pushDelta
* Apply a delta event. The bridge picks `solve_on_change` if the delta is * sparse enough; otherwise it falls back to a full re-solve.
plugins/ruflo-graph-intelligence/src/application/streaming-bridge.ts:91
↓ 5 callers
Method
queryDevice
* Run a k-NN query against a device's vector store.
v3/@claude-flow/plugin-iot-cognitum/src/domain/services/telemetry-service.ts:80
↓ 5 callers
Function
readFile
(path: string)
ruflo/src/ruvocal/src/lib/wasm/idb.ts:169
↓ 5 callers
Method
readMemory
(key: string, namespace: string)
v3/@claude-flow/guidance/src/conformance-kit.ts:99
↓ 5 callers
Method
readU32
()
v3/@claude-flow/cli/src/appliance/gguf-engine.ts:85
↓ 5 callers
Method
rebalance
()
v3/@claude-flow/swarm/src/types.ts:483
↓ 5 callers
Method
recall
(query: string, topK = 5)
v3/@claude-flow/memory/src/controller-registry.ts:1214
↓ 5 callers
Method
recordCoordinationLatency
(latencyMs: number)
v3/@claude-flow/swarm/src/unified-coordinator.ts:1032
↓ 5 callers
Method
recordOutcome
* Record pattern usage outcome
v3/@claude-flow/hooks/src/reasoningbank/index.ts:541
↓ 5 callers
Method
recordStorageUsage
* Record storage usage in bytes.
v3/@claude-flow/guidance/src/coherence.ts:372
↓ 5 callers
Method
recordSuccess
* Record a successful operation
v3/@claude-flow/cli/src/production/circuit-breaker.ts:134
↓ 5 callers
Function
recordTrajectoryOutcome
(args: { task: string; quality: number; scores?: Record<string, number>; source?: string; /** iter 3
v3/@claude-flow/cli/src/ruvector/router-trajectory.ts:246
↓ 5 callers
Method
registerLazyCommandName
* Register a lazy-loaded command's name so Pass 1/Pass 2 can recognize it as * a command position even though its full definition hasn't been loade
v3/@claude-flow/cli/src/parser.ts:118
↓ 5 callers
Method
release
(err?: Error)
v3/@claude-flow/plugins/src/integrations/ruvector/streaming.ts:32
↓ 5 callers
Method
removeAgent
(agentId: string)
v3/@claude-flow/testing/src/helpers/mock-factory.ts:252
↓ 5 callers
Function
reqNum
(o, k, p)
plugins/ruflo-business-pods/scripts/pod-tick.mjs:109
↓ 5 callers
Function
requireNumber
(parent: Record<string, unknown>, key: string, path: string)
v3/@claude-flow/cli/src/business-pods/pod-schema.ts:101
↓ 5 callers
Function
resolveDbPath
(cliFlag?: string)
v3/@claude-flow/cli/src/memory/memory-initializer.ts:103
↓ 5 callers
Function
resolveLoopPaths
(projectPath: string, name = 'default', stateDir?: string)
v3/@claude-flow/codex/src/loop/index.ts:67
↓ 5 callers
Method
retrieve
(namespace: string, key: string)
v3/plugins/gastown-bridge/src/gupp/state.ts:435
↓ 5 callers
Method
rollbackRollout
* Force-rollback a rollout regardless of current stage.
v3/@claude-flow/plugin-iot-cognitum/src/domain/services/firmware-orchestration-service.ts:119
↓ 5 callers
Function
rollup
(findings)
v3/@claude-flow/cli/plugins/ruflo-metaharness/scripts/test-similarity.mjs:227
↓ 5 callers
Function
rollup
(findings)
plugins/ruflo-metaharness/scripts/test-similarity.mjs:227
↓ 5 callers
Method
rowToEntry
(row: any)
v3/@claude-flow/memory/src/sqlite-backend.ts:748
↓ 5 callers
Method
rowToEntry
(row: any)
v3/@claude-flow/memory/src/sqljs-backend.ts:791
↓ 5 callers
Function
run
(args = [])
scripts/__tests__/audit-supply-chain.test.mjs:22
↓ 5 callers
Method
runFullAudit
()
v3/@claude-flow/security/__tests__/acceptance/security-compliance.test.ts:19
↓ 5 callers
Function
runMetaharness
(args, opts)
plugins/ruflo-metaharness/scripts/_harness.mjs:128
↓ 5 callers
Function
runPageRank
(matrix: SparseMatrix, query: PageRankQuery)
plugins/ruflo-graph-intelligence/src/infrastructure/solver-bridge.ts:288
↓ 5 callers
Method
runStressTest
* Run stress test with increasing load
v3/@claude-flow/performance/src/attention-benchmarks.ts:190
↓ 5 callers
Function
runViaComponent
()
v3/@claude-flow/cli/__tests__/doctor-encryption.test.ts:68
↓ 5 callers
Function
safeJSONParse
* Safely parse JSON with size limits
v3/plugins/teammate-plugin/src/teammate-bridge.ts:217
↓ 5 callers
Function
safePercentage
(used: number, limit: number)
v3/@claude-flow/guidance/src/coherence.ts:531
↓ 5 callers
Function
saveAgentStore
(store: AgentStore)
v3/@claude-flow/cli/src/mcp-tools/agent-tools.ts:80
↓ 5 callers
Function
saveDeploymentState
(cwd: string, state: DeploymentState)
v3/@claude-flow/cli/src/commands/deployment.ts:68
↓ 5 callers
Method
saveToFile
* Save database to file
v3/@claude-flow/embeddings/src/persistent-cache.ts:158
↓ 5 callers
Function
scanSourceFiles
* Helper: Scan directory for source files
v3/@claude-flow/cli/src/commands/analyze.ts:1290
↓ 5 callers
Method
search
(query: HyperbolicPoint, index: string, k: number)
v3/plugins/hyperbolic-reasoning/src/types.ts:516
↓ 5 callers
Method
search
(embedding: Float32Array, k: number, options?: SearchOptions)
v3/plugins/agentic-qe/src/bridges/QEMemoryBridge.ts:31
↓ 5 callers
Function
searchExact
( store: QuantizedVectorStore, query: number[], k: number, metric: 'cosine' | 'euclidean' = 'cosine' )
v3/@claude-flow/plugins/__tests__/ruvector-quantization.test.ts:306
↓ 5 callers
Method
selectMode
(messageType: FederationMessageType)
v3/@claude-flow/plugin-agent-federation/src/domain/services/routing-service.ts:51
↓ 5 callers
Method
sendError
(id: string | number | null, code: number, message: string)
v3/@claude-flow/mcp/src/transport/stdio.ts:205
↓ 5 callers
Method
sendError
* Send error response
v3/@claude-flow/shared/src/mcp/transport/stdio.ts:262
↓ 5 callers
Method
sendError
* Send error response
v3/mcp/transport/stdio.ts:262
↓ 5 callers
Method
sendMessage
* Send a message to another agent
v3/@claude-flow/hooks/src/swarm/index.ts:228
↓ 5 callers
Function
sessionTs
(rec)
plugins/ruflo-cost-tracker/scripts/_sessions.mjs:63
↓ 5 callers
Method
setCoherenceScore
(score: number)
v3/@claude-flow/guidance/src/conformance-kit.ts:112
↓ 5 callers
Method
setColorEnabled
(enabled: boolean)
v3/@claude-flow/cli-core/src/output.ts:482
↓ 5 callers
Method
setKvEntry
Store a key-value pair in the in-memory KV cache.
v3/@claude-flow/cli/src/appliance/gguf-engine.ts:426
↓ 5 callers
Function
setNestedValue
(obj: Record<string, unknown>, path: string, value: unknown)
ruflo/src/ruvocal/src/lib/server/database/rvf.ts:432
↓ 5 callers
Method
setThresholds
* Configure coherence thresholds * @param thresholds New threshold values
v3/plugins/prime-radiant/src/interfaces.ts:384
↓ 5 callers
Method
shutdown
()
v3/@claude-flow/swarm/src/coordination/swarm-hub.ts:64
↓ 5 callers
Method
shutdown
* Shutdown the plugin
v3/@claude-flow/shared/src/plugins/types.ts:68
↓ 5 callers
Method
sign
Returns an Ed25519 signature (base64) over the given canonical bytes.
v3/@claude-flow/plugin-agent-federation/src/domain/services/wg-witness-service.ts:68
↓ 5 callers
Function
skip
(name, reason)
ruflo/src/ruvocal/mcp-bridge/test-harness.js:44
↓ 5 callers
Function
skip
(name, reason)
ruflo/src/mcp-bridge/test-harness.js:44
↓ 5 callers
Method
sling
(beadId: string, target: SlingTarget, formula?: string, priority?: number)
v3/plugins/gastown-bridge/src/types.ts:843
↓ 5 callers
Function
spawnAsync
Spawn a child process and capture stdout/stderr.
v3/@claude-flow/cli/src/appliance/rvfa-runner.ts:38
↓ 5 callers
Method
startPeriodicDiscovery
()
v3/@claude-flow/plugin-agent-federation/src/domain/services/discovery-service.ts:168
↓ 5 callers
Function
stopDaemon
()
v3/@claude-flow/cli/src/services/worker-daemon.ts:1711
↓ 5 callers
Method
stopPeriodicDiscovery
()
v3/@claude-flow/plugin-agent-federation/src/domain/services/discovery-service.ts:175
↓ 5 callers
Method
stopWatching
* Stop watching a convoy
v3/plugins/gastown-bridge/src/convoy/observer.ts:543
↓ 5 callers
Function
streamText
(updates: MessageUpdate[])
ruflo/src/ruvocal/src/lib/utils/messageUpdates.spec.ts:23
↓ 5 callers
Method
stripAnsi
(text: string)
v3/@claude-flow/cli-core/src/output.ts:369
↓ 5 callers
Function
sub
* Subtracts vector b from vector a.
v3/@claude-flow/plugins/src/integrations/ruvector/hyperbolic.ts:89
↓ 5 callers
Method
submitPlan
* Submit a plan for approval
v3/plugins/teammate-plugin/src/teammate-bridge.ts:1213
↓ 5 callers
Method
subscribe
(eventType: EventType, handler: EventHandler<T>)
v3/@claude-flow/shared/src/events.ts:68
↓ 5 callers
Method
sweepExpired
* Drop all entries whose `expiresAt` is in the past.
v3/@claude-flow/memory/src/consolidator.ts:90
← previous
next →
2,201–2,300 of 18,477, ranked by callers