aboutsummaryrefslogtreecommitdiff
path: root/go/filer/operations.go
diff options
context:
space:
mode:
Diffstat (limited to 'go/filer/operations.go')
-rw-r--r--go/filer/operations.go58
1 files changed, 58 insertions, 0 deletions
diff --git a/go/filer/operations.go b/go/filer/operations.go
new file mode 100644
index 000000000..7e89b534d
--- /dev/null
+++ b/go/filer/operations.go
@@ -0,0 +1,58 @@
+package filer
+
+import ()
+
+import (
+ "code.google.com/p/weed-fs/go/util"
+ "encoding/json"
+ "errors"
+ _ "fmt"
+ "net/url"
+ "strconv"
+)
+
+type ListFilesResult struct {
+ Files []FileEntry
+ Error string `json:"error,omitempty"`
+}
+
+func ListFiles(server string, directoryId DirectoryId, fileName string) (*ListFilesResult, error) {
+ values := make(url.Values)
+ values.Add("directoryId", strconv.Itoa(int(directoryId)))
+ jsonBlob, err := util.Post("http://"+server+"/dir/lookup", values)
+ if err != nil {
+ return nil, err
+ }
+ var ret ListFilesResult
+ err = json.Unmarshal(jsonBlob, &ret)
+ if err != nil {
+ return nil, err
+ }
+ if ret.Error != "" {
+ return nil, errors.New(ret.Error)
+ }
+ return &ret, nil
+}
+
+type ListDirectoriesResult struct {
+ Directories []DirectoryEntry
+ Error string `json:"error,omitempty"`
+}
+
+func ListDirectories(server string, directoryId DirectoryId) (*ListDirectoriesResult, error) {
+ values := make(url.Values)
+ values.Add("directoryId", strconv.Itoa(int(directoryId)))
+ jsonBlob, err := util.Post("http://"+server+"/dir/lookup", values)
+ if err != nil {
+ return nil, err
+ }
+ var ret ListDirectoriesResult
+ err = json.Unmarshal(jsonBlob, &ret)
+ if err != nil {
+ return nil, err
+ }
+ if ret.Error != "" {
+ return nil, errors.New(ret.Error)
+ }
+ return &ret, nil
+}