MCPcopy Create free account
hub / github.com/containerd/containerd / streamProcessors

Function streamProcessors

cmd/containerd/command/config.go:145–173  ·  view source on GitHub ↗
()

Source from the content-addressed store, hash-verified

143}
144
145func streamProcessors() map[string]srvconfig.StreamProcessor {
146 const (
147 ctdDecoder = "ctd-decoder"
148 basename = "io.containerd.ocicrypt.decoder.v1"
149 )
150 decryptionKeysPath := filepath.Join(defaults.DefaultConfigDir, "ocicrypt", "keys")
151 ctdDecoderArgs := []string{
152 "--decryption-keys-path", decryptionKeysPath,
153 }
154 ctdDecoderEnv := []string{
155 "OCICRYPT_KEYPROVIDER_CONFIG=" + filepath.Join(defaults.DefaultConfigDir, "ocicrypt", "ocicrypt_keyprovider.conf"),
156 }
157 return map[string]srvconfig.StreamProcessor{
158 basename + ".tar.gzip": {
159 Accepts: []string{images.MediaTypeImageLayerGzipEncrypted},
160 Returns: ocispec.MediaTypeImageLayerGzip,
161 Path: ctdDecoder,
162 Args: ctdDecoderArgs,
163 Env: ctdDecoderEnv,
164 },
165 basename + ".tar": {
166 Accepts: []string{images.MediaTypeImageLayerEncrypted},
167 Returns: ocispec.MediaTypeImageLayer,
168 Path: ctdDecoder,
169 Args: ctdDecoderArgs,
170 Env: ctdDecoderEnv,
171 },
172 }
173}

Callers 1

Calls

no outgoing calls

Tested by

no test coverage detected

Used in the wild real call sites across dependent graphs

searching dependent graphs…