aboutsummaryrefslogtreecommitdiff
path: root/weed/pb/filer_pb/filer_pb_helper.go
diff options
context:
space:
mode:
Diffstat (limited to 'weed/pb/filer_pb/filer_pb_helper.go')
-rw-r--r--weed/pb/filer_pb/filer_pb_helper.go14
1 files changed, 14 insertions, 0 deletions
diff --git a/weed/pb/filer_pb/filer_pb_helper.go b/weed/pb/filer_pb/filer_pb_helper.go
index 5c40332e6..b2ffacc01 100644
--- a/weed/pb/filer_pb/filer_pb_helper.go
+++ b/weed/pb/filer_pb/filer_pb_helper.go
@@ -1,6 +1,9 @@
package filer_pb
import (
+ "context"
+ "fmt"
+
"github.com/chrislusf/seaweedfs/weed/storage/needle"
)
@@ -67,3 +70,14 @@ func AfterEntryDeserialization(chunks []*FileChunk) {
}
}
+
+func CreateEntry(ctx context.Context, client SeaweedFilerClient, request *CreateEntryRequest) error {
+ resp, err := client.CreateEntry(ctx, request)
+ if err == nil && resp.Error != "" {
+ return fmt.Errorf("CreateEntry: %v", resp.Error)
+ }
+ if err != nil {
+ return fmt.Errorf("CreateEntry: %v", err)
+ }
+ return err
+}