|
|
@ -258,12 +258,12 @@ func (s *storageRESTServer) WalkDirHandler(w http.ResponseWriter, r *http.Reques |
|
|
|
vars := mux.Vars(r) |
|
|
|
vars := mux.Vars(r) |
|
|
|
volume := vars[storageRESTVolume] |
|
|
|
volume := vars[storageRESTVolume] |
|
|
|
dirPath := vars[storageRESTDirPath] |
|
|
|
dirPath := vars[storageRESTDirPath] |
|
|
|
prefix := vars[storageRESTPrefixFilter] |
|
|
|
|
|
|
|
recursive, err := strconv.ParseBool(vars[storageRESTRecursive]) |
|
|
|
recursive, err := strconv.ParseBool(vars[storageRESTRecursive]) |
|
|
|
if err != nil { |
|
|
|
if err != nil { |
|
|
|
s.writeErrorResponse(w, err) |
|
|
|
s.writeErrorResponse(w, err) |
|
|
|
return |
|
|
|
return |
|
|
|
} |
|
|
|
} |
|
|
|
|
|
|
|
prefix := r.URL.Query().Get(storageRESTPrefixFilter) |
|
|
|
writer := streamHTTPResponse(w) |
|
|
|
writer := streamHTTPResponse(w) |
|
|
|
writer.CloseWithError(s.storage.WalkDir(r.Context(), WalkDirOptions{ |
|
|
|
writer.CloseWithError(s.storage.WalkDir(r.Context(), WalkDirOptions{ |
|
|
|
Bucket: volume, |
|
|
|
Bucket: volume, |
|
|
|