MCPcopy Create free account

hub / github.com/awslabs/soci-snapshotter / functions

Functions1,722 in github.com/awslabs/soci-snapshotter

↓ 786 callersMethodErrorf
Errorf is called when Shell encounters unrecoverable error.
util/dockershell/shell.go:55
↓ 199 callersMethodX
X executes a command. Stdio is streamed to Reporter. When the command fails, the error is reported via Reporter.Errorf and this Shell is marked as "in
util/dockershell/shell.go:159
↓ 173 callersMethodString
()
fs/unpacker_test.go:321
↓ 166 callersMethodRun
Run runs the specified commands.
util/dockershell/exec/cmd.go:158
↓ 159 callersMethodFatal
(format string, v ...interface{})
util/dockershell/shell.go:128
↓ 122 callersMethodmirror
(imageName string, opts ...imageOpt)
integration/util_test.go:634
↓ 99 callersMethodClose
()
fs/remote/blob.go:64
↓ 99 callersFunctionrebootContainerd
(t *testing.T, sh *shell.Shell, customContainerdConfig, customSnapshotterConfig string, monitorFuncs ...func(s
integration/util_test.go:936
↓ 97 callersMethodUnlock
Unlock unlocks the mutex of the given name
util/namedmutex/namedmutex.go:68
↓ 93 callersMethodLock
Lock locks the mutex of the given name
util/namedmutex/namedmutex.go:50
↓ 85 callersFunctionFile
File is a regular file entry
util/testutil/tar.go:372
↓ 76 callersFunctiondockerhub
(name string, opts ...imageOpt)
integration/util_test.go:551
↓ 75 callersMethodGet
Get returns a reader to read the specified contents from cache
cache/cache.go:91
↓ 65 callersFunctiongetSnapshotterConfigToml
(t *testing.T, opts ...snapshotterConfigOpt)
integration/util_test.go:484
↓ 58 callersMethodO
O executes a command and return the stdout. Stderr is streamed to Reporter. When the command fails, the error is reported via Reporter.Errorf and this
util/dockershell/shell.go:304
↓ 56 callersMethodRandomByteData
RandomByteData returns a byte slice with `size` populated with random generated data
util/testutil/random.go:61
↓ 55 callersMethodString
()
integration/convert_test.go:373
↓ 54 callersMethodCommand
Command creates a new Cmd for the specified commands.
util/dockershell/exec/cmd.go:63
↓ 54 callersFunctionbuildIndex
buildIndex builds an index for the source image with given options. By default, it will build with min-layer-size = 0 and span-size = CLI default retu
integration/util_soci_test.go:162
↓ 51 callersFunctiongetContainerdConfigToml
getContainerdConfigToml creates a containerd config yaml, by appending all `additionalConfigs` to the default `containerdConfigTemplate`.
integration/util_test.go:341
↓ 46 callersFunctionwithMinLayerSize
withMinLayerSize overrides the minimum layer size for which to create a ztoc when creating an index with `buildIndex`
integration/util_soci_test.go:111
↓ 43 callersFunctionnewRegistryConfig
(opts ...registryConfigOpt)
integration/util_test.go:610
↓ 41 callersFunctioncopyImage
(sh *shell.Shell, src, dst imageInfo)
integration/util_test.go:573
↓ 41 callersFunctionnewShellWithRegistry
(t *testing.T, r registryConfig, opts ...registryOpt)
integration/util_test.go:662
↓ 39 callersMethodAdd
Add returns a writer to add contents to cache
cache/cache.go:87
↓ 39 callersMethodUnmarshal
Unmarshal deserialize the passed uidmap and gidmap strings into a IDMap object. Error is returned in case of failure
idtools/idmap.go:138
↓ 30 callersMethodInfo
Info returns the information of this layer.
fs/layer/layer.go:91
↓ 30 callersMethodOLog
OLog executes a command and return the stdout. Stdio is streamed to Reporter. When the command fails, different from O, the error is reported via Repo
util/dockershell/shell.go:325
↓ 30 callersFunctionfatalf
fatalf prints a formatted fatal error mesage to both stdout and a testing.B. When running benchmarks with `go test -bench=.`, the `testing.B`'s output
benchmark/benchmarkTests.go:56
↓ 29 callersMethodRun
Run waits for f.waitPeriod to pass before emitting a log and metric for each operation in FuseOpsList. Should be started in different goroutine so tha
fs/layer/node.go:172
↓ 27 callersMethodDone
Done releases the reference to this layer. The resources related to this layer will be discarded sooner or later. Queries after calling this function
fs/layer/layer.go:110
↓ 27 callersMethodOpen
(ctx context.Context, flags uint32)
fs/layer/node.go:481
↓ 27 callersMethodPipe
Pipe executes passed commands sequentially and stdout of a command is piped into the next command's stdin. The stdout of the last command is streamed
util/dockershell/shell.go:224
↓ 26 callersFunctionnewSnapshotterBaseShell
(t *testing.T, opts ...composeDefaultTemplateOpt)
integration/util_test.go:788
↓ 25 callersMethodName
()
ztoc/fbs/ztoc/FileMetadata.go:36
↓ 25 callersMethodStat
Stat returns the info for an active or committed snapshot by name or key. Should be used for parent resolution, existence checks and to discern the k
snapshot/snapshot.go:252
↓ 22 callersMethodClose
Close closes the cache
cache/cache.go:94
↓ 22 callersMethodLogf
Logf is called to report some useful information (e.g. executing command) by Shell.
util/dockershell/shell.go:58
↓ 21 callersMethodFetch
(ctx context.Context, off int64, size int64)
fs/remote/resolver.go:679
↓ 20 callersMethodcreds
()
integration/util_test.go:630
↓ 19 callersFunctionNewTestRand
NewSetSeedRand allows us to have deterministic tests by seeding the random var. It uses the test name as part of the seed, which allows better randomn
util/testutil/random.go:43
↓ 19 callersMethodWait
()
fs/unpacker_test.go:313
↓ 19 callersFunctiongetImageDigest
(sh *shell.Shell, ref string)
integration/util_test.go:887
↓ 18 callersMethodDo
Do sends a request using the underlying retryable client. If no error is returned and the AuthPolicy deems that the response warrants authentication,
internal/http/auth.go:137
↓ 18 callersMethodEqual
(o FileMetadata)
ztoc/ztoc.go:112
↓ 18 callersMethodPut
(buffer *[]byte)
fs/unpacker.go:119
↓ 16 callersFunctionArtifactsDbPath
Get the default artifacts db path
soci/artifacts.go:96
↓ 16 callersMethodCleanup
Cleanup cleans up disk resources from removed or abandoned snapshots
snapshot/snapshot.go:685
↓ 16 callersMethodCreate
Create an unpack job in storage and return its unique identifier.
fs/adaptive_fetch_image_layers.go:277
↓ 16 callersMethodRemove
Remove removes the specified contents from the cache. OnEvicted callback will be called when nobody refers to the removed content.
util/lrucache/lrucache.go:107
↓ 15 callersMethodGetAttr
(id uint32)
metadata/metadata.go:84
↓ 15 callersFunctionNewDB
NewDB returns an instance of an ArtifactsDB
soci/artifacts.go:132
↓ 15 callersMethodPrepare
(ctx context.Context, key, parent string, opts ...snapshots.Opt)
snapshot/snapshot.go:365
↓ 15 callersMethodSize
()
fs/remote/blob.go:60
↓ 15 callersMethodStore
Store takes in a descriptor and io.Reader and stores it in the local store.
fs/artifact_fetcher.go:52
↓ 14 callersMethodCommit
()
cache/cache.go:108
↓ 14 callersMethodDigest
()
soci/util_test.go:165
↓ 14 callersFunctionDir
Dir is a directory entry
util/testutil/tar.go:306
↓ 14 callersMethodOpenFile
(id uint32)
fs/reader/reader.go:61
↓ 14 callersMethodReadAt
(p []byte, offset int64, opts ...Option)
fs/remote/blob.go:62
↓ 14 callersFunctionhasFile
(name string, size int64)
metadata/util_test.go:415
↓ 14 callersMethodupperPath
upperPath produces a file path like "{snapshotter.root}/snapshots/{id}/fs"
snapshot/snapshot.go:993
↓ 13 callersFunctionBuildZtocReader
BuildZtocReader creates the tar gz file for tar entries. It returns ztoc and io.SectionReader of the file.
ztoc/testutil.go:30
↓ 13 callersMethodClose
()
fs/reader/reader.go:63
↓ 13 callersFunctioncheckFuseMounts
(t *testing.T, sh *shell.Shell, remoteSnapshotsExpectedCount int)
integration/pull_test.go:214
↓ 13 callersFunctionfailOnError
(t *testing.T, fn func() error)
snapshot/snapshot_test.go:72
↓ 13 callersFunctionlookup
(r testableReader, name string)
metadata/util_test.go:529
↓ 12 callersMethodBytes
Bytes serilizes the underlying zinfo data (depending on implementation) into bytes for storage.
ztoc/compression/zinfo.go:46
↓ 12 callersMethodCombinedOLog
CombinedOLog executes a command and return the stdout and stderr as a combined stream. When the command fails, the error is reported via Reporter.Logf
util/dockershell/shell.go:346
↓ 12 callersMethodRemove
Remove abandons the snapshot identified by key. The snapshot will immediately become unavailable and unrecoverable. Disk space will be freed up on the
snapshot/snapshot.go:597
↓ 12 callersFunctionWithType
(contentStoreType ContentStoreType)
soci/store/store.go:145
↓ 12 callersMethodreportFailure
reportFailure handles telemetry operations pertaining to FUSE failures as well as writing an error to the state file.
fs/layer/node.go:260
↓ 12 callersFunctionwithContentStoreType
withContentStoreType overrides the default content store
integration/util_soci_test.go:131
↓ 11 callersFunctionGetContentStoreBlobPath
GetContentStoreBlobPath returns the bottom level directory for the content store, e.g. "/blobs/sha256".
util/testutil/store.go:42
↓ 11 callersMethodPath
()
internal/archive/compression/compression.go:144
↓ 11 callersFunctiondecode_int32
ztoc/compression/gzip_zinfo.c:73
↓ 11 callersFunctionputInt
(b *bolt.Bucket, k []byte, v int64)
metadata/db.go:413
↓ 11 callersFunctionwithContentStoreConfig
(opts ...store.Option)
integration/util_test.go:1142
↓ 10 callersMethodArgs
()
internal/archive/compression/compression.go:145
↓ 10 callersFunctionContentStoreOptions
ContentStoreOptions builds a list of content store options from a CLI context.
cmd/soci/commands/internal/store.go:28
↓ 10 callersFunctionNew
New creates new cache.
util/lrucache/lrucache.go:55
↓ 10 callersFunctionNewContentStore
(opts ...Option)
soci/store/store.go:205
↓ 10 callersMethodStderr
Stdout is used as a stderr destination of executing commands.
util/dockershell/shell.go:64
↓ 10 callersMethodString
String returns a human-readable description of this command.
util/dockershell/exec/cmd.go:189
↓ 10 callersMethodUnmount
(ctx context.Context, mountpoint string)
snapshot/snapshot.go:113
↓ 10 callersMethodlogAndIncrementOpCounter
logAndIncrementOpCounter handles logging as well as incrementing the FuseOperationCounter.
fs/layer/node.go:246
↓ 10 callersFunctionsociIndexFromDigest
(sh *shell.Shell, indexDigest string)
integration/util_soci_test.go:278
↓ 9 callersMethodBuildZtoc
BuildZtoc builds a `Ztoc` given the filename of a layer blob. By default it assumes the layer is compressed using `gzip`, unless specified via `WithCo
ztoc/ztoc_builder.go:76
↓ 9 callersMethodClose
Close releases any resources held by the interface implementation.
ztoc/compression/zinfo.go:43
↓ 9 callersFunctionDecodeIndex
DecodeIndex deserializes a JSON blob in an io.Reader into a SOCI index. The blob is an OCI 1.0 Manifest
soci/soci_index.go:198
↓ 9 callersFunctionIsErrAlreadyExists
IsErrAlreadyExists is a store-type-agnostic way to check if the content exists in the store.
soci/store/store.go:88
↓ 9 callersMethodIsInvalid
IsInvalid returns true when this Shell is marked as "invalid". For continuing further command execution, call Refresh for aquiering a new instance of
util/dockershell/shell.go:144
↓ 9 callersMethodMetadata
()
fs/reader/reader.go:62
↓ 9 callersFunctionNewIndex
NewIndex returns a new index.
soci/soci_index.go:949
↓ 9 callersFunctionNewIndexBuilder
NewIndexBuilder returns an `IndexBuilder` that is used to create soci indices.
soci/soci_index.go:451
↓ 9 callersFunctionNewMemoryCache
()
cache/cache.go:386
↓ 9 callersFunctionNewRemoteSnapshotMonitor
NewRemoteSnapshotMonitor creates a new instance of RemoteSnapshotMonitor
util/testutil/shell.go:202
↓ 9 callersFunctionUnmarshal
Unmarshal takes the reader with flatbuffers byte stream and deserializes it ztoc. In case if there's any error situation during deserialization from f
ztoc/ztoc_marshaler.go:56
↓ 9 callersMethodValue
()
ztoc/fbs/ztoc/Xattr.go:44
↓ 9 callersMethodWalk
Walk applys a function to all ArtifactEntries in the ArtifactsDB
soci/artifacts.go:169
next →1–100 of 1,722, ranked by callers