scriptoriumadmin/featurebase
1
0
Fork 0
mirror of https://github.com/featurebasedb/featurebase.git synced 2026-09-10 23:11:01 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions

Merge pull request #776 from niaow/configure-slurp

Browse source 
Configure slurp
This commit is contained in:
jaten-molecula 2020-09-03 02:33:58 -04:00 • committed by GitHub
commit d3485dbdb3
No known key found for this signature in database
GPG key ID: 4AEE18F83AFDEB23
1 changed files with 10 additions and 8 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

18
cmd/slurp/slurp.go
View file

@ -19,6 +19,7 @@ import (
"bytes"
"compress/gzip"
"context"
"flag"
"time"
//"fmt"
@ -178,13 +179,20 @@ func UploadTar(srcFile string, client *http.InternalClient) error {
}
func main() {
var host string
var tarSrcPath string
flag.StringVar(&host, "host", "127.0.0.1:10101", "host to import into")
flag.StringVar(&tarSrcPath, "src", "q2.tar.gz", "data to import")
flag.Parse()
uri, err := pilosa.NewURIFromAddress(host)
panicOn(err)
globURI = uri
host := "127.0.0.1:10101"
h := &gohttp.Client{}
c, err := http.NewInternalClient(host, h)
panicOn(err)
tarSrcPath := os.Args[1] //"q2.tar.gz"
t0 := time.Now()
println("uploading", tarSrcPath)
panicOn(UploadTar(tarSrcPath, c))
@ -193,12 +201,6 @@ func main() {
var globURI *pilosa.URI
func init() {
var err error
globURI, err = pilosa.NewURIFromHostPort("127.0.0.1", 10101)
panicOn(err)
}
// get correct node to go to.
func GetImportRoaringURI(index string, shard uint64) *pilosa.URI {
return globURI