Code
Hub
Workspaces
Following
Trending
Connect
MCP
copy
Create free account
hub
/
github.com/awslabs/amazon-ecr-containerd-resolver
/ functions
Functions
136 in github.com/awslabs/amazon-ecr-containerd-resolver
⨍
Functions
136
◇
Types & classes
24
↓ 16 callers
Method
Close
()
ecr/layer_writer.go:149
↓ 16 callers
Method
Digest
()
ecr/layer_writer.go:153
↓ 10 callers
Method
Fetch
(ctx context.Context, desc ocispec.Descriptor)
ecr/fetcher.go:52
↓ 8 callers
Method
Push
(ctx context.Context, desc ocispec.Descriptor)
ecr/pusher.go:50
↓ 8 callers
Method
Registry
Registry returns the Amazon ECR registry
ecr/ref.go:146
↓ 7 callers
Function
ChunkedProcessor
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 callers
Function
NewResolver
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 callers
Method
Canonical
Canonical returns the canonical representation for the reference
ecr/ref.go:179
↓ 4 callers
Function
ParseRef
ParseRef parses an ECR reference into its constituent parts
ecr/ref.go:62
↓ 4 callers
Method
Spec
Spec returns a reference.Spec
ecr/ref.go:189
↓ 4 callers
Method
TagDigest
TagDigest returns the tag and/or digest specified by the reference
ecr/ref.go:210
↓ 4 callers
Method
Write
(b []byte)
ecr/manifest_writer.go:45
↓ 3 callers
Method
Content
()
ecr/internal/testdata/media_type.go:10
↓ 3 callers
Method
ImageID
ImageID returns an ecr.ImageIdentifier suitable for using in calls to ECR
ecr/ref.go:197
↓ 3 callers
Method
MediaType
()
ecr/internal/testdata/media_type.go:9
↓ 3 callers
Method
Region
Region returns the AWS region
ecr/ref.go:141
↓ 3 callers
Method
Resolve
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 callers
Function
WithMediaTypeRemoved
(src MediaTypeSample)
ecr/internal/testdata/media_type.go:35
↓ 3 callers
Method
getClient
(region string)
ecr/resolver.go:235
↓ 2 callers
Method
ARN
ARN returns the canonical representation of the ECR ARN
ecr/ref.go:184
↓ 2 callers
Method
BatchGetImage
(context.Context, *ecr.BatchGetImageInput, ...func(*ecr.Options))
ecr/base.go:54
↓ 2 callers
Method
Commit
(ctx context.Context, size int64, expected digest.Digest, opts ...content.Opt)
ecr/manifest_writer.go:58
↓ 2 callers
Method
Commit
(ctx context.Context, size int64, expected digest.Digest, opts ...content.Opt)
ecr/layer_writer.go:157
↓ 2 callers
Method
Fetcher
(ctx context.Context, ref string)
ecr/resolver.go:299
↓ 2 callers
Function
ParseImageURI
ParseImageURI takes an ECR image URI and then constructs and returns an ECRSpec struct
ecr/ref.go:71
↓ 2 callers
Method
Pusher
(ctx context.Context, ref string)
ecr/resolver.go:315
↓ 2 callers
Function
RedactHTTPQueryValuesFromURL
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 callers
Method
fetchLayerURL
(ctx context.Context, desc ocispec.Descriptor, downloadURL string)
ecr/fetcher.go:150
↓ 2 callers
Method
getImageByDescriptor
getImageByDescriptor retrieves an image from ECR for a given OCI descriptor.
ecr/base.go:72
↓ 2 callers
Method
markStatusExists
(ctx context.Context, desc ocispec.Descriptor)
ecr/pusher.go:153
↓ 2 callers
Method
markStatusStarted
(ctx context.Context, desc ocispec.Descriptor)
ecr/pusher.go:164
↓ 2 callers
Function
newLayerWriter
(base *ecrBase, tracker docker.StatusTracker, ref string, desc ocispec.Descriptor)
ecr/layer_writer.go:53
↓ 2 callers
Function
parseEnvInt
(ctx context.Context, varname string, val *int)
example/ecr-pull/main.go:117
↓ 2 callers
Function
parseImageManifestMediaType
(ctx context.Context, body string)
ecr/resolver.go:260
↓ 2 callers
Method
runGetImage
runGetImage submits and handles the response for requests of ECR images.
ecr/base.go:115
↓ 1 callers
Method
BatchCheckLayerAvailability
(context.Context, *ecr.BatchCheckLayerAvailabilityInput, ...func(*ecr.Options))
ecr/base.go:56
↓ 1 callers
Method
CompleteLayerUpload
(context.Context, *ecr.CompleteLayerUploadInput, ...func(*ecr.Options))
ecr/base.go:59
↓ 1 callers
Method
Digest
()
ecr/manifest_writer.go:54
↓ 1 callers
Function
Display
Display pretty prints out the download or upload progress
example/ecr-pull/progress.go:217
↓ 1 callers
Method
GetDownloadUrlForLayer
(context.Context, *ecr.GetDownloadUrlForLayerInput, ...func(*ecr.Options))
ecr/base.go:55
↓ 1 callers
Function
GetPartition
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 callers
Method
InitiateLayerUpload
(context.Context, *ecr.InitiateLayerUploadInput, ...func(*ecr.Options))
ecr/base.go:57
↓ 1 callers
Method
PutImage
(context.Context, *ecr.PutImageInput, ...func(*ecr.Options))
ecr/base.go:60
↓ 1 callers
Function
RedactDescriptor
RedactDescriptor returns a copy of the provided image descriptor with its URLs redacted.
ecr/internal/util/oci/redact.go:25
↓ 1 callers
Function
RedactHTTPQueryValuesFromURLError
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 callers
Method
UploadLayerPart
(context.Context, *ecr.UploadLayerPartInput, ...func(*ecr.Options))
ecr/base.go:58
↓ 1 callers
Function
WithLayerDownloadParallelism
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 callers
Function
WithTracker
WithTracker is a ResolverOption to use a specific docker.Tracker
ecr/resolver.go:83
↓ 1 callers
Method
Write
(b []byte)
ecr/layer_writer.go:137
↓ 1 callers
Method
add
(ref string)
example/ecr-push/progress.go:50
↓ 1 callers
Method
add
(desc ocispec.Descriptor)
example/ecr-pull/progress.go:180
↓ 1 callers
Method
checkBlobExistence
(ctx context.Context, desc ocispec.Descriptor)
ecr/pusher.go:126
↓ 1 callers
Method
checkManifestExistence
(ctx context.Context, desc ocispec.Descriptor)
ecr/pusher.go:92
↓ 1 callers
Function
display
Display pretty prints out the download or upload progress
example/ecr-push/progress.go:106
↓ 1 callers
Function
displayUploadProgress
(ctx context.Context, ongoing *pushjobs, errs chan error)
example/ecr-push/main.go:111
↓ 1 callers
Method
doRequest
(ctx context.Context, req *http.Request)
ecr/fetcher.go:177
↓ 1 callers
Method
fetchForeignLayer
(ctx context.Context, desc ocispec.Descriptor)
ecr/fetcher.go:131
↓ 1 callers
Method
fetchLayer
(ctx context.Context, desc ocispec.Descriptor)
ecr/fetcher.go:111
↓ 1 callers
Method
fetchLayerHtcat
(ctx context.Context, desc ocispec.Descriptor, downloadURL string)
ecr/fetcher.go:186
↓ 1 callers
Method
fetchManifest
(ctx context.Context, desc ocispec.Descriptor)
ecr/fetcher.go:86
↓ 1 callers
Method
getImage
getImage fetches the reference's image from ECR.
ecr/base.go:64
↓ 1 callers
Function
getPartition
(partitions []Partition, region string)
ecr/internal/awsrulesfn/partition.go:34
↓ 1 callers
Method
isResolved
()
example/ecr-pull/progress.go:200
↓ 1 callers
Method
jobs
()
example/ecr-pull/progress.go:192
↓ 1 callers
Function
mergeOverrides
(into PartitionConfig, from RegionOverrides)
ecr/internal/awsrulesfn/partition.go:60
↓ 1 callers
Function
newJobs
(name string)
example/ecr-pull/progress.go:173
↓ 1 callers
Function
newPushJobs
(tracker docker.StatusTracker)
example/ecr-push/progress.go:43
↓ 1 callers
Function
parseARN
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 callers
Function
parseEnvInt
(ctx context.Context, varname string, val *int)
example/ecr-push/main.go:145
↓ 1 callers
Function
parseEnvInt
(ctx context.Context, varname string, val *int)
example/ecr-copy/main.go:87
↓ 1 callers
Method
processChunks
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 callers
Method
pushBlob
(ctx context.Context, desc ocispec.Descriptor)
ecr/pusher.go:108
↓ 1 callers
Method
pushManifest
(ctx context.Context, desc ocispec.Descriptor)
ecr/pusher.go:67
↓ 1 callers
Method
readChunk
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 callers
Method
readIntoChunks
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 callers
Function
showProgress
(ctx context.Context, ongoing *jobs, cs content.Store, out io.Writer)
example/ecr-pull/progress.go:42
↓ 1 callers
Method
status
()
example/ecr-push/progress.go:61
Method
BatchCheckLayerAvailability
(ctx context.Context, arg *ecr.BatchCheckLayerAvailabilityInput, opts ...func(*ecr.Options))
ecr/fake_ecr_client_test.go:47
Method
BatchGetImage
(ctx context.Context, arg *ecr.BatchGetImageInput, opts ...func(*ecr.Options))
ecr/fake_ecr_client_test.go:39
Method
Close
()
ecr/manifest_writer.go:50
Method
CompleteLayerUpload
(ctx context.Context, arg *ecr.CompleteLayerUploadInput, opts ...func(*ecr.Options))
ecr/fake_ecr_client_test.go:59
Method
Content
Content provides the sample's JSON data as a string.
ecr/internal/testdata/media_type.go:25
Function
ExampleNewResolver_pull
()
ecr/doc_test.go:27
Function
ExampleNewResolver_push
()
ecr/doc_test.go:39
Method
GetDownloadUrlForLayer
(ctx context.Context, arg *ecr.GetDownloadUrlForLayerInput, opts ...func(*ecr.Options))
ecr/fake_ecr_client_test.go:43
Method
InitiateLayerUpload
(ctx context.Context, arg *ecr.InitiateLayerUploadInput, opts ...func(*ecr.Options))
ecr/fake_ecr_client_test.go:51
Method
MediaType
MediaType is the defined sample's actual mediaType.
ecr/internal/testdata/media_type.go:20
Method
Partition
Partition returns the AWS partition
ecr/ref.go:136
Method
PutImage
(ctx context.Context, arg *ecr.PutImageInput, opts ...func(*ecr.Options))
ecr/fake_ecr_client_test.go:63
Method
Status
()
ecr/manifest_writer.go:114
Method
Status
()
ecr/layer_writer.go:204
Function
TestChunkedProcessorBlockingFail
(t *testing.T)
ecr/stream/chunked_processor_test.go:52
Function
TestChunkedProcessorBlockingSuccess
(t *testing.T)
ecr/stream/chunked_processor_test.go:63
Function
TestChunkedProcessorChunkingSuccess
(t *testing.T)
ecr/stream/chunked_processor_test.go:77
Function
TestChunkedProcessorEmptySuccess
(t *testing.T)
ecr/stream/chunked_processor_test.go:89
Function
TestChunkedProcessorFail
(t *testing.T)
ecr/stream/chunked_processor_test.go:41
Function
TestChunkedProcessorSuccess
(t *testing.T)
ecr/stream/chunked_processor_test.go:29
Function
TestFetchForeignLayer
(t *testing.T)
ecr/fetcher_test.go:52
Function
TestFetchForeignLayerNotFound
(t *testing.T)
ecr/fetcher_test.go:97
Function
TestFetchLayer
(t *testing.T)
ecr/fetcher_test.go:244
next →
1–100 of 136, ranked by callers