MCPcopy Create free account

hub / github.com/awslabs/amazon-ecr-containerd-resolver / functions

Functions136 in github.com/awslabs/amazon-ecr-containerd-resolver

↓ 16 callersMethodClose
()
ecr/layer_writer.go:149
↓ 16 callersMethodDigest
()
ecr/layer_writer.go:153
↓ 10 callersMethodFetch
(ctx context.Context, desc ocispec.Descriptor)
ecr/fetcher.go:52
↓ 8 callersMethodPush
(ctx context.Context, desc ocispec.Descriptor)
ecr/pusher.go:50
↓ 8 callersMethodRegistry
Registry returns the Amazon ECR registry
ecr/ref.go:146
↓ 7 callersFunctionChunkedProcessor
ChunkedProcessor breaks an io.Reader into smaller parts (Chunks) and invokes callbacks on those chunks. ChunkedProcessor asynchronously reads a io.Re
ecr/stream/chunked_processor.go:69
↓ 5 callersFunctionNewResolver
NewResolver creates a new remotes.Resolver capable of interacting with Amazon ECR. NewResolver can be called with no arguments for default configurat
ecr/resolver.go:115
↓ 4 callersMethodCanonical
Canonical returns the canonical representation for the reference
ecr/ref.go:179
↓ 4 callersFunctionParseRef
ParseRef parses an ECR reference into its constituent parts
ecr/ref.go:62
↓ 4 callersMethodSpec
Spec returns a reference.Spec
ecr/ref.go:189
↓ 4 callersMethodTagDigest
TagDigest returns the tag and/or digest specified by the reference
ecr/ref.go:210
↓ 4 callersMethodWrite
(b []byte)
ecr/manifest_writer.go:45
↓ 3 callersMethodContent
()
ecr/internal/testdata/media_type.go:10
↓ 3 callersMethodImageID
ImageID returns an ecr.ImageIdentifier suitable for using in calls to ECR
ecr/ref.go:197
↓ 3 callersMethodMediaType
()
ecr/internal/testdata/media_type.go:9
↓ 3 callersMethodRegion
Region returns the AWS region
ecr/ref.go:141
↓ 3 callersMethodResolve
Resolve attempts to resolve the provided reference into a name and a descriptor. Valid references are of the form "ecr.aws/arn:aws:ecr:<region>:<acco
ecr/resolver.go:154
↓ 3 callersFunctionWithMediaTypeRemoved
(src MediaTypeSample)
ecr/internal/testdata/media_type.go:35
↓ 3 callersMethodgetClient
(region string)
ecr/resolver.go:235
↓ 2 callersMethodARN
ARN returns the canonical representation of the ECR ARN
ecr/ref.go:184
↓ 2 callersMethodBatchGetImage
(context.Context, *ecr.BatchGetImageInput, ...func(*ecr.Options))
ecr/base.go:54
↓ 2 callersMethodCommit
(ctx context.Context, size int64, expected digest.Digest, opts ...content.Opt)
ecr/manifest_writer.go:58
↓ 2 callersMethodCommit
(ctx context.Context, size int64, expected digest.Digest, opts ...content.Opt)
ecr/layer_writer.go:157
↓ 2 callersMethodFetcher
(ctx context.Context, ref string)
ecr/resolver.go:299
↓ 2 callersFunctionParseImageURI
ParseImageURI takes an ECR image URI and then constructs and returns an ECRSpec struct
ecr/ref.go:71
↓ 2 callersMethodPusher
(ctx context.Context, ref string)
ecr/resolver.go:315
↓ 2 callersFunctionRedactHTTPQueryValuesFromURL
RedactHTTPQueryValuesFromURL is a log utility to parse a raw URL as a URL and redact HTTP query values to prevent leaking sensitive information like e
ecr/internal/util/http/redact.go:40
↓ 2 callersMethodfetchLayerURL
(ctx context.Context, desc ocispec.Descriptor, downloadURL string)
ecr/fetcher.go:150
↓ 2 callersMethodgetImageByDescriptor
getImageByDescriptor retrieves an image from ECR for a given OCI descriptor.
ecr/base.go:72
↓ 2 callersMethodmarkStatusExists
(ctx context.Context, desc ocispec.Descriptor)
ecr/pusher.go:153
↓ 2 callersMethodmarkStatusStarted
(ctx context.Context, desc ocispec.Descriptor)
ecr/pusher.go:164
↓ 2 callersFunctionnewLayerWriter
(base *ecrBase, tracker docker.StatusTracker, ref string, desc ocispec.Descriptor)
ecr/layer_writer.go:53
↓ 2 callersFunctionparseEnvInt
(ctx context.Context, varname string, val *int)
example/ecr-pull/main.go:117
↓ 2 callersFunctionparseImageManifestMediaType
(ctx context.Context, body string)
ecr/resolver.go:260
↓ 2 callersMethodrunGetImage
runGetImage submits and handles the response for requests of ECR images.
ecr/base.go:115
↓ 1 callersMethodBatchCheckLayerAvailability
(context.Context, *ecr.BatchCheckLayerAvailabilityInput, ...func(*ecr.Options))
ecr/base.go:56
↓ 1 callersMethodCompleteLayerUpload
(context.Context, *ecr.CompleteLayerUploadInput, ...func(*ecr.Options))
ecr/base.go:59
↓ 1 callersMethodDigest
()
ecr/manifest_writer.go:54
↓ 1 callersFunctionDisplay
Display pretty prints out the download or upload progress
example/ecr-pull/progress.go:217
↓ 1 callersMethodGetDownloadUrlForLayer
(context.Context, *ecr.GetDownloadUrlForLayerInput, ...func(*ecr.Options))
ecr/base.go:55
↓ 1 callersFunctionGetPartition
GetPartition returns an AWS [Partition] for the region provided. If the partition cannot be determined nil will be returned.
ecr/internal/awsrulesfn/partitions.go:8
↓ 1 callersMethodInitiateLayerUpload
(context.Context, *ecr.InitiateLayerUploadInput, ...func(*ecr.Options))
ecr/base.go:57
↓ 1 callersMethodPutImage
(context.Context, *ecr.PutImageInput, ...func(*ecr.Options))
ecr/base.go:60
↓ 1 callersFunctionRedactDescriptor
RedactDescriptor returns a copy of the provided image descriptor with its URLs redacted.
ecr/internal/util/oci/redact.go:25
↓ 1 callersFunctionRedactHTTPQueryValuesFromURLError
RedactHTTPQueryValuesFromURLError is a log utility to parse an error as a URL error and redact HTTP query values to prevent leaking sensitive informat
ecr/internal/util/http/redact.go:26
↓ 1 callersMethodUploadLayerPart
(context.Context, *ecr.UploadLayerPartInput, ...func(*ecr.Options))
ecr/base.go:58
↓ 1 callersFunctionWithLayerDownloadParallelism
WithLayerDownloadParallelism is a ResolverOption to configure whether layer parts should be downloaded in parallel. Layer parallelism is backed by th
ecr/resolver.go:95
↓ 1 callersFunctionWithTracker
WithTracker is a ResolverOption to use a specific docker.Tracker
ecr/resolver.go:83
↓ 1 callersMethodWrite
(b []byte)
ecr/layer_writer.go:137
↓ 1 callersMethodadd
(ref string)
example/ecr-push/progress.go:50
↓ 1 callersMethodadd
(desc ocispec.Descriptor)
example/ecr-pull/progress.go:180
↓ 1 callersMethodcheckBlobExistence
(ctx context.Context, desc ocispec.Descriptor)
ecr/pusher.go:126
↓ 1 callersMethodcheckManifestExistence
(ctx context.Context, desc ocispec.Descriptor)
ecr/pusher.go:92
↓ 1 callersFunctiondisplay
Display pretty prints out the download or upload progress
example/ecr-push/progress.go:106
↓ 1 callersFunctiondisplayUploadProgress
(ctx context.Context, ongoing *pushjobs, errs chan error)
example/ecr-push/main.go:111
↓ 1 callersMethoddoRequest
(ctx context.Context, req *http.Request)
ecr/fetcher.go:177
↓ 1 callersMethodfetchForeignLayer
(ctx context.Context, desc ocispec.Descriptor)
ecr/fetcher.go:131
↓ 1 callersMethodfetchLayer
(ctx context.Context, desc ocispec.Descriptor)
ecr/fetcher.go:111
↓ 1 callersMethodfetchLayerHtcat
(ctx context.Context, desc ocispec.Descriptor, downloadURL string)
ecr/fetcher.go:186
↓ 1 callersMethodfetchManifest
(ctx context.Context, desc ocispec.Descriptor)
ecr/fetcher.go:86
↓ 1 callersMethodgetImage
getImage fetches the reference's image from ECR.
ecr/base.go:64
↓ 1 callersFunctiongetPartition
(partitions []Partition, region string)
ecr/internal/awsrulesfn/partition.go:34
↓ 1 callersMethodisResolved
()
example/ecr-pull/progress.go:200
↓ 1 callersMethodjobs
()
example/ecr-pull/progress.go:192
↓ 1 callersFunctionmergeOverrides
(into PartitionConfig, from RegionOverrides)
ecr/internal/awsrulesfn/partition.go:60
↓ 1 callersFunctionnewJobs
(name string)
example/ecr-pull/progress.go:173
↓ 1 callersFunctionnewPushJobs
(tracker docker.StatusTracker)
example/ecr-push/progress.go:43
↓ 1 callersFunctionparseARN
parseARN parses an ECR ARN into its constituent parts. An example ARN is: arn:aws:ecr:us-west-2:123456789012:repository/foo/bar
ecr/ref.go:153
↓ 1 callersFunctionparseEnvInt
(ctx context.Context, varname string, val *int)
example/ecr-push/main.go:145
↓ 1 callersFunctionparseEnvInt
(ctx context.Context, varname string, val *int)
example/ecr-copy/main.go:87
↓ 1 callersMethodprocessChunks
processChunks selects between the read & error channels provided in the context and invokes the readCallback with the results on success. If an error
ecr/stream/chunked_processor.go:135
↓ 1 callersMethodpushBlob
(ctx context.Context, desc ocispec.Descriptor)
ecr/pusher.go:108
↓ 1 callersMethodpushManifest
(ctx context.Context, desc ocispec.Descriptor)
ecr/pusher.go:67
↓ 1 callersMethodreadChunk
readChunk reads and returns a new Chunk to the caller. Given the current part and bytesBegin, populates the new Chunk with the proper offsets. Will re
ecr/stream/chunked_processor.go:165
↓ 1 callersMethodreadIntoChunks
readIntoChunks begins event loop for reading Chunks. On return, either the complete buffer is read (or there is an error reading from the buffer) and
ecr/stream/chunked_processor.go:101
↓ 1 callersFunctionshowProgress
(ctx context.Context, ongoing *jobs, cs content.Store, out io.Writer)
example/ecr-pull/progress.go:42
↓ 1 callersMethodstatus
()
example/ecr-push/progress.go:61
MethodBatchCheckLayerAvailability
(ctx context.Context, arg *ecr.BatchCheckLayerAvailabilityInput, opts ...func(*ecr.Options))
ecr/fake_ecr_client_test.go:47
MethodBatchGetImage
(ctx context.Context, arg *ecr.BatchGetImageInput, opts ...func(*ecr.Options))
ecr/fake_ecr_client_test.go:39
MethodClose
()
ecr/manifest_writer.go:50
MethodCompleteLayerUpload
(ctx context.Context, arg *ecr.CompleteLayerUploadInput, opts ...func(*ecr.Options))
ecr/fake_ecr_client_test.go:59
MethodContent
Content provides the sample's JSON data as a string.
ecr/internal/testdata/media_type.go:25
FunctionExampleNewResolver_pull
()
ecr/doc_test.go:27
FunctionExampleNewResolver_push
()
ecr/doc_test.go:39
MethodGetDownloadUrlForLayer
(ctx context.Context, arg *ecr.GetDownloadUrlForLayerInput, opts ...func(*ecr.Options))
ecr/fake_ecr_client_test.go:43
MethodInitiateLayerUpload
(ctx context.Context, arg *ecr.InitiateLayerUploadInput, opts ...func(*ecr.Options))
ecr/fake_ecr_client_test.go:51
MethodMediaType
MediaType is the defined sample's actual mediaType.
ecr/internal/testdata/media_type.go:20
MethodPartition
Partition returns the AWS partition
ecr/ref.go:136
MethodPutImage
(ctx context.Context, arg *ecr.PutImageInput, opts ...func(*ecr.Options))
ecr/fake_ecr_client_test.go:63
MethodStatus
()
ecr/manifest_writer.go:114
MethodStatus
()
ecr/layer_writer.go:204
FunctionTestChunkedProcessorBlockingFail
(t *testing.T)
ecr/stream/chunked_processor_test.go:52
FunctionTestChunkedProcessorBlockingSuccess
(t *testing.T)
ecr/stream/chunked_processor_test.go:63
FunctionTestChunkedProcessorChunkingSuccess
(t *testing.T)
ecr/stream/chunked_processor_test.go:77
FunctionTestChunkedProcessorEmptySuccess
(t *testing.T)
ecr/stream/chunked_processor_test.go:89
FunctionTestChunkedProcessorFail
(t *testing.T)
ecr/stream/chunked_processor_test.go:41
FunctionTestChunkedProcessorSuccess
(t *testing.T)
ecr/stream/chunked_processor_test.go:29
FunctionTestFetchForeignLayer
(t *testing.T)
ecr/fetcher_test.go:52
FunctionTestFetchForeignLayerNotFound
(t *testing.T)
ecr/fetcher_test.go:97
FunctionTestFetchLayer
(t *testing.T)
ecr/fetcher_test.go:244
next →1–100 of 136, ranked by callers