MCPcopy Create free account

hub / github.com/cloudflare/artifact-fs / functions

Functions761 in github.com/cloudflare/artifact-fs

↓ 3 callersFunctionupsertState
(ctx context.Context, tx *sql.Tx, key string, value string)
internal/snapshot/store.go:228
↓ 3 callersFunctionuserinfoLikeBeforePath
(candidate string)
internal/auth/redact.go:257
↓ 3 callersFunctionvalidateOptionalString
(name: string, value: unknown)
examples/cloudflare-sandbox-sdk/src/index.ts:457
↓ 3 callersFunctionwaitBenchmarkHydratorIdle
(b *testing.B, h *Service, repoID model.RepoID)
internal/hydrator/hydrator_benchmark_test.go:283
↓ 2 callersMethodBlobToCache
(ctx context.Context, repo RepoConfig, objectOID string, dstPath string)
internal/model/types.go:164
↓ 2 callersMethodCommitTime
()
internal/fusefs/merged.go:46
↓ 2 callersMethodCommitTimestamp
(ctx context.Context, repo RepoConfig, oid string)
internal/model/types.go:167
↓ 2 callersMethodCreate
(ctx context.Context, path string, mode uint32)
internal/fusefs/ops.go:96
↓ 2 callersMethodEnqueueBatch
(tasks []HydrationTask)
internal/model/types.go:197
↓ 2 callersMethodLen
()
internal/hydrator/hydrator.go:539
↓ 2 callersMethodListByPrefix
(ctx context.Context, prefix string)
internal/model/types.go:192
↓ 2 callersMethodLookUpInode
(context.Context, *fuseops.LookUpInodeOp)
internal/fusefs/gated_fs_test.go:22
↓ 2 callersFunctionMountRepoWithGate
(repo model.RepoConfig, resolver *Resolver, engine *Engine, gate *ReadyGate)
internal/fusefs/fuse_unix.go:714
↓ 2 callersFunctionNew
(ctx context.Context, dbPath string)
internal/registry/registry.go:46
↓ 2 callersFunctionParseRefresh
(v string)
internal/daemon/daemon.go:1334
↓ 2 callersMethodPrepare
(ctx context.Context, name string)
internal/daemon/daemon.go:424
↓ 2 callersMethodQueueDepth
(repoID RepoID)
internal/model/types.go:200
↓ 2 callersMethodReadTreeHEAD
ReadTreeHEAD updates the git index to match HEAD. Must be called after HEAD changes (branch switch, commit) so git status inside the mount is correct.
internal/gitstore/gitstore.go:823
↓ 2 callersMethodRemoveRepo
(ctx context.Context, name string)
internal/model/types.go:152
↓ 2 callersMethodSetHydrationConcurrency
(n int)
internal/daemon/daemon.go:111
↓ 2 callersMethodUpdatePrepareState
(ctx context.Context, repoID model.RepoID, state string, prepareErr string)
internal/registry/registry.go:91
↓ 2 callersMethodUpdatePrepareStateForConfig
(ctx context.Context, cfg model.RepoConfig, state string, prepareErr string)
internal/registry/registry.go:100
↓ 2 callersMethodValidateAmbientRemote
(repo model.RepoConfig)
internal/gitstore/gitstore.go:164
↓ 2 callersMethodWrite
(ctx context.Context, path string, off int64, data []byte)
internal/fusefs/ops.go:83
↓ 2 callersMethodalive
()
internal/gitstore/gitstore.go:678
↓ 2 callersFunctionapplyAheadBehind
(st *model.RepoRuntimeState, state aheadBehind)
internal/daemon/daemon.go:1214
↓ 2 callersFunctionapplyHydrationStats
(st *model.RepoRuntimeState, cacheDir string)
internal/daemon/daemon.go:1238
↓ 2 callersMethodapplyPrepareState
(ctx context.Context, cfg model.RepoConfig, state string, stateErr error, applyReadyRuntime bool)
internal/daemon/daemon.go:894
↓ 2 callersFunctionauthorizeRequest
(request: Request, env: Env)
examples/cloudflare-sandbox-sdk/src/index.ts:540
↓ 2 callersFunctionbranchRefName
(ref string)
internal/daemon/daemon.go:814
↓ 2 callersMethodchanged
(path string)
internal/watcher/watcher.go:85
↓ 2 callersFunctionchildName
childName extracts the immediate child name of entryPath under parent. Returns ("", false) if entryPath is not a descendant of parent.
internal/fusefs/merged.go:18
↓ 2 callersMethodcloneBlobless
(ctx context.Context, cfg model.RepoConfig, extraEnv []string)
internal/gitstore/gitstore.go:89
↓ 2 callersMethodclose
(t *testing.T)
e2e_git_test.go:109
↓ 2 callersMethodcloseAll
(value T)
internal/hydrator/inflight.go:39
↓ 2 callersFunctioncollectMountedRepoState
( sandbox: ReturnType<typeof getSandbox>, repoName: string, mountPath: string )
examples/cloudflare-sandbox-sdk/src/index.ts:344
↓ 2 callersFunctioncompareMountMetadata
( existing: StoredMountMetadata | null, requested: { remote?: string; branch?: string; repoNam
examples/cloudflare-sandbox-sdk/src/index.ts:398
↓ 2 callersFunctioncreatePreparedGitDir
(t *testing.T, remoteURL string)
e2e_async_test.go:130
↓ 2 callersMethodcurrentRefChanged
(refPath string)
internal/watcher/watcher.go:60
↓ 2 callersMethodensurePreparedRepo
ensurePreparedRepo makes sure the repo is cloned and has an initial snapshot. The returned snapshot store remains open for callers that need to contin
internal/daemon/daemon.go:493
↓ 2 callersFunctionerrorResponse
(error: unknown)
examples/cloudflare-sandbox-sdk/src/index.ts:527
↓ 2 callersFunctionfetchBatchToFile
(ctx context.Context, batch *batchCatFile, objectOID string, dstPath string)
internal/gitstore/gitstore.go:489
↓ 2 callersFunctionfetchRefTarget
(repo model.RepoConfig, ref string)
internal/gitstore/gitstore.go:1201
↓ 2 callersMethodfetchState
(ctx context.Context, cfg model.RepoConfig)
internal/daemon/daemon.go:1160
↓ 2 callersMethodfileHandle
(handleID fuseops.HandleID)
internal/fusefs/fuse_unix.go:147
↓ 2 callersFunctiongitArgsWithSafeDirectory
(dir string, args ...string)
e2e_test.go:502
↓ 2 callersFunctiongitCmdQuiet
(t *testing.T, dir string, args ...string)
e2e_git_test.go:427
↓ 2 callersMethodheadRefPath
(headPath string)
internal/watcher/watcher.go:68
↓ 2 callersFunctionhydrateBenchmarkNodes
(b *testing.B, h *Service, cfg model.RepoConfig, nodes []model.BaseNode, callerWorkers int)
internal/hydrator/hydrator_benchmark_test.go:262
↓ 2 callersMethodhydrationWorkers
()
internal/daemon/daemon.go:118
↓ 2 callersFunctionisMalformedHTTPUserinfo
(raw string, u *url.URL)
internal/auth/redact.go:138
↓ 2 callersFunctionisMounted
isMounted checks whether the given path is a FUSE mount point by reading /proc/mounts.
e2e_setup_linux_test.go:25
↓ 2 callersFunctionisPendingOrFailedPrepareState
(state string)
internal/daemon/daemon.go:1353
↓ 2 callersFunctionisSCPStyleRemote
(raw string)
internal/gitstore/gitstore.go:1053
↓ 2 callersFunctionmalformedUserinfoInRemote
(rawURL string, u *url.URL)
internal/gitstore/gitstore.go:983
↓ 2 callersFunctionmarkFetchResult
(st *model.RepoRuntimeState, at time.Time, result string)
internal/daemon/daemon.go:1225
↓ 2 callersMethodmountRepo
mountRepo opens all stores, starts the FUSE server, watcher, and refresh loop. Called by the daemon's Start for each registered repo.
internal/daemon/daemon.go:521
↓ 2 callersFunctionnewAsyncPreparedE2ERepo
(t *testing.T, preparedGitDir string, fetchRef string)
e2e_async_test.go:167
↓ 2 callersFunctionnormalizeMode
normalizeMode ensures sane permission bits. Git tree entries have mode 040000 which has zero permission bits after masking; directories need at least
internal/fusefs/merged.go:100
↓ 2 callersFunctionnormalizeRemote
(value: string)
examples/cloudflare-sandbox-sdk/src/index.ts:236
↓ 2 callersFunctionnormalizeRequestedSandboxId
(value: string)
examples/cloudflare-sandbox-sdk/src/index.ts:307
↓ 2 callersMethodnotifyHydrated
(repoID model.RepoID, objectOID string, size int64)
internal/hydrator/hydrator.go:458
↓ 2 callersFunctionparseStatusOutput
(out string)
e2e_git_test.go:491
↓ 2 callersFunctionpercentiles
(durs []time.Duration)
bench_test.go:434
↓ 2 callersFunctionpickHydrationSample
pickHydrationSample selects files for hydration testing, preferring small text files to avoid slow binary downloads dominating the benchmark.
bench_test.go:402
↓ 2 callersFunctionprepareGateError
(msg string)
internal/daemon/daemon.go:1369
↓ 2 callersMethodprepareRepo
prepareRepo clones the git repo and builds the initial snapshot. It does NOT start a FUSE mount or any background goroutines, so it's safe to call fro
internal/daemon/daemon.go:481
↓ 2 callersFunctionreadBatchBlob
(ctx context.Context, batch *batchCatFile, objectOID string, maxBytes int64)
internal/gitstore/gitstore.go:542
↓ 2 callersFunctionreadFileChunk
(path string, off int64, size int)
internal/fusefs/ops.go:234
↓ 2 callersFunctionreadMountMetadata
( sandbox: ReturnType<typeof getSandbox> )
examples/cloudflare-sandbox-sdk/src/index.ts:384
↓ 2 callersMethodreadObjectSize
(oid string)
internal/gitstore/gitstore.go:784
↓ 2 callersMethodreadPersistedStatus
(ctx context.Context, cfg model.RepoConfig)
internal/daemon/daemon.go:1021
↓ 2 callersFunctionredactMalformedURL
(raw string)
internal/auth/redact.go:38
↓ 2 callersFunctionredactQueryFragment
(raw string)
internal/auth/redact.go:57
↓ 2 callersFunctionremoteHasInlineCredentials
(rawURL string)
internal/gitstore/gitstore.go:965
↓ 2 callersFunctionremoteStartIndex
(s string)
internal/auth/redact.go:471
↓ 2 callersMethodremove
(key string, ch chan T)
internal/hydrator/inflight.go:14
↓ 2 callersFunctionremoveAllWithRetry
(t *testing.T, path string)
e2e_git_test.go:538
↓ 2 callersMethodremoveInvalidCacheFile
(cachePath string, repoID model.RepoID, objectOID string)
internal/hydrator/hydrator.go:295
↓ 2 callersMethodresetRunningPrepareState
(cfg model.RepoConfig)
internal/daemon/daemon.go:705
↓ 2 callersMethodresolveAttrs
(ctx context.Context, path string)
internal/fusefs/fuse_unix.go:325
↓ 2 callersMethodrestartRunningPrepareIfCurrent
(ctx context.Context, repo model.RepoConfig, rt *repoRuntime, alreadyPreparing bool)
internal/daemon/daemon.go:235
↓ 2 callersFunctionscanRepo
(s scanner)
internal/registry/registry.go:160
↓ 2 callersFunctionschemeLessUserinfoHasPassword
(raw string)
internal/gitstore/gitstore.go:1033
↓ 2 callersFunctionsetHeadState
(st *model.RepoRuntimeState, oid string, ref string, gen int64)
internal/daemon/daemon.go:1208
↓ 2 callersMethodsetPrepareState
(ctx context.Context, cfg model.RepoConfig, state string, stateErr error)
internal/daemon/daemon.go:886
↓ 2 callersFunctionshouldMountAsync
(cfg model.RepoConfig)
internal/daemon/daemon.go:1349
↓ 2 callersMethodstartRepoBackground
(rt *repoRuntime)
internal/daemon/daemon.go:1180
↓ 2 callersMethodstartRuntime
(rt *repoRuntime)
internal/daemon/daemon.go:1168
↓ 2 callersFunctionstateInt64
(ctx context.Context, q stateQueryer, key string)
internal/snapshot/store.go:216
↓ 2 callersMethodstopRuntime
(rt *repoRuntime)
internal/daemon/daemon.go:1282
↓ 2 callersFunctionwaitFor
(t *testing.T, timeout time.Duration, ready func() bool)
internal/daemon/async_test.go:741
↓ 1 callersMethodBaseCachePath
(ctx context.Context, path string)
internal/fusefs/ops.go:63
↓ 1 callersMethodBlobToCache
(ctx context.Context, repo model.RepoConfig, objectOID string, dstPath string)
internal/hydrator/hydrator.go:18
↓ 1 callersMethodComputeAheadBehind
(ctx context.Context, repo RepoConfig)
internal/model/types.go:166
↓ 1 callersMethodFetchNow
(ctx context.Context, name string)
internal/daemon/daemon.go:398
↓ 1 callersMethodFetchRefNonInteractive
(ctx context.Context, repo model.RepoConfig, ref string)
internal/gitstore/gitstore.go:132
↓ 1 callersMethodGetNodeCtx
(ctx context.Context, generation int64, path string)
internal/snapshot/store.go:135
↓ 1 callersFunctionMountRepo
(repo model.RepoConfig, resolver *Resolver, engine *Engine)
internal/fusefs/fuse_unix.go:710
↓ 1 callersMethodPop
()
internal/hydrator/hydrator.go:555
← previousnext →201–300 of 761, ranked by callers