scriptoriumadmin/featurebase
1
0
Fork 0
mirror of https://github.com/featurebasedb/featurebase.git synced 2026-09-07 17:15:56 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions

shard import

Browse source
This commit is contained in:
Todd Gruben 2021-05-14 11:05:53 -05:00
parent 42b465b80c
commit 69245ee209
1 changed files with 12 additions and 1 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

13
ctl/restore.go
View file

@ -23,6 +23,7 @@ import (
"io"
gohttp "net/http"
"os"
"strconv"
"strings"
"github.com/pilosa/pilosa/v2"
@ -171,8 +172,18 @@ func (cmd *RestoreCommand) Run(ctx context.Context) error {
indexName := record[1]
switch record[2] {
case "shards":
shard := record[3]
sshard := record[3]
shard, err := strconv.Atoi(sshard)
if err != nil {
return err
}
vprint.VV("shard %v %v", shard, indexName)
url := primary.URI.Path(fmt.Sprintf("/internal/restore/%v/%v", indexName, shard))
vprint.VV("%v", url)
_, err = c.Post(url, "application/octet-stream", tarReader)
if err != nil {
return err
}
case "translate":
vprint.VV("column keys %v", indexName)
case "attributes":