Code
Hub
Workspaces
Following
Trending
Connect
MCP
copy
Create free account
hub
/
github.com/GizClaw/flowcraft
/ functions
Functions
13,468 in github.com/GizClaw/flowcraft
⨍
Functions
13,468
◇
Types & classes
2,684
↓ 19 callers
Method
Play
Play starts playing utterances from the stream asynchronously. It returns a channel that is closed when playback finishes (drained or aborted). Strea
voice/sink.go:16
↓ 19 callers
Method
RegisterBuilder
RegisterBuilder registers builder for the given node type. Re-registering the same type overwrites the previous entry.
sdk/graph/node/factory.go:54
↓ 19 callers
Method
RoundTrip
RoundTrip starts one user turn. A newer turn interrupts the previous active turn for the same Claw instance.
sdkx/claw/roundtrip.go:95
↓ 19 callers
Method
Run
(ctx context.Context, state *read.ReadState)
memory/recall/internal/pipeline/read/stages/context_pack.go:29
↓ 19 callers
Method
Tokenize
Tokenize implements Tokenizer.
memory/text/tokenize/simple.go:61
↓ 19 callers
Function
WithPoolSize
WithPoolSize sets the VM pool size.
sdk/script/luart/luart.go:26
↓ 19 callers
Function
asSlice
asSlice mirrors asMap for arrays.
eval/taubench/sierra_common.go:83
↓ 19 callers
Function
launchedCaptain
launchedCaptain is a small helper that wraps New + Launch + t.Cleanup for the common "build, start, run one Call" path.
tests/quality/vessel/helpers_test.go:99
↓ 19 callers
Function
makeLoudFrame
(samples int)
voice/session_test.go:31
↓ 19 callers
Method
save
(ctx context.Context, st state)
memory/recall/store/workspace/backend.go:84
↓ 19 callers
Function
streamSubscribeFunc
(t *testing.T, runID string, bus event.Bus)
sdk/graph/node/scriptnode/bridge_stream_test.go:763
↓ 18 callers
Method
Aggregate
Aggregate returns errors.Join over every entry, or nil if empty. Use this when handing the aggregate to a caller that wants standard error inspection.
cmd/vesseld/resolver/errors.go:49
↓ 18 callers
Method
GetMessages
(ctx context.Context, conversationID string)
memory/history/store.go:263
↓ 18 callers
Method
GetMessages
(ctx context.Context, conversationID string)
sdk/history/store.go:263
↓ 18 callers
Method
Interrupted
()
sdk/errdefs/errors.go:48
↓ 18 callers
Method
Iterate
(ctx context.Context, namespace string, cursor string, batch int)
sdk/retrieval/index.go:61
↓ 18 callers
Method
List
(ctx context.Context, dir string)
sdk/workspace/workspace.go:36
↓ 18 callers
Function
New
New creates an Anthropic LLM instance.
sdkx/llm/anthropic/anthropic.go:185
↓ 18 callers
Function
New
(opts ...TTSOption)
voice/tts/minimax/minimax.go:99
↓ 18 callers
Method
NewFromConfig
NewFromConfig creates a raw LLM instance via the registered factory. Important: this method no longer wraps the instance with caps / defaults / limit
sdk/llm/factory.go:100
↓ 18 callers
Method
SaveMessages
(ctx context.Context, conversationID string, messages []model.Message)
sdk/history/store.go:23
↓ 18 callers
Method
Stderr
Stderr returns the captured stderr+stdout text. Useful in test failure messages so the user sees the daemon log without having to re-run.
tests/e2e/vesseld/helpers/daemon.go:218
↓ 18 callers
Method
Structurize
(f domain.TemporalFact, input IngestInput)
memory/recall/internal/port/ingest.go:73
↓ 18 callers
Method
Tokenize
(text string)
sdk/textsearch/tokenizer.go:19
↓ 18 callers
Function
samePartition
(a, b domain.Scope)
memory/recall/store/workspace/backend.go:95
↓ 18 callers
Function
startRound
startRound resolves the model and opens the underlying stream. Failure to resolve or to open the stream surfaces as a rich error containing the source
sdk/script/bindings/bridge_llm_round.go:151
↓ 18 callers
Function
stringSchema
(desc string)
eval/taubench/retail.go:322
↓ 18 callers
Function
withRunID
(ev Event, runID string)
voice/pipeline.go:312
↓ 18 callers
Function
writeError
writeError translates a Go error into HTTP status + JSON body. The `reason` field carries the errdefs category name so clients can branch without stri
cmd/vesseld/api/errors.go:21
↓ 17 callers
Method
AddDocument
AddDocument updates corpus statistics for a new document's tokens.
sdk/textsearch/bm25.go:19
↓ 17 callers
Method
Definition
()
sdk/tool/tool.go:13
↓ 17 callers
Method
Exec
Exec runs cmd with args under opts. See LocalRunner doc for which policy fields are honoured vs. rejected with errdefs.NotAvailable.
sdk/sandbox/local.go:72
↓ 17 callers
Method
List
List returns ObservedAt-ascending facts filtered by the supplied query. The default view hides superseded facts.
memory/recall/internal/store/temporal/memory.go:145
↓ 17 callers
Method
Message
()
sdk/llm/llm.go:132
↓ 17 callers
Method
Rename
Rename moves src to dst within the same workspace. Implementations MUST be atomic when the underlying medium supports it (e.g. POSIX rename(2) on a lo
sdk/workspace/workspace.go:33
↓ 17 callers
Method
ReportUsage
(ctx context.Context, usage model.TokenUsage)
sdk/engine/host.go:118
↓ 17 callers
Method
Snapshot
---------- Snapshot / Restore ---------- Snapshot returns a serialisable copy of the current state. Vars are deep-copied so the snapshot is safe to re
sdk/engine/board.go:233
↓ 17 callers
Method
Snapshot
(ctx context.Context, namespace string, dst io.Writer)
sdk/retrieval/index.go:55
↓ 17 callers
Function
WithAPIKey
(key string)
voice/tts/minimax/minimax.go:52
↓ 17 callers
Function
mustUpsert
(t *testing.T, idx retrieval.Index, ns string, docs []retrieval.Doc)
memory/retrieval/contract/contract.go:39
↓ 17 callers
Function
withCompiler
Internal injection helpers — used by package-internal tests and adapter wiring. Not part of the public surface.
memory/recall/options.go:121
↓ 17 callers
Function
withProviderReport
(ev Event, report provider.Report)
voice/provider_observability.go:7
↓ 16 callers
Method
Close
Close stops the background cleanup goroutine.
memory/history/store.go:103
↓ 16 callers
Method
Close
Close stops the background cleanup goroutine.
sdk/history/store.go:103
↓ 16 callers
Method
Context
Context returns the owner context shared by all accepted work.
memory/internal/background/group.go:39
↓ 16 callers
Method
CountByStatus
CountByStatus returns the number of cards in the given status. If cardType is non-empty, only cards of that type are counted.
sdk/kanban/board.go:440
↓ 16 callers
Method
DeleteByDataset
(ctx context.Context, datasetID string)
sdk/knowledge/repo.go:48
↓ 16 callers
Method
DeleteByDoc
DeleteByDoc removes all chunks for a document. Missing target documents are idempotent success and MUST NOT return NotFound.
sdk/knowledge/repo.go:47
↓ 16 callers
Method
GetCardByID
GetCardByID returns a deep copy of the card with the given ID, or nil if not found.
sdk/kanban/board.go:428
↓ 16 callers
Method
Matches
Matches reports whether s satisfies pattern p. Matching is segment-wise: - literal segments must compare byte-for-byte equal; - '*' matches any singl
sdk/event/subject.go:130
↓ 16 callers
Function
New
New builds an adapter pointing at the Seedream endpoint. An empty model defaults to "doubao-seedream-5-0-260128"; an empty baseURL defaults to https:/
sdkx/llm/bytedance/image/image.go:130
↓ 16 callers
Function
New
New constructs a retrieval Projection backed by index. Index ownership stays with the caller (Memory.Close closes the index, not the projection).
memory/recall/internal/lens/retrieval/projection.go:59
↓ 16 callers
Function
New
New constructs a Pipeline.
memory/retrieval/pipeline/pipeline.go:117
↓ 16 callers
Function
New
New constructs a Pipeline.
sdk/retrieval/pipeline/pipeline.go:117
↓ 16 callers
Method
Plays
()
voice/session_test.go:100
↓ 16 callers
Method
Read
(_ context.Context, path string)
sdk/workspace/mem.go:33
↓ 16 callers
Method
Resolve
Resolve replaces all ${scope.name} references in template with actual values. References that cannot be resolved are left unchanged.
sdk/graph/variable/resolver.go:66
↓ 16 callers
Method
Root
()
sdk/retrieval/bbh/index.go:42
↓ 16 callers
Method
SetChannel
SetChannel replaces the entire message list for a channel. The input slice is copied; later mutations by the caller do not affect the Board.
sdk/engine/board.go:194
↓ 16 callers
Function
errorEvent
(err error)
voice/pipeline.go:319
↓ 16 callers
Function
kindOf
--------------------------------------------------------------------------- helpers — env.Header(HeaderKanbanKind) is the canonical "what kind of kanb
sdk/kanban/events_test.go:344
↓ 16 callers
Function
makePCM16Sine
--- helpers ---
voice/audio/resample_test.go:15
↓ 16 callers
Function
newChunkRepo
(t *testing.T)
memory/knowledge/backend/fs/chunk_test.go:16
↓ 16 callers
Function
newChunkRepo
(t *testing.T)
sdk/knowledge/backend/fs/chunk_test.go:16
↓ 16 callers
Function
newTool
(t *testing.T)
sdkx/tool/memory/tool_test.go:13
↓ 16 callers
Function
saveText
saveText is a tiny helper that runs Save with a single user message and returns the resulting entry IDs in order.
sdk/recall/resolver_test.go:43
↓ 16 callers
Function
scope
()
memory/recall/internal/lens/timeline/projection_test.go:11
↓ 15 callers
Method
Capabilities
()
sdk/retrieval/index.go:14
↓ 15 callers
Method
Close
Close releases bookkeeping resources for runID. Whether the underlying data is also deleted is implementation-defined: MemorySessionStore drops the in
vessel/session.go:49
↓ 15 callers
Method
Extract
(ctx context.Context, input port.IngestInput)
memory/recall/internal/ingest/extractor_llm_two_pass.go:749
↓ 15 callers
Method
HTTPClient
HTTPClient returns an http.Client whose transport dials the daemon's unix socket. The base URL for any request is `http://vesseld` — the host name is
tests/e2e/vesseld/helpers/daemon.go:224
↓ 15 callers
Function
Load
Load parses spec and returns the provider name, model, and config map ready for sdk/llm.NewFromConfig or sdkx/embedding.NewFromConfig. spec is "<alia
eval/internal/env/provider.go:70
↓ 15 callers
Function
NewTwoPassLLMExtractor
(client llm.LLM)
memory/recall/internal/ingest/extractor_llm_two_pass.go:729
↓ 15 callers
Method
OnStage
(event diagnostic.StageDiagnostic)
memory/recall/internal/port/telemetry.go:10
↓ 15 callers
Method
Register
Register appends a lens. Order matches planner source priority.
memory/recall/internal/lens/registry.go:21
↓ 15 callers
Method
RegisterEngine
RegisterEngine registers an engine factory under name. Re-registering the same name overwrites — this is intentional so a fork of vesseld can replace
cmd/vesseld/catalog/catalog.go:195
↓ 15 callers
Method
RunAudio
RunAudio processes a complete audio input in one shot. Requires a non-nil STT provider.
voice/pipeline.go:253
↓ 15 callers
Method
ServeHTTP
(w http.ResponseWriter, r *http.Request)
sdkx/llm/anthropic/cache_integration_test.go:28
↓ 15 callers
Method
Stats
Stats returns queue depth and terminal-state counts for operators. Implementations MUST require a non-zero Scope partition (RuntimeID and UserID); glo
memory/recall/internal/port/async_semantic.go:50
↓ 15 callers
Function
Stem
Stem applies a simplified Porter stemmer to the given word.
sdk/textsearch/stemmer.go:6
↓ 15 callers
Method
Stream
()
voice/source.go:13
↓ 15 callers
Method
String
()
tests/e2e/vesseld/helpers/daemon.go:289
↓ 15 callers
Function
WithMeta
WithMeta attaches a key-value pair to the card's metadata.
sdk/kanban/card.go:63
↓ 15 callers
Function
candidateSnapshotPtr
(in []diagnostic.CandidateSnapshot)
memory/recall/internal/pipeline/read/stages/audit_snapshots.go:24
↓ 15 callers
Function
echoEngine
echoEngine is a minimal engine.EngineFunc test double that turns every user message into an assistant echo, so vessel tests can assert on Result.Messa
vessel/captain_test.go:23
↓ 15 callers
Function
hasTask
(tasks []domain.QueryTaskIntent, want domain.QueryTaskIntent)
memory/recall/internal/pipeline/read/stages/candidate_expansion_suggestions.go:18
↓ 15 callers
Function
newLayerRepo
(t *testing.T)
memory/knowledge/backend/fs/layer_test.go:13
↓ 15 callers
Function
newLayerRepo
(t *testing.T)
sdk/knowledge/backend/fs/layer_test.go:13
↓ 15 callers
Function
newResolverMockStore
()
sdk/llm/resolver_test.go:38
↓ 15 callers
Function
providerReport
(recorder *provider.Recorder, operation string)
voice/pipeline.go:334
↓ 14 callers
Method
AppendMemoryFact
AppendMemoryFact writes a caller-supplied structured fact into this Claw workspace's configured memory runtime without creating a chat turn.
sdkx/claw/memory_fact.go:98
↓ 14 callers
Method
Channel
---------- Channels ---------- Channel returns a copy of messages for the given channel. An empty or missing channel returns a nil slice (not a zero-l
sdk/engine/board.go:181
↓ 14 callers
Method
Complete
(ctx context.Context, requestID, leaseToken string, result AsyncSemanticResult)
memory/recall/internal/port/async_semantic.go:45
↓ 14 callers
Method
Delete
(ctx context.Context, datasetID, name string)
sdk/knowledge/repo.go:21
↓ 14 callers
Method
Error
()
sdk/agent/run_test.go:187
↓ 14 callers
Function
ExtractFeatures
ExtractFeatures returns the shared query-understanding features for a recall query. It is part of the intent pipeline; non-intent callers should prefe
memory/recall/internal/intent/features.go:19
↓ 14 callers
Method
Generate
(ctx context.Context, messages []llm.Message, opts ...llm.GenerateOption)
sdkx/llm/mock/mock.go:34
↓ 14 callers
Method
IsValid
IsValid checks if the video ID is valid (11 characters, alphanumeric + hyphen/underscore).
sdkx/extract/youtube/detect.go:14
↓ 14 callers
Method
List
(ctx context.Context)
sdk/recall/namespace_registry.go:16
↓ 14 callers
Method
List
(ctx context.Context, datasetID string)
sdk/knowledge/repo.go:22
← previous
next →
301–400 of 13,468, ranked by callers