aboutsummaryrefslogtreecommitdiff
path: root/weed/filer/read.go
diff options
context:
space:
mode:
authorChris Lu <chris.lu@gmail.com>2020-12-06 20:12:52 -0800
committerChris Lu <chris.lu@gmail.com>2020-12-06 20:12:52 -0800
commit9acda432fe65ad3b136f5ebff48c29de36c3f97c (patch)
treecf49d8aadb6574effc067eb76d19e4a449ea6b4a /weed/filer/read.go
parentae5eb85a0692c46fb6a66818b3cc08bb26ed8cdb (diff)
downloadseaweedfs-9acda432fe65ad3b136f5ebff48c29de36c3f97c.tar.xz
seaweedfs-9acda432fe65ad3b136f5ebff48c29de36c3f97c.zip
fix import cycle
Diffstat (limited to 'weed/filer/read.go')
-rw-r--r--weed/filer/read.go27
1 files changed, 27 insertions, 0 deletions
diff --git a/weed/filer/read.go b/weed/filer/read.go
new file mode 100644
index 000000000..13f282dc7
--- /dev/null
+++ b/weed/filer/read.go
@@ -0,0 +1,27 @@
+package filer
+
+import (
+ "bytes"
+ "github.com/chrislusf/seaweedfs/weed/pb/filer_pb"
+ "github.com/chrislusf/seaweedfs/weed/wdclient"
+ "math"
+)
+
+func ReadEntry(masterClient *wdclient.MasterClient, filerClient filer_pb.SeaweedFilerClient, dir, name string, byteBuffer *bytes.Buffer) error {
+
+ request := &filer_pb.LookupDirectoryEntryRequest{
+ Directory: dir,
+ Name: name,
+ }
+ respLookupEntry, err := filer_pb.LookupEntry(filerClient, request)
+ if err != nil {
+ return err
+ }
+ if len(respLookupEntry.Entry.Content) > 0 {
+ _, err = byteBuffer.Write(respLookupEntry.Entry.Content)
+ return err
+ }
+
+ return StreamContent(masterClient, byteBuffer, respLookupEntry.Entry.Chunks, 0, math.MaxInt64)
+
+}