nixos/nix
1
1
Fork 0
mirror of https://github.com/NixOS/nix.git synced 2025-11-08 19:46:02 +01:00
Code Activity

Merge pull request #14376 from lovesegfault/nix-s3-abort-multipart

Browse source 
feat(libstore/s3-binary-cache-store): implement `abortMultipartUpload()`
This commit is contained in:
John Ericson 2025-10-27 19:52:36 +00:00 • committed by GitHub
commit ea17cc1b57
No known key found for this signature in database
GPG key ID: B5690EEEBB952194
1 changed files with 21 additions and 0 deletions
Download patch file Download diff file Expand all files Collapse all files

21
src/libstore/s3-binary-cache-store.cc
View file

@ -26,6 +26,14 @@ public:
private: private:
ref<S3BinaryCacheStoreConfig> s3Config; ref<S3BinaryCacheStoreConfig> s3Config;
/**
* Abort a multipart upload
*
* @see
* https://docs.aws.amazon.com/AmazonS3/latest/API/API_AbortMultipartUpload.html#API_AbortMultipartUpload_RequestSyntax
*/
void abortMultipartUpload(std::string_view key, std::string_view uploadId);
}; };
void S3BinaryCacheStore::upsertFile( void S3BinaryCacheStore::upsertFile(
@ -37,6 +45,19 @@ void S3BinaryCacheStore::upsertFile(
HttpBinaryCacheStore::upsertFile(path, istream, mimeType, sizeHint); HttpBinaryCacheStore::upsertFile(path, istream, mimeType, sizeHint);
} }
void S3BinaryCacheStore::abortMultipartUpload(std::string_view key, std::string_view uploadId)
{
auto req = makeRequest(key);
req.setupForS3();
auto url = req.uri.parsed();
url.query["uploadId"] = uploadId;
req.uri = VerbatimURL(url);
req.method = HttpMethod::DELETE;
getFileTransfer()->enqueueFileTransfer(req).get();
}
StringSet S3BinaryCacheStoreConfig::uriSchemes() StringSet S3BinaryCacheStoreConfig::uriSchemes()
{ {
return {"s3"}; return {"s3"};