New creates a new Processor.

ErrConcurrentReplication is returned from Processor.ReplicateBlob() when the same blob is already being replicated by another worker.

InboundManifestCacheHitCounter is a prometheus.CounterVec.

InboundManifestCacheMissCounter is a prometheus.CounterVec.

AuditAccount is an audittools.Target.

AuditQuotas is an audittools.Target.

BytesWithDigest is a bytestring that already had its digest computed earlier.

ImpossibleQuotaError is emitted when SetQuotas() fails because the requested quota is impossible.

IncomingManifest contains information about a manifest uploaded by the user (or downloaded from a peer registry in the case of replication).

Processor is a higher-level interface wrapping keppel.DB and keppel.StorageDriver.

QuotaRequest is the request body payload for PUT /keppel/v1/quotas/:auth_tenant_id.

QuotaResponse is the response body payload for GET or PUT /keppel/v1/quotas/:auth_tenant_id.

SingleQuotaRequest appears in type QuotaRequest.

SingleQuotaResponse appears in type QuotaRequest.

UpstreamManifestMissingError is returned from ReplicateManifest when a manifest is legitimately nonexistent on upstream (i.e.