diff options
| author | Chris Lu <chris.lu@gmail.com> | 2020-12-06 20:12:52 -0800 |
|---|---|---|
| committer | Chris Lu <chris.lu@gmail.com> | 2020-12-06 20:12:52 -0800 |
| commit | 9acda432fe65ad3b136f5ebff48c29de36c3f97c (patch) | |
| tree | cf49d8aadb6574effc067eb76d19e4a449ea6b4a /weed/filer/read.go | |
| parent | ae5eb85a0692c46fb6a66818b3cc08bb26ed8cdb (diff) | |
| download | seaweedfs-9acda432fe65ad3b136f5ebff48c29de36c3f97c.tar.xz seaweedfs-9acda432fe65ad3b136f5ebff48c29de36c3f97c.zip | |
fix import cycle
Diffstat (limited to 'weed/filer/read.go')
| -rw-r--r-- | weed/filer/read.go | 27 |
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) + +} |
