seaweedfs/go/operation/lookup.go

89 lines
2.1 KiB
Go
Raw Normal View History

package operation
import (
2013-02-27 06:54:22 +00:00
"code.google.com/p/weed-fs/go/util"
2013-01-17 08:56:56 +00:00
"encoding/json"
"errors"
_ "fmt"
2014-03-30 18:28:04 +00:00
"math/rand"
2013-01-17 08:56:56 +00:00
"net/url"
"strings"
2014-05-25 21:01:54 +00:00
"time"
)
type Location struct {
Url string `json:"url,omitempty"`
PublicUrl string `json:"publicUrl,omitempty"`
}
type LookupResult struct {
VolumeId string `json:"volumeId,omitempty"`
Locations []Location `json:"locations,omitempty"`
Error string `json:"error,omitempty"`
}
2014-05-25 21:01:54 +00:00
var (
vc VidCache
)
func Lookup(server string, vid string) (ret *LookupResult, err error) {
locations, cache_err := vc.Get(vid)
if cache_err != nil {
2014-06-02 16:22:23 +00:00
if ret, err = do_lookup(server, vid); err == nil {
vc.Set(vid, ret.Locations, 1*time.Minute)
}
2014-05-25 21:01:54 +00:00
} else {
ret = &LookupResult{VolumeId: vid, Locations: locations}
}
return
}
func do_lookup(server string, vid string) (*LookupResult, error) {
2013-01-17 08:56:56 +00:00
values := make(url.Values)
values.Add("volumeId", vid)
2013-01-17 08:56:56 +00:00
jsonBlob, err := util.Post("http://"+server+"/dir/lookup", values)
if err != nil {
return nil, err
}
var ret LookupResult
err = json.Unmarshal(jsonBlob, &ret)
if err != nil {
return nil, err
}
if ret.Error != "" {
return nil, errors.New(ret.Error)
}
return &ret, nil
}
2013-11-19 07:03:59 +00:00
func LookupFileId(server string, fileId string) (fullUrl string, err error) {
2014-03-30 18:28:04 +00:00
parts := strings.Split(fileId, ",")
if len(parts) != 2 {
return "", errors.New("Invalid fileId " + fileId)
2013-11-19 07:03:59 +00:00
}
2014-03-30 18:28:04 +00:00
lookup, lookupError := Lookup(server, parts[0])
2013-11-19 07:03:59 +00:00
if lookupError != nil {
return "", lookupError
}
if len(lookup.Locations) == 0 {
return "", errors.New("File Not Found")
}
2014-03-30 18:28:04 +00:00
return "http://" + lookup.Locations[rand.Intn(len(lookup.Locations))].PublicUrl + "/" + fileId, nil
2013-11-19 07:03:59 +00:00
}
2014-04-15 16:09:40 +00:00
func LookupVolumeIds(server string, vids []string) (map[string]LookupResult, error) {
values := make(url.Values)
for _, vid := range vids {
values.Add("volumeId", vid)
}
jsonBlob, err := util.Post("http://"+server+"/vol/lookup", values)
if err != nil {
return nil, err
}
2014-04-15 16:09:40 +00:00
ret := make(map[string]LookupResult)
err = json.Unmarshal(jsonBlob, &ret)
if err != nil {
2014-04-15 16:09:40 +00:00
return nil, errors.New(err.Error() + " " + string(jsonBlob))
}
return ret, nil
}