aboutsummaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorChris Lu <chris.lu@gmail.com>2018-09-03 11:38:10 -0700
committerChris Lu <chris.lu@gmail.com>2018-09-03 11:38:10 -0700
commit0b0ece964915691cd3146e1457c471df3fcf6470 (patch)
tree90f63e6273822d166adb249d9133022b2a5733c3
parent0adb2ba6b8c755792ec2357691ac8970eaf7e80c (diff)
downloadseaweedfs-0b0ece964915691cd3146e1457c471df3fcf6470.tar.xz
seaweedfs-0b0ece964915691cd3146e1457c471df3fcf6470.zip
add place holders for multiplarts upload
-rw-r--r--weed/s3api/s3api_object_multipart_handlers.go40
-rw-r--r--weed/s3api/s3api_server.go30
2 files changed, 55 insertions, 15 deletions
diff --git a/weed/s3api/s3api_object_multipart_handlers.go b/weed/s3api/s3api_object_multipart_handlers.go
new file mode 100644
index 000000000..6e2c96ddd
--- /dev/null
+++ b/weed/s3api/s3api_object_multipart_handlers.go
@@ -0,0 +1,40 @@
+package s3api
+
+import (
+ "net/http"
+)
+
+// NewMultipartUploadHandler - New multipart upload.
+func (api *S3ApiServer) NewMultipartUploadHandler(w http.ResponseWriter, r *http.Request) {
+
+}
+
+// CompleteMultipartUploadHandler - Completes multipart upload.
+func (api *S3ApiServer) CompleteMultipartUploadHandler(w http.ResponseWriter, r *http.Request) {
+
+}
+
+// AbortMultipartUploadHandler - Aborts multipart upload.
+func (api *S3ApiServer) AbortMultipartUploadHandler(w http.ResponseWriter, r *http.Request) {
+
+}
+
+// ListMultipartUploadsHandler - Lists multipart uploads.
+func (api *S3ApiServer) ListMultipartUploadsHandler(w http.ResponseWriter, r *http.Request) {
+
+}
+
+// ListObjectPartsHandler - Lists object parts in a multipart upload.
+func (api *S3ApiServer) ListObjectPartsHandler(w http.ResponseWriter, r *http.Request) {
+
+}
+
+// PutObjectPartHandler - Put an object part in a multipart upload.
+func (api *S3ApiServer) PutObjectPartHandler(w http.ResponseWriter, r *http.Request) {
+
+}
+
+// DeleteMultipleObjectsHandler - Delete an object part in a multipart upload.
+func (api *S3ApiServer) DeleteMultipleObjectsHandler(w http.ResponseWriter, r *http.Request) {
+
+}
diff --git a/weed/s3api/s3api_server.go b/weed/s3api/s3api_server.go
index 0b3826625..2cc063098 100644
--- a/weed/s3api/s3api_server.go
+++ b/weed/s3api/s3api_server.go
@@ -53,6 +53,21 @@ func (s3a *S3ApiServer) registerRouter(router *mux.Router) {
// HeadBucket
bucket.Methods("HEAD").HandlerFunc(s3a.HeadBucketHandler)
+ // PutObjectPart
+ bucket.Methods("PUT").Path("/{object:.+}").HandlerFunc(s3a.PutObjectPartHandler).Queries("partNumber", "{partNumber:[0-9]+}", "uploadId", "{uploadId:.*}")
+ // CompleteMultipartUpload
+ bucket.Methods("POST").Path("/{object:.+}").HandlerFunc(s3a.CompleteMultipartUploadHandler).Queries("uploadId", "{uploadId:.*}")
+ // NewMultipartUpload
+ bucket.Methods("POST").Path("/{object:.+}").HandlerFunc(s3a.NewMultipartUploadHandler).Queries("uploads", "")
+ // DeleteMultipleObjects
+ bucket.Methods("POST").HandlerFunc(s3a.DeleteMultipleObjectsHandler).Queries("delete", "")
+ // AbortMultipartUpload
+ bucket.Methods("DELETE").Path("/{object:.+}").HandlerFunc(s3a.AbortMultipartUploadHandler).Queries("uploadId", "{uploadId:.*}")
+ // ListObjectParts
+ bucket.Methods("GET").Path("/{object:.+}").HandlerFunc(s3a.ListObjectPartsHandler).Queries("uploadId", "{uploadId:.*}")
+ // ListMultipartUploads
+ bucket.Methods("GET").HandlerFunc(s3a.ListMultipartUploadsHandler).Queries("uploads", "")
+
// DeleteObject
bucket.Methods("DELETE").Path("/{object:.+}").HandlerFunc(s3a.DeleteObjectHandler)
// DeleteBucket
@@ -71,21 +86,6 @@ func (s3a *S3ApiServer) registerRouter(router *mux.Router) {
// CopyObjectPart
bucket.Methods("PUT").Path("/{object:.+}").HeadersRegexp("X-Amz-Copy-Source", ".*?(\\/|%2F).*?").HandlerFunc(s3a.CopyObjectPartHandler).Queries("partNumber", "{partNumber:[0-9]+}", "uploadId", "{uploadId:.*}")
- // PutObjectPart
- bucket.Methods("PUT").Path("/{object:.+}").HandlerFunc(s3a.PutObjectPartHandler).Queries("partNumber", "{partNumber:[0-9]+}", "uploadId", "{uploadId:.*}")
- // ListObjectParts
- bucket.Methods("GET").Path("/{object:.+}").HandlerFunc(s3a.ListObjectPartsHandler).Queries("uploadId", "{uploadId:.*}")
- // CompleteMultipartUpload
- bucket.Methods("POST").Path("/{object:.+}").HandlerFunc(s3a.CompleteMultipartUploadHandler).Queries("uploadId", "{uploadId:.*}")
- // NewMultipartUpload
- bucket.Methods("POST").Path("/{object:.+}").HandlerFunc(s3a.NewMultipartUploadHandler).Queries("uploads", "")
- // AbortMultipartUpload
- bucket.Methods("DELETE").Path("/{object:.+}").HandlerFunc(s3a.AbortMultipartUploadHandler).Queries("uploadId", "{uploadId:.*}")
-
- // ListMultipartUploads
- bucket.Methods("GET").HandlerFunc(s3a.ListMultipartUploadsHandler).Queries("uploads", "")
- // DeleteMultipleObjects
- bucket.Methods("POST").HandlerFunc(s3a.DeleteMultipleObjectsHandler).Queries("delete", "")
// not implemented
// GetBucketLocation