summaryrefslogtreecommitdiff
path: root/vendor/codeberg.org/gruf/go-storage/s3/errors.go
diff options
context:
space:
mode:
authorLibravatar kim <89579420+NyaaaWhatsUpDoc@users.noreply.github.com>2024-05-22 09:46:24 +0000
committerLibravatar GitHub <noreply@github.com>2024-05-22 11:46:24 +0200
commit3d3e99ae52ff8895b840cbced2e55b5f849fd4be (patch)
treec646d5eb99368028a2fbdafbe2c4400059d8eed5 /vendor/codeberg.org/gruf/go-storage/s3/errors.go
parent--- (#2923) (diff)
downloadgotosocial-3d3e99ae52ff8895b840cbced2e55b5f849fd4be.tar.xz
[performance] update storage backend and make use of seek syscall when available (#2924)
* update to use go-storage/ instead of go-store/v2/storage/ * pull in latest version from codeberg * remove test output :innocent: * add code comments * set the exclusive bit when creating new files in disk config * bump to actual release version * bump to v0.1.1 (tis a simple no-logic change) * update readme * only use a temporary read seeker when decoding video if required (should only be S3 now) * use fastcopy library to use memory pooled buffers when calling TempFileSeeker() * update to use seek call in serveFileRange()
Diffstat (limited to 'vendor/codeberg.org/gruf/go-storage/s3/errors.go')
-rw-r--r--vendor/codeberg.org/gruf/go-storage/s3/errors.go47
1 files changed, 47 insertions, 0 deletions
diff --git a/vendor/codeberg.org/gruf/go-storage/s3/errors.go b/vendor/codeberg.org/gruf/go-storage/s3/errors.go
new file mode 100644
index 000000000..2cbdd2e9d
--- /dev/null
+++ b/vendor/codeberg.org/gruf/go-storage/s3/errors.go
@@ -0,0 +1,47 @@
+package s3
+
+import (
+ "strings"
+
+ "codeberg.org/gruf/go-storage"
+ "codeberg.org/gruf/go-storage/internal"
+ "github.com/minio/minio-go/v7"
+)
+
+// transformS3Error transforms an error returned from S3Storage underlying
+// minio.Core client, by wrapping where necessary with our own error types.
+func transformS3Error(err error) error {
+ // Cast this to a minio error response
+ ersp, ok := err.(minio.ErrorResponse)
+ if ok {
+ switch ersp.Code {
+ case "NoSuchKey":
+ return internal.WrapErr(err, storage.ErrNotFound)
+ case "Conflict":
+ return internal.WrapErr(err, storage.ErrAlreadyExists)
+ default:
+ return err
+ }
+ }
+
+ // Check if error has an invalid object name prefix
+ if strings.HasPrefix(err.Error(), "Object name ") {
+ return internal.WrapErr(err, storage.ErrInvalidKey)
+ }
+
+ return err
+}
+
+func isNotFoundError(err error) bool {
+ errRsp, ok := err.(minio.ErrorResponse)
+ return ok && errRsp.Code == "NoSuchKey"
+}
+
+func isConflictError(err error) bool {
+ errRsp, ok := err.(minio.ErrorResponse)
+ return ok && errRsp.Code == "Conflict"
+}
+
+func isObjectNameError(err error) bool {
+ return strings.HasPrefix(err.Error(), "Object name ")
+}