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
↓ 9 callers
Function
next
()
scripts/gen-seed-corpus.mjs:62
↓ 9 callers
Function
normaliseAnswer
(raw: string | null | undefined)
v3/@claude-flow/cli/src/benchmarks/gaia-judge.ts:89
↓ 9 callers
Method
notFound
* Create a BeadsError for a not found scenario
v3/plugins/gastown-bridge/src/errors.ts:207
↓ 9 callers
Method
on
(event: string, callback: (...args: unknown[]) => void)
v3/@claude-flow/plugins/src/integrations/ruvector/streaming.ts:52
↓ 9 callers
Method
onInitialize
(handler: (context: PluginContext) => Promise<void>)
v3/@claude-flow/plugins/src/sdk/index.ts:166
↓ 9 callers
Method
pairDevice
Pair a registered device, promoting its trust level.
v3/@claude-flow/plugin-iot-cognitum/src/application/iot-coordinator.ts:304
↓ 9 callers
Function
parseMarkdownEntries
(content: string)
v3/@claude-flow/memory/src/auto-memory-bridge.ts:812
↓ 9 callers
Method
parseOutput
(output: string, format: 'json' | 'text' | 'markdown')
v3/@claude-flow/cli/__tests__/services/headless-worker-executor.test.ts:278
↓ 9 callers
Function
pct
(n)
plugins/ruflo-cost-tracker/scripts/trend.mjs:48
↓ 9 callers
Method
persistState
* Persist current state to storage
v3/plugins/gastown-bridge/src/gupp/adapter.ts:262
↓ 9 callers
Method
predictFailingTests
(changes: CodeChange[], topK: number)
v3/plugins/test-intelligence/src/types.ts:419
↓ 9 callers
Method
projectToManifold
* Projects a point onto the hyperbolic manifold. * * For Poincare: Ensures ||x|| < maxNorm * For Lorentz: Ensures x is on the hyperboloid
v3/@claude-flow/plugins/src/integrations/ruvector/hyperbolic.ts:713
↓ 9 callers
Function
quantizeBinary
* Binary quantization (sign-based)
v3/@claude-flow/plugins/__tests__/ruvector-quantization.test.ts:101
↓ 9 callers
Function
randomVec
(dim: number, seed: number)
v3/@claude-flow/memory/src/hnsw-persistence.test.ts:29
↓ 9 callers
Method
reconcile
* Detect conflicting assertions: multiple assertions active at the same * time in the same namespace. * * Returns groups of assertions that a
v3/@claude-flow/guidance/src/temporal.ts:501
↓ 9 callers
Method
recordOutcome
* Record task outcome for learning * * @param task - Completed task * @param result - Task result
v3/@claude-flow/swarm/src/queen-coordinator.ts:1840
↓ 9 callers
Method
recordVote
(proposalId: string, nodeId: string, vote: boolean)
v3/@claude-flow/plugin-agent-federation/src/domain/services/routing-service.ts:179
↓ 9 callers
Method
requestHandoff
(params: { issueId: string; fromId: string; toId?: string; toType?: ClaimantType; reason:
v3/@claude-flow/claims/src/api/mcp-tools.ts:174
↓ 9 callers
Function
requireAuth
(locals: App.Locals)
ruflo/src/ruvocal/src/lib/server/api/utils/requireAuth.ts:6
↓ 9 callers
Function
requireCoordinator
(get: CoordinatorGetter)
v3/@claude-flow/plugin-agent-federation/src/cli-commands.ts:8
↓ 9 callers
Function
rng
()
v3/@claude-flow/cli/__tests__/router-bandit.test.ts:150
↓ 9 callers
Function
routeToModelFull
( task: string, embedding?: number[] )
v3/@claude-flow/cli/src/ruvector/model-router.ts:1418
↓ 9 callers
Function
safeJsonParse
(raw: string)
v3/@claude-flow/cli/src/autopilot-state.ts:89
↓ 9 callers
Function
sanitizeMessage
* Sanitize a string message
v3/@claude-flow/shared/src/utils/secure-logger.js:38
↓ 9 callers
Function
sanitizeMessage
* Sanitize a string message
v3/@claude-flow/shared/src/utils/secure-logger.ts:58
↓ 9 callers
Method
save
(entry: MemoryEntry)
v3/@claude-flow/memory/src/domain/repositories/memory-repository.interface.ts:79
↓ 9 callers
Method
save
(fleet: DeviceFleet)
v3/@claude-flow/plugin-iot-cognitum/src/domain/repositories/fleet-repository.ts:4
↓ 9 callers
Function
saveLoopState
(statePath: string, state: LoopState)
v3/@claude-flow/codex/src/loop/index.ts:281
↓ 9 callers
Function
saveNeuralStore
(store: NeuralStore)
v3/@claude-flow/cli/src/mcp-tools/neural-tools.ts:178
↓ 9 callers
Method
scanUrl
* Scan URL for security threats without navigating
v3/@claude-flow/browser/src/application/browser-service.ts:213
↓ 9 callers
Function
scrubReasoningBlocks
(text: string)
v3/@claude-flow/cli/src/mcp-tools/hooks-tools.ts:35
↓ 9 callers
Function
selectAgentBackend
(pod: PodTemplate)
v3/@claude-flow/cli/src/business-pods/domain-affinity-policy.ts:51
↓ 9 callers
Function
sha256Hex
(input: Buffer | string)
v3/@claude-flow/browser/src/infrastructure/witness-signer.ts:83
↓ 9 callers
Function
shouldSkipPermissions
(flags: Record<string, unknown>)
v3/@claude-flow/cli/__tests__/hive-mind-skip-permissions.test.ts:25
↓ 9 callers
Function
smartSearch
( search: SearchFn, opts: SmartSearchOptions )
v3/@claude-flow/memory/src/smart-retrieval.ts:372
↓ 9 callers
Method
stop
()
v3/mcp/types.ts:360
↓ 9 callers
Function
str
(v: unknown)
v3/@claude-flow/cli/src/appliance/rvfa-format.ts:146
↓ 9 callers
Function
successResult
(data: unknown)
v3/plugins/hyperbolic-reasoning/src/types.ts:532
↓ 9 callers
Method
suspend
* Transition this peer to SUSPENDED. Legal from ACTIVE only — calling * from SUSPENDED or EVICTED returns false (the entity is already at or * p
v3/@claude-flow/plugin-agent-federation/src/domain/entities/federation-node.ts:154
↓ 9 callers
Method
terminateAgent
(agentId: AgentId)
v3/@claude-flow/swarm/src/coordination/swarm-hub.ts:71
↓ 9 callers
Function
test
(name: string, fn: () => void | Promise<void>)
v3/@claude-flow/cli/src/benchmarks/gaia-convergence.smoke.ts:41
↓ 9 callers
Method
transform
* Map a raw predicted value to its calibrated value. Uses piecewise-linear * interpolation between adjacent bucket midpoints, clamped at the * e
v3/@claude-flow/cli/src/ruvector/router-calibrator.ts:102
↓ 9 callers
Function
validate
* Generic validation function * Uses parse + try/catch to get output types with defaults applied
v3/@claude-flow/shared/src/core/config/validator.ts:57
↓ 9 callers
Function
validateBoolean
(input: unknown)
v3/@claude-flow/plugins/src/security/index.ts:69
↓ 9 callers
Method
validateConfig
()
v3/@claude-flow/cli/__tests__/services/headless-worker-executor.test.ts:298
↓ 9 callers
Function
validatePath
( inputPath: unknown, options?: { allowedExtensions?: string[]; blockedPatterns?: RegExp[]; mu
v3/@claude-flow/plugins/src/security/index.ts:141
↓ 9 callers
Method
validatePath
(path: string)
v3/@claude-flow/testing/src/helpers/test-application.ts:41
↓ 9 callers
Function
validatePositiveInt
(value: unknown, defaultVal: number, max: number)
v3/@claude-flow/cli/src/mcp-tools/agentdb-tools.ts:29
↓ 9 callers
Function
visited
(visits: number, parentVisits: number)
v3/@claude-flow/browser/tests/workflow-compiler.test.ts:128
↓ 9 callers
Method
warn
(message: string, ...args: unknown[])
v3/plugins/agentic-qe/src/interfaces.ts:1060
↓ 9 callers
Function
withRetry
( fn: () => Promise<T>, config: Partial<RetryConfig> = {}, strategy: RetryStrategy = 'exponential' )
v3/@claude-flow/cli/src/production/retry.ts:156
↓ 8 callers
Method
acquireLock
* Acquire a distributed lock
v3/@claude-flow/shared/src/core/interfaces/coordinator.interface.ts:182
↓ 8 callers
Method
applyPatch
( rvfaPath: string, patchBuf: Buffer, opts?: ApplyOptions, )
v3/@claude-flow/cli/src/appliance/rvfa-distribution.ts:228
↓ 8 callers
Function
assert
(condition, message)
scripts/smoke-windows-hook-execution.mjs:37
↓ 8 callers
Method
assignTask
(agentId: AgentId, taskId: TaskId)
v3/@claude-flow/swarm/src/coordination/agent-registry.ts:46
↓ 8 callers
Method
bootstrapElevate
* Founder-bootstrap trust elevation (ADR-164 §3.5.4). * * Bypasses the organic trust-accrual thresholds (minInteractions: 500 for * 2→3, etc.
v3/@claude-flow/plugin-agent-federation/src/application/trust-evaluator.ts:181
↓ 8 callers
Method
broadcast
(message: Omit<Message, 'id' | 'timestamp' | 'to'>)
v3/@claude-flow/swarm/src/types.ts:500
↓ 8 callers
Function
cachePath
(suffix)
v3/@claude-flow/cli/scripts/run-beir-bge.mjs:162
↓ 8 callers
Function
callAnthropicMessages
(input: AnthropicCallInput)
v3/@claude-flow/cli/src/mcp-tools/agent-execute-core.ts:125
↓ 8 callers
Method
canRunWorker
* Check if system resources allow worker execution
v3/@claude-flow/cli/src/services/worker-daemon.ts:613
↓ 8 callers
Function
check
(label, ok, detail)
scripts/smoke-tool-output-guardrail.mjs:37
↓ 8 callers
Function
check
()
v3/@claude-flow/cli/src/commands/progress.ts:194
↓ 8 callers
Function
classifyBreak
(reason: string | undefined)
v3/@claude-flow/browser/src/infrastructure/causal-recovery-store.ts:199
↓ 8 callers
Function
cleanup
()
v3/@claude-flow/cli/src/commands/daemon.ts:232
↓ 8 callers
Method
click
Click.
v3/@claude-flow/browser/src/domain/browser-adapter.ts:45
↓ 8 callers
Method
cloneBudget
* Create a deep clone of the current budget.
v3/@claude-flow/guidance/src/gateway.ts:549
↓ 8 callers
Function
clonePriors
(p: Record<ClaudeModel, BetaPrior>)
v3/@claude-flow/cli/src/ruvector/model-router.ts:459
↓ 8 callers
Method
close
()
v3/@claude-flow/plugins/__tests__/ruvector-streaming.test.ts:35
↓ 8 callers
Method
commit
()
v3/@claude-flow/plugins/src/integrations/ruvector/types.ts:1792
↓ 8 callers
Method
compose
(f: Morphism, g: Morphism)
v3/plugins/prime-radiant/src/types.ts:295
↓ 8 callers
Method
create
()
v3/mcp/transport/connection-pool.ts:89
↓ 8 callers
Function
createASTAnalyzer
(config?: Partial<ASTAnalyzerConfig>)
v3/@claude-flow/cli/src/ruvector/ast-analyzer.ts:310
↓ 8 callers
Function
createClaimStatusChangedEvent
( claimId: ClaimId, issueId: IssueId, previousStatus: ClaimStatus, newStatus: ClaimStatus, note?: st
v3/@claude-flow/claims/src/domain/events.ts:294
↓ 8 callers
Function
createDiscoveryService
(config?: Partial<StoreConfig>)
v3/@claude-flow/cli/src/transfer/store/discovery.ts:460
↓ 8 callers
Function
createEventStore
(path: string)
v3/@claude-flow/guidance/src/persistence.ts:562
↓ 8 callers
Function
createHookExecutor
( registry: HookRegistry, eventBus?: IEventBus )
v3/@claude-flow/shared/src/hooks/executor.ts:376
↓ 8 callers
Method
createIndex
(options: VectorIndexOptions)
v3/@claude-flow/plugins/src/integrations/ruvector/types.ts:1753
↓ 8 callers
Method
createIndex
(name: string, config: IndexConfig)
v3/@claude-flow/testing/src/helpers/mock-factory.ts:178
↓ 8 callers
Function
createMemoryStoredEvent
( memoryId: string, namespace: string, key: string, memoryType: string, size: number )
v3/@claude-flow/shared/src/events/domain-events.ts:503
↓ 8 callers
Function
createMockConsensusResult
(approved: boolean)
v3/@claude-flow/swarm/__tests__/queen-coordinator.test.ts:236
↓ 8 callers
Function
createMockContext
(overrides: Partial<PluginContext> = {})
v3/plugins/agentic-qe/__tests__/plugin.test.ts:266
↓ 8 callers
Function
createTestGraph
(numNodes: number, numEdges: number, featureDim: number)
v3/@claude-flow/plugins/__tests__/ruvector-bridge.test.ts:1490
↓ 8 callers
Method
dedupe
* Deduplicate concurrent requests for the same key
v3/plugins/gastown-bridge/src/cache.ts:498
↓ 8 callers
Function
defaultBucketedPriors
Uniform priors for every complexity bucket (cold start).
v3/@claude-flow/cli/src/ruvector/model-router.ts:449
↓ 8 callers
Function
definePrompt
( name: string, description: string, handler: PromptHandler, options?: { title?: string; argum
v3/@claude-flow/mcp/src/prompt-registry.ts:236
↓ 8 callers
Method
detectCycle
(graph: BeadGraph)
v3/plugins/gastown-bridge/src/index.ts:189
↓ 8 callers
Method
download
* Download pattern
v3/@claude-flow/cli/src/transfer/store/index.ts:149
↓ 8 callers
Function
embedTaskWithCache
(task: string)
v3/@claude-flow/cli/src/ruvector/task-embedder.ts:149
↓ 8 callers
Function
emit
(report)
scripts/auto-retrain-router.mjs:73
↓ 8 callers
Function
emit
(payload, exitCode = 0)
plugins/ruflo-testgen/scripts/tdd-repair/tdd-repair.mjs:86
↓ 8 callers
Method
emit
(event: ConvoyEvent)
v3/plugins/gastown-bridge/tests/convoy.test.ts:325
↓ 8 callers
Function
emitAndExit
(payload, code)
v3/@claude-flow/cli/plugins/ruflo-metaharness/scripts/drift-from-history.mjs:78
↓ 8 callers
Function
emitAndExit
(payload, code)
plugins/ruflo-metaharness/scripts/drift-from-history.mjs:78
↓ 8 callers
Method
emitConvoyEvent
* Emit convoy event
v3/plugins/gastown-bridge/src/convoy/tracker.ts:805
↓ 8 callers
Method
ensureInitialized
()
v3/@claude-flow/swarm/src/coordination/swarm-hub.ts:489
↓ 8 callers
Method
ensureInitialized
()
v3/@claude-flow/shared/src/events/event-store.ts:592
↓ 8 callers
Function
ensureReady
()
ruflo/src/ruvocal/src/lib/wasm/workerClient.ts:97
↓ 8 callers
Function
estimateTokens
(text: string)
v3/@claude-flow/embeddings/src/chunking.ts:313
↓ 8 callers
Method
evaluateCommand
* Evaluate all gates for a command
v3/@claude-flow/guidance/src/gates.ts:97
↓ 8 callers
Method
evict
* Transition this peer to EVICTED. Legal from ACTIVE or SUSPENDED. * EVICTED is terminal under normal flow — only `reactivate` (operator- * init
v3/@claude-flow/plugin-agent-federation/src/domain/entities/federation-node.ts:163
← previous
next →
1,201–1,300 of 18,477, ranked by callers