MCPcopy Create free account

hub / github.com/GizClaw/flowcraft / functions

Functions13,468 in github.com/GizClaw/flowcraft

⨍ Functions 13,468◇ Types & classes 2,684
↓ 6 callersFunctionResolveMode
ResolveMode normalises zero values to a canonical Mode. - "" -> ModeBM25 (legacy default) Any other recognised mode is returned unchanged.
memory/knowledge/query.go:35
↓ 6 callersFunctionResolveMode
ResolveMode normalises zero values to a canonical Mode. - "" -> ModeBM25 (legacy default) Any other recognised mode is returned unchanged.
sdk/knowledge/query.go:35
↓ 6 callersFunctionRevisionOf
RevisionOf reads a revision annotation from fact metadata.
memory/recall/internal/domain/revision.go:48
↓ 6 callersMethodSave
(ctx context.Context, scope Scope, msgs []llm.Message)
eval/locomo/runners/runner.go:90
↓ 6 callersMethodSave
Save writes a checkpoint to disk with multi-version retention.
sdk/graph/runner/internal/executor/checkpoint.go:112
↓ 6 callersMethodSaveExplain
(ctx context.Context, scope Scope, req SaveRequest)
memory/recall/explain.go:50
↓ 6 callersMethodSearchDocuments
SearchDocuments executes the query at DOC granularity: each Hit represents one matching docName scored over the entire document rather than per chunk.
memory/knowledge/service.go:307
↓ 6 callersFunctionSequentialIDGenerator
SequentialIDGenerator returns a deterministic generator for tests. IDs follow the pattern prefix + ascending zero-padded counter.
memory/recall/internal/ingest/id.go:52
↓ 6 callersMethodSetConfig
(config map[string]any)
sdk/graph/core.go:50
↓ 6 callersMethodSetNodeID
SetNodeID is a typed shorthand for SetHeader(HeaderNodeID, id).
sdk/event/envelope.go:173
↓ 6 callersMethodShutdown
Shutdown closes the underlying file. Subsequent Export calls are no-ops.
sdkx/telemetry/logfile/logfile.go:122
↓ 6 callersMethodSideEffectOutbox
SideEffectOutbox returns the commit-after side-effect outbox adapter.
memory/recall/store/sqlite/backend.go:76
↓ 6 callersFunctionStart
Start starts runner loops for each target. The returned Supervisor is stopped by calling Stop or by cancelling ctx.
memory/recall/ops/supervisor.go:26
↓ 6 callersFunctionSupports
Supports centralises capability checks so callers do not spread Capabilities + type-assertion combinations across the codebase.
sdk/retrieval/capability_helpers.go:25
↓ 6 callersMethodSyncSideStores
(ctx context.Context, scope Scope)
sdk/recall/memory.go:108
↓ 6 callersMethodUpdateValidity
UpdateValidity closes a fact's validity window. The operation is idempotent: a fact already closed with the supplied (validTo, correctedBy) tuple retu
memory/recall/internal/store/temporal/memory.go:334
↓ 6 callersMethodValidate
Validate runs every shape check that does not require IO. The resolver does deeper validation that DOES touch the filesystem (e.g. confirming Auth.Tok
cmd/vesseld/apispec/v1alpha1/daemon.go:205
↓ 6 callersMethodVoiceClone
VoiceClone clones a voice from a previously uploaded audio file. The returned VoiceCloneResult.VoiceID can be used with Synthesize / SynthesizeStream
voice/tts/minimax/minimax.go:593
↓ 6 callersMethodWarmNamespace
(ctx context.Context, namespace string)
memory/retrieval/index.go:86
↓ 6 callersFunctionWithBufferMax
WithBufferMax sets the maximum message count kept in the returned [History]. Must be > 0; values ≤ 0 are ignored and the default (50) is kept.
memory/history/buffer.go:32
↓ 6 callersFunctionWithBufferMax
WithBufferMax sets the maximum message count kept in the returned [History]. Must be > 0; values ≤ 0 are ignored and the default (50) is kept.
sdk/history/buffer.go:32
↓ 6 callersFunctionWithCheckpointStore
WithCheckpointStore wires an [engine.CheckpointStore] that the Captain hooks into the sandbox host. Every engine that calls host.Checkpoint(ctx, cp) i
vessel/option.go:193
↓ 6 callersFunctionWithCredentialProfile
WithCredentialProfile returns ctx tagged with the given credential profile. The resolver reads this tag when looking up ProviderConfig — empty string
sdk/llm/profile.go:40
↓ 6 callersFunctionWithDetectorConfirm
WithDetectorConfirm sets the number of consecutive frames that must exceed the interrupt threshold before a barge-in is confirmed. Default: 3.
voice/detect/energy.go:40
↓ 6 callersFunctionWithEmbedder
WithEmbedder enables semantic indexing. The projection will embed every fact's searchable content and store the vector in Doc.Vector so the index can
memory/recall/internal/lens/retrieval/projection.go:50
↓ 6 callersFunctionWrap
Wrap returns retrieval.Index that records mutations to j after inner success. Capability projection (issue #157): the wrapper exposes ONLY the option
memory/retrieval/journal/wrap.go:62
↓ 6 callersMethodWriteReport
WriteReport serialises rep to indented JSON and routes it to either --out (when set) or stdout. The "wrote <path>" confirmation line goes to stdout wh
eval/internal/cliflags/global.go:90
↓ 6 callersMethodaddAll
addAll concatenates another Errors aggregate into this one.
cmd/vesseld/resolver/errors.go:31
↓ 6 callersFunctionanswerabilityCandidate
(id string, rank int, textScore, score float64, fact domain.TemporalFact, group string)
memory/recall/internal/pipeline/read/stages/context_pack_test.go:618
↓ 6 callersFunctionappendRunOpt
appendRunOpt is the single seam that grows Runner.runOpts so all forwarders share one append site. Keeping this private avoids callers reaching into r
sdk/graph/runner/options.go:74
↓ 6 callersFunctionappendUniqueHintLimited
(values []string, value string, limit int)
eval/locomo/answer_hints.go:151
↓ 6 callersFunctionbasicSpec
(name string)
vessel/captain_test.go:46
↓ 6 callersMethodbuildRequest
(text string, stream bool, o *speechtts.TTSOptions)
voice/tts/minimax/minimax.go:447
↓ 6 callersFunctioncalendarMonthNumber
(raw string)
memory/text/timex/calendar.go:130
↓ 6 callersFunctioncanonicalKeyPart
(s string)
memory/recall/internal/lens/profile/projection.go:218
↓ 6 callersFunctioncanonicalKeyPart
(s string)
memory/recall/internal/lens/relation/projection.go:203
↓ 6 callersFunctionclassifyAPIError
classifyAPIError gives Volcengine arkruntime's *APIError / *RequestError types a status-code-aware classification path. Same root cause as the openai
sdkx/llm/bytedance/classify.go:33
↓ 6 callersFunctionclawConfigDir
()
cmd/claw/cli/claw_home.go:19
↓ 6 callersFunctioncloneDoc
(d retrieval.Doc)
memory/retrieval/memory/index.go:424
↓ 6 callersFunctioncloneDoc
(d retrieval.Doc)
sdk/retrieval/memory/index.go:433
↓ 6 callersFunctioncloneStrings
(in []string)
memory/recall/internal/domain/temporal_fact.go:114
↓ 6 callersFunctioncomposeObservers
composeObservers returns a single Observer that fans every method out to obs in registration order, swallowing panics so one bad observer cannot tear
sdk/agent/observer.go:140
↓ 6 callersFunctionconfigUsage
()
cmd/claw/cli/config.go:55
↓ 6 callersFunctioncontains
--- helpers ---
sdkx/sandbox/nsjail/flags_test.go:275
↓ 6 callersFunctioncontainsName
(names []string, want string)
memory/retrieval/pipeline/factory_test.go:193
↓ 6 callersFunctioncontainsName
(names []string, want string)
sdk/retrieval/pipeline/factory_test.go:193
↓ 6 callersFunctioncontextPackAnswerabilityScore
(query contextPackQueryFeatures, cand contextPackCandidate, selected []contextPackCandidate)
memory/recall/internal/pipeline/read/stages/context_packer.go:1079
↓ 6 callersMethodcount
(id string)
vessel/lifecycle_resume_e2e_test.go:316
↓ 6 callersFunctioncountDroppedReason
countDroppedReason tallies dropped facts whose Reason matches any of the supplied keys. Used by IngestDetail to surface policy / validation / dedup at
memory/recall/internal/pipeline/write/stages/ingest.go:102
↓ 6 callersFunctioncountString
countString returns the number of occurrences of s in xs. Sierra uses list.count() in several tools to validate that duplicate item ids in the action'
eval/taubench/sierra_common.go:221
↓ 6 callersMethoddatasetLayerPath
datasetLayerPath is the dataset-level layer text path.
memory/knowledge/backend/fs/paths.go:131
↓ 6 callersMethoddatasetLayerPath
datasetLayerPath is the dataset-level layer text path.
sdk/knowledge/backend/fs/paths.go:134
↓ 6 callersFunctiondcg
dcg returns the discounted cumulative gain of the first k grades. Uses the BEIR-standard exponential gain (2^grade - 1) which rewards graded relevance
eval/beir/beir.go:741
↓ 6 callersFunctiondecodeBody
(t *testing.T, raw []byte)
sdkx/llm/anthropic/cache_integration_test.go:81
↓ 6 callersFunctiondefaultConfig
()
sdkx/claw/workspace.go:50
↓ 6 callersFunctiondocKey
(namespace, id string)
memory/retrieval/bbh/index.go:314
↓ 6 callersFunctiondocsNamespace
docsNamespace returns the namespace for the dataset's doc-level virtual documents (#134). Kept package-private: callers must go through SearchDocs / R
memory/knowledge/backend/retrieval/namespace.go:70
↓ 6 callersFunctiondocsNamespace
docsNamespace returns the namespace for the dataset's doc-level virtual documents (#134). Kept package-private: callers must go through SearchDocs / R
sdk/knowledge/backend/retrieval/namespace.go:73
↓ 6 callersFunctiondrainEvents
(events <-chan Event)
sdkx/claw/roundtrip_test.go:1167
↓ 6 callersFunctionensureClawConfigDir
()
cmd/claw/cli/claw_home.go:11
↓ 6 callersMethodensureOpen
()
memory/retrieval/bbh/index.go:189
↓ 6 callersMethodensureOpen
()
sdk/retrieval/bbh/index.go:181
↓ 6 callersMethodensureShard
(namespace string)
memory/retrieval/bbh/index.go:196
↓ 6 callersFunctionenvFlags
envFlags renders sandbox.EnvPolicy as a sequence of --env KEY=VALUE arguments. We do not use nsjail's --keep_env because it asks nsjail to read its ow
sdkx/sandbox/nsjail/flags.go:78
↓ 6 callersFunctionevidenceIDs
(refs []recall.EvidenceRef)
memory/recall/recalltest/evidence.go:180
↓ 6 callersFunctionevidenceStoreForTest
(t testing.TB, newStore EvidenceStoreFactory)
memory/recall/recalltest/evidence.go:156
↓ 6 callersFunctionexpansionItem
(id string, score float64, subject, predicate, object, evidenceID, evidenceText string)
memory/recall/internal/pipeline/read/stages/candidate_expansion_suggestions_test.go:90
↓ 6 callersFunctionexpressionValidFrom
(expr *timex.Expression)
memory/recall/internal/ingest/time_resolver.go:198
↓ 6 callersFunctionfatal
(msg string, err error)
examples/voice-pipeline/main.go:76
↓ 6 callersMethodfinish
(err error)
sdkx/llm/ollama/stream.go:222
↓ 6 callersFunctionformatRefError
formatRefError is the small wrapper used by factory bodies to produce a uniform "<category> <ref>: <reason>" prefix; saves every factory from re-spell
cmd/vesseld/catalog/catalog.go:330
↓ 6 callersFunctionhitSnapshots
(hits []domain.Hit)
memory/recall/internal/pipeline/read/stages/audit_snapshots.go:65
↓ 6 callersFunctionintPtr
(i int)
memory/history/compactor.go:1427
↓ 6 callersFunctionintPtr
(i int)
sdk/history/compactor.go:1428
↓ 6 callersFunctionjoinKey
(parts ...string)
memory/recall/internal/ingest/normalizer.go:165
↓ 6 callersFunctionkeyOf
(s domain.Scope)
memory/recall/internal/lens/entity/projection.go:252
↓ 6 callersMethodlistDocs
(namespace string, filter retrieval.Filter)
memory/retrieval/bbh/index.go:843
↓ 6 callersMethodlistDocs
(namespace string, filter retrieval.Filter)
sdk/retrieval/bbh/index.go:823
↓ 6 callersFunctionloadConfigFile
(root, path string)
memory/retrieval/bbh/config.go:237
↓ 6 callersFunctionloadConfigFile
(root, path string)
sdk/retrieval/bbh/config.go:227
↓ 6 callersFunctionloadIntent
(ctx context.Context, ws workspace.Workspace, prefix, archivePrefix, convID string)
memory/history/archive.go:130
↓ 6 callersFunctionloadIntent
(ctx context.Context, ws workspace.Workspace, prefix, archivePrefix, convID string)
sdk/history/archive.go:130
↓ 6 callersFunctionlocalPathSize
(path string)
cmd/claw/cli/auto.go:731
↓ 6 callersFunctionlookupsFromFacts
lookupsFromFacts builds an in-memory LineageLookups against a fixed set of facts so each test can declare just the topology.
memory/recall/internal/domain/lineage_test.go:17
↓ 6 callersFunctionmakeProse
makeProse generates n words of filler text (no JSON start bytes at word boundaries).
sdk/llm/json_test.go:445
↓ 6 callersFunctionmrr
mrr returns 1/(rank of first relevant doc) or 0 if none in the list.
eval/beir/beir.go:868
↓ 6 callersMethodmsgTypeFlag
()
voice/stt/bytedance/protocol.go:43
↓ 6 callersFunctionmustAdd
--- helpers -----------------------------------------------------
sdk/recall/partition_fanout_test.go:156
↓ 6 callersFunctionmustConfigFromMap
(t *testing.T, m map[string]any)
sdk/graph/node/llmnode/config_test.go:14
↓ 6 callersFunctionmustEnvelope
---------- helpers ----------
sdk/engine/subjects_test.go:328
↓ 6 callersFunctionnewCaptureServer
(t *testing.T)
sdkx/llm/anthropic/cache_integration_test.go:48
↓ 6 callersFunctionnewLLMExtractorOption
(apply func(*llmExtractorConfig))
memory/recall/options.go:194
↓ 6 callersFunctionnewMockClient
()
sdkx/workspace/objstore/s3/s3_test.go:24
↓ 6 callersFunctionnewTestBackend
(t testing.TB)
memory/recall/store/workspace/conformance_test.go:73
↓ 6 callersFunctionnewTestBackend
(t testing.TB)
memory/recall/store/sqlite/conformance_test.go:40
↓ 6 callersFunctionnewTokenBucket
newTokenBucket returns a bucket sized for the daemon-config rate limit. requestsPerMinute / tokensPerMinute = 0 disables that dimension (no cap on tha
cmd/vesseld/fleet/ratelimit.go:39
↓ 6 callersMethodnsDir
nsDir returns the namespace base directory.
memory/retrieval/workspace/paths.go:22
↓ 6 callersFunctionparseChannelMessages
parseChannelMessages converts a script-supplied list (typically []any returned by getChannel + push, or freshly built by the script) into a []model.Me
sdk/script/bindings/llm_marshal.go:262
↓ 6 callersMethodpeekScopeGen
peekScopeGen returns the current wipe generation for the scope's canonical (runtime, user) partition.
memory/recall/scope_generation.go:12
↓ 6 callersFunctionphs
(start, n int)
memory/recall/store/sqlite/backend.go:90
← previousnext →1,001–1,100 of 13,468, ranked by callers