mirror of
https://github.com/featurebasedb/featurebase.git
synced 2026-10-07 19:37:51 +00:00
add things.
This commit is contained in:
parent
f33cbdf168
commit
a3f93a617b
2 changed files with 10 additions and 5 deletions
|
|
@ -148,7 +148,8 @@ func (service *Service) MetaWatcher() {
|
|||
}
|
||||
}
|
||||
database, _ := cluster.GetDatabase("main")
|
||||
database.TestSetBit(db.Bitmap{0, "general"}, 0)
|
||||
spew.Dump(database)
|
||||
database.TestSetBit(db.Bitmap{1200, "general"}, 1)
|
||||
|
||||
receiver := make(chan *etcd.Response)
|
||||
stop := make(chan bool)
|
||||
|
|
|
|||
|
|
@ -2,6 +2,7 @@ package db
|
|||
|
||||
import (
|
||||
"github.com/stathat/consistent"
|
||||
"github.com/davecgh/go-spew/spew"
|
||||
"github.com/nu7hatch/gouuid"
|
||||
"log"
|
||||
"fmt"
|
||||
|
|
@ -219,8 +220,11 @@ func (d *Database) TestSetBit(bitmap Bitmap, profile_id int) {
|
|||
log.Println("slice:",slice)
|
||||
frame, _ := d.GetFrame(bitmap.FrameType)
|
||||
fsi, _ := d.GetFrameSliceIntersect(frame, slice)
|
||||
fragment,erry := fsi.Hashring.Get(fmt.Sprintf("%d", bitmap.Id))
|
||||
|
||||
log.Println("fragment:",fragment)
|
||||
log.Println("error:",erry)
|
||||
frag_id_s,err := fsi.Hashring.Get(fmt.Sprintf("%d", bitmap.Id))
|
||||
frag_id, err := strconv.Atoi(frag_id_s)
|
||||
fragment, err := fsi.GetFragment(frag_id)
|
||||
if err != nil {
|
||||
log.Fatal(err)
|
||||
}
|
||||
spew.Dump(fragment)
|
||||
}
|
||||
|
|
|
|||
Loading…
Add table
Reference in a new issue