MCPcopy Create free account

hub / github.com/GizClaw/flowcraft / functions

Functions13,468 in github.com/GizClaw/flowcraft

↓ 8 callersFunctionnewChunkRepoWithIndex
newChunkRepoWithIndex returns both the repo and the underlying in-memory index so tests can inspect the doc-level namespace directly without going thr
memory/knowledge/backend/retrieval/chunk_test.go:21
↓ 8 callersFunctionnewChunkRepoWithIndex
newChunkRepoWithIndex returns both the repo and the underlying in-memory index so tests can inspect the doc-level namespace directly without going thr
sdk/knowledge/backend/retrieval/chunk_test.go:21
↓ 8 callersFunctionnewClientPC
(t *testing.T)
voice/webrtc/transport_test.go:250
↓ 8 callersFunctionnewFakeNotifier
()
memory/knowledge/reloader_test.go:17
↓ 8 callersFunctionnewFakeNotifier
()
sdk/knowledge/reloader_test.go:17
↓ 8 callersFunctionnewMemoryEnabledTestClaw
(t *testing.T)
sdkx/claw/memory_test.go:698
↓ 8 callersFunctionnewRepo
(t *testing.T)
memory/knowledge/backend/fs/document_test.go:14
↓ 8 callersFunctionnewRepo
(t *testing.T)
sdk/knowledge/backend/fs/document_test.go:14
↓ 8 callersFunctionnewScriptedLLM
(text string)
sdk/script/bindings/bridge_llm_facade_test.go:33
↓ 8 callersFunctionnormaliseExtractedKind
normaliseExtractedKind maps the LLM's "kind" field to a canonical FactKind. Empty / unrecognised values fall through to KindNote- equivalent (empty st
memory/recall/internal/ingest/extractor_llm.go:626
↓ 8 callersFunctionopenApp
(workspaceDir string)
cmd/claw/cli/workspace.go:92
↓ 8 callersFunctionparseRSSDate
(s string)
sdkx/extract/podcast/rss.go:176
↓ 8 callersFunctionplanCacheAnchors
planCacheAnchors decides where to place Anthropic cache_control breakpoints across the request, respecting the global 4-breakpoint budget. Inputs are
sdkx/llm/anthropic/cache.go:95
↓ 8 callersFunctionsafeToken
(s string)
sdk/retrieval/bbh/index.go:302
↓ 8 callersFunctionsampleScope
()
memory/recall/internal/pipeline/fanout_test.go:53
↓ 8 callersFunctionscope
()
memory/recall/internal/store/temporal/helpers_test.go:9
↓ 8 callersFunctionsubscribeBus
subscribeBus subscribes to b.Bus() with a generous buffer and registers the subscription's Close with t.Cleanup. The pattern PatternAll() is used beca
sdk/kanban/helpers_test.go:133
↓ 8 callersFunctiontestSemanticIngestor
()
memory/recall/async_semantic_processor_test.go:39
↓ 8 callersMethodthreshold
()
voice/vad/vad.go:148
↓ 8 callersFunctiontoRecallScope
(s runners.Scope)
eval/locomo/runners/flowcraftv2/convert.go:19
↓ 8 callersFunctiontoRoundOptions
toRoundOptions folds defaults with the script-supplied override into the bridge-internal roundOptions value the round logic consumes. It only handles
sdk/script/bindings/bridge_llm.go:234
↓ 8 callersMethodvalidateScope
validateScope is enforced by every write path.
sdk/recall/save.go:56
↓ 8 callersFunctionwriteFile
(t *testing.T, dir, name, body string)
cmd/vesseld/loader/loader_test.go:9
↓ 7 callersMethodAppendSliceVar
AppendSliceVar atomically appends a value to a slice stored in a board variable. It returns an error if the existing value is not a []any (instead of
sdk/engine/board.go:137
↓ 7 callersMethodAttach
Attach registers sink for runID, returning a detach function the caller MUST invoke when the transport closes (deferred-friendly). sinkID identifies t
sdk/engine/stream_sink.go:176
↓ 7 callersMethodAwaitJob
(ctx context.Context, id JobID, timeout time.Duration)
sdk/recall/memory.go:93
↓ 7 callersMethodCards
Cards returns a snapshot of task cards on the board, excluding internal bookkeeping cards (result rows and cron rule definitions).
sdk/kanban/board.go:573
↓ 7 callersMethodClose
()
sdk/knowledge/reloader.go:23
↓ 7 callersMethodCloseContext
CloseContext releases resources owned by Claw, using ctx to bound close-time drains such as async memory extraction.
sdkx/claw/claw.go:84
↓ 7 callersMethodCount
(text string)
memory/history/token.go:77
↓ 7 callersMethodCount
(text string)
sdk/history/token.go:77
↓ 7 callersFunctionDefaultFallbackPolicy
()
voice/provider/fallback.go:88
↓ 7 callersFunctionDefineSchema
DefineSchema starts building a ToolDefinition with the given properties.
sdk/tool/schema.go:83
↓ 7 callersMethodEnsureTrace
EnsureTrace allocates the Trace if not pre-populated. Idempotent.
memory/recall/internal/pipeline/forget/state.go:95
↓ 7 callersFunctionExtractKeywords
ExtractKeywords tokenizes text and deduplicates.
sdk/textsearch/bm25.go:70
↓ 7 callersMethodForgetOptional
ForgetOptional runs optional forgets best-effort.
memory/recall/internal/pipeline/fanout.go:199
↓ 7 callersMethodGetCard
GetCard returns the card with the given ID, or an error if not found.
sdk/kanban/kanban.go:348
↓ 7 callersMethodGracefulStop
GracefulStop asks worker loops to stop before the next drain pass and waits for any in-flight drain to finish without cancelling its context.
memory/recall/ops/supervisor.go:66
↓ 7 callersFunctionInfo
(ctx context.Context, msg string, attrs ...otellog.KeyValue)
sdk/telemetry/logger.go:77
↓ 7 callersMethodInspect
Inspect returns a point-in-time summary of all discovered namespaces.
memory/retrieval/bbh/inspector.go:113
↓ 7 callersMethodInterrupt
Interrupt queues an interrupt for the engine. Non-blocking: if the buffer is full the call drops the new signal silently — tests that care should call
sdk/engine/enginetest/mock_host.go:90
↓ 7 callersMethodInvalidateCache
InvalidateCache removes cached LLM instances. With no options it clears every entry; options narrow the scope. See WithProvider / WithModel / WithProf
sdk/llm/resolver.go:130
↓ 7 callersMethodIsSpeech
(f audio.Frame)
voice/detect/echo.go:93
↓ 7 callersFunctionIsTimeout
(err error)
sdk/errdefs/errors.go:66
↓ 7 callersMethodLayer
Layer reads a document-level layer; returns "" without error when missing (contract: callers should treat absence as "not yet generated").
sdk/knowledge/service.go:225
↓ 7 callersFunctionNew
New constructs an Ingestor from explicit stages. Nil fields fall back to the deterministic implementation.
memory/recall/internal/ingest/ingest.go:47
↓ 7 callersFunctionNew
New returns an empty timeline projection.
memory/recall/internal/lens/timeline/projection.go:53
↓ 7 callersFunctionNew
New returns an empty in-memory Index using CJKTokenizer for BM25.
memory/retrieval/memory/index.go:32
↓ 7 callersFunctionNew
New constructs a Memory backed by idx. Caller must Close() on shutdown. idx is a positional parameter because it is the only non-replaceable dependenc
sdk/recall/memory.go:792
↓ 7 callersFunctionNew
New returns an empty in-memory Index using CJKTokenizer for BM25.
sdk/retrieval/memory/index.go:31
↓ 7 callersMethodNew
(provider, apiKey, baseURL string, opts ...TTSProviderOption)
voice/tts/tts.go:75
↓ 7 callersFunctionNewBoard
NewBoard creates an empty execution board.
sdk/graph/board.go:28
↓ 7 callersFunctionNewCorpusStats
NewCorpusStats creates an empty CorpusStats.
sdk/textsearch/bm25.go:14
↓ 7 callersFunctionNewFactory
NewFactory creates an empty Factory. Call RegisterBuilder (or the per-sub-package Register helpers like llmnode.Register, scriptnode.Register, knowled
sdk/graph/node/factory.go:48
↓ 7 callersFunctionNewMemorySessionStore
NewMemorySessionStore constructs an empty in-memory session store.
vessel/session.go:102
↓ 7 callersFunctionNewMulti
NewMulti returns an empty router. Register backends before calling Get, otherwise every reference resolves to errdefs.Validation ("unknown scheme"). M
cmd/vesseld/secrets/secrets.go:46
↓ 7 callersFunctionNewProviderRegistry
()
sdk/embedding/factory.go:19
↓ 7 callersFunctionNewSeverityFilter
NewSeverityFilter wraps base with a severity gate. Records with severity < min, or severity >= max when max != 0, are dropped before reaching base. U
sdk/telemetry/log.go:168
↓ 7 callersMethodOnRunEnd
OnRunEnd fires after engine.Execute returned and Run finished classifying the outcome. res is the same pointer Run is about to return; observers MUST
sdk/agent/observer.go:79
↓ 7 callersFunctionPCM16RMS
PCM16RMS computes the root-mean-square of PCM16LE audio data.
voice/vad/vad.go:301
↓ 7 callersMethodPush
Push appends additional steps. Safe to call from a test goroutine concurrent with Generate.
tests/quality/vessel/fakellm/fakellm.go:152
↓ 7 callersMethodQuery
(ctx context.Context, scope domain.Scope, from, to time.Time, kinds []domain.FactKind, limit int)
memory/recall/internal/lens/timeline/source.go:14
↓ 7 callersFunctionRRF
RRF (Reciprocal Rank Fusion) merges several ranked hit lists into a single ranked list. For every (list, position) pair a hit contributes 1 / (k + ran
memory/retrieval/scoring/fusion.go:31
↓ 7 callersFunctionRRF
RRF (Reciprocal Rank Fusion) merges several ranked hit lists into a single ranked list. For every (list, position) pair a hit contributes 1 / (k + ran
sdk/retrieval/scoring/fusion.go:31
↓ 7 callersMethodRecognizeStream
RecognizeStream implements StreamSTT by splitting audio via VAD. Input and output both use Stream[T]. The returned output stream is bound to ctx: whe
voice/stt/eager.go:34
↓ 7 callersMethodRemember
(ctx context.Context, ns string)
sdk/recall/namespace_registry.go:15
↓ 7 callersMethodRerank
(ctx context.Context, query string, hits []retrieval.Hit)
sdk/retrieval/pipeline/stages_rerank.go:13
↓ 7 callersMethodResolve
Resolve implements port.TimeResolver.
memory/recall/internal/ingest/time_resolver.go:41
↓ 7 callersMethodResume
Resume re-launches a previously interrupted (or persisted) run by loading its checkpoint from the wired [engine.CheckpointStore] and dispatching the o
vessel/captain.go:403
↓ 7 callersMethodScopeOf
ScopeOf returns the scope of a registered tool, or ScopeAgent if not found.
sdk/tool/registry.go:138
↓ 7 callersMethodSearchDocuments
SearchDocuments executes the query at DOC granularity: each Hit represents one matching docName scored over the entire document rather than per chunk.
sdk/knowledge/service.go:307
↓ 7 callersMethodSetChannel
(name string, msgs []model.Message)
sdk/script/bindings/bridge_board.go:29
↓ 7 callersFunctionSupports
Supports centralises capability checks so callers do not spread Capabilities + type-assertion combinations across the codebase.
memory/retrieval/capability_helpers.go:26
↓ 7 callersFunctionWithDefaults
WithDefaults wraps inner so that GenerateOptions fields the caller did not set are filled from the supplied defaults. Caller-set fields always win; th
sdk/llm/with_defaults.go:13
↓ 7 callersFunctionWithEvidenceStore
WithEvidenceStore installs an optional secondary evidence lookup adapter. Save keeps embedded EvidenceRefs authoritative; adapter write failures are t
memory/recall/options.go:153
↓ 7 callersFunctionWithExtra
(key string, value any)
sdk/llm/option.go:171
↓ 7 callersFunctionWithLimits
WithLimits wraps inner so that numeric GenerateOptions fields exceeding the spec's hard ceilings are clamped down (with a telemetry warning), not erro
sdk/llm/with_limits.go:19
↓ 7 callersFunctionWithMinChars
WithMinChars sets the minimum character count before a break point triggers.
voice/tts/segmenter.go:15
↓ 7 callersFunctionWithRequireUserID
WithRequireUserID rejects any write/recall whose scope is missing UserID, unless paired with [WithAllowGlobal]. Use this to enforce per-user isolation
sdk/recall/memory.go:677
↓ 7 callersFunctionWithTemperature
(t float64)
sdk/llm/option.go:101
↓ 7 callersFunctionWriteConfig
(templateFS fs.FS, configSource, workspaceDir string)
cmd/claw/cli/config_file.go:32
↓ 7 callersMethodackAsyncJobFail
(ctx context.Context, job port.AsyncSemanticJob, start time.Time, cause error)
memory/recall/async_semantic.go:359
↓ 7 callersFunctionassertRange
(t *testing.T, expr *timex.Expression, wantStart, wantEnd time.Time)
memory/text/timex/extract_test.go:525
↓ 7 callersFunctionatomicWrite
atomicWrite writes data to dst atomically: it stages the payload in a sibling tmp path and then Renames into place. Workspace.Rename is required to be
memory/knowledge/backend/fs/atomic.go:20
↓ 7 callersFunctionatomicWrite
atomicWrite writes data to dst atomically: it stages the payload in a sibling tmp path and then Renames into place. Workspace.Rename is required to be
sdk/knowledge/backend/fs/atomic.go:20
↓ 7 callersFunctionbuildEchoRunner
buildEchoRunner constructs the trivial echo graph + runner used by most cases below. Centralising it keeps each test focused on the assertion that var
sdk/graph/runner/integration_test.go:61
↓ 7 callersFunctioncanonicalMessagesRaw
(text string)
sdk/script/bindings/bridge_llm_test.go:14
↓ 7 callersFunctioncanonicalSpace
canonicalSpace is the package-internal alias for [normalize.CollapseSpaces]. Kept as a one-line wrapper so the normalizer's call sites stay self-docum
memory/recall/internal/ingest/normalizer.go:89
↓ 7 callersFunctionchunksNamespace
chunksNamespace returns the namespace for the dataset's chunks.
memory/knowledge/backend/retrieval/namespace.go:57
↓ 7 callersFunctionchunksNamespace
chunksNamespace returns the namespace for the dataset's chunks.
sdk/knowledge/backend/retrieval/namespace.go:60
↓ 7 callersFunctionclawHistoryXMLAttr
(msg model.Message, nodeName, attrName string)
sdkx/claw/roundtrip.go:521
↓ 7 callersFunctioncollectionSiblingFacts
(a, b domain.TemporalFact)
memory/recall/internal/pipeline/read/stages/context_packer.go:1467
↓ 7 callersFunctioncontextPackAppendCoreCandidate
(selected []contextPackCandidate, cand contextPackCandidate, cap int)
memory/recall/internal/pipeline/read/stages/context_packer.go:519
↓ 7 callersFunctioncontextPackBestCoreCandidate
(candidates, selected []contextPackCandidate, pred func(contextPackCandidate) bool, score func(contextPackCand
memory/recall/internal/pipeline/read/stages/context_packer.go:503
↓ 7 callersMethodconvMu
(convID string)
memory/history/summary_store.go:145
↓ 7 callersMethodconvMu
(convID string)
sdk/history/summary_store.go:144
↓ 7 callersFunctionconvertMessages
(msgs []llm.Message)
sdkx/llm/openai/chat/openai.go:308
↓ 7 callersFunctioncopyMap
(m map[string]any)
sdk/graph/runner/internal/executor/helpers_test.go:61
↓ 7 callersFunctiondecodeSparse
(b []byte)
memory/retrieval/sqlite/index.go:976
↓ 7 callersFunctiondecodeVector
(b []byte)
memory/retrieval/postgres/index.go:852
← previousnext →801–900 of 13,468, ranked by callers