diff options
| author | Chris Lu <chris.lu@gmail.com> | 2016-07-20 23:45:55 -0700 |
|---|---|---|
| committer | Chris Lu <chris.lu@gmail.com> | 2016-07-20 23:45:55 -0700 |
| commit | cdae9fc680c8e7f99c0ef47dd98f674df76e5078 (patch) | |
| tree | 8189bdfb1f38fce7ddc2a2ff73ab040caeb5f30a /weed/operation/filer/register.go | |
| parent | 40ba6d2a6f146ab730cc5409c3dbcfb71f7acab9 (diff) | |
| download | seaweedfs-cdae9fc680c8e7f99c0ef47dd98f674df76e5078.tar.xz seaweedfs-cdae9fc680c8e7f99c0ef47dd98f674df76e5078.zip | |
add "weed copy" command to copy files to filer
Diffstat (limited to 'weed/operation/filer/register.go')
| -rw-r--r-- | weed/operation/filer/register.go | 31 |
1 files changed, 31 insertions, 0 deletions
diff --git a/weed/operation/filer/register.go b/weed/operation/filer/register.go new file mode 100644 index 000000000..2c4703680 --- /dev/null +++ b/weed/operation/filer/register.go @@ -0,0 +1,31 @@ +package operation + +import ( + "fmt" + "net/url" + + "github.com/chrislusf/seaweedfs/weed/security" + "github.com/chrislusf/seaweedfs/weed/util" +) + +type SubmitResult struct { + FileName string `json:"fileName,omitempty"` + FileUrl string `json:"fileUrl,omitempty"` + Fid string `json:"fid,omitempty"` + Size uint32 `json:"size,omitempty"` + Error string `json:"error,omitempty"` +} + +func RegisterFile(filer string, path string, fileId string, secret security.Secret) error { + // TODO: jwt need to be used + _ = security.GenJwt(secret, fileId) + + values := make(url.Values) + values.Add("path", path) + values.Add("fileId", fileId) + _, err := util.Post("http://"+filer+"/admin/register", values) + if err != nil { + return fmt.Errorf("Failed to register path:%s on filer:%s to file id:%s", path, filer, fileId) + } + return nil +} |
