Commit b9517de

committed

add token range example in the distributed-db playground

1 parent f6233a1 commit b9517deCopy full SHA for b9517de

File tree

-1

lines changed

-1

lines changed

Lines changed: 9 additions & 1 deletion

Original file line number	Diff line number	Diff line change
`@@ -1,6 +1,8 @@`
`1`	`1`	`package main`
`2`	`2`
`3`	`3`	`import (`
	`4`	`+ "crypto/md5"`
	`5`	`+ "encoding/json"`
`4`	`6`	`"fmt"`
`5`	`7`	`"hash/fnv"`
`6`	`8`	`"math"`
`@@ -46,11 +48,17 @@ func main() {`
`46`	`48`	`}`
`47`	`49`	`tokens.AddNode(newNode)`
`48`	`50`
`49`		`- for i := 0; i < 1000; i++ {`
	`51`	`+ for i := 0; i < 50; i++ {`
`50`	`52`	`key := fmt.Sprintf("k%d", i+1)`
`51`	`53`	`sum := hash(key)`
`52`	`54`	`fmt.Println(key, sum, tokens.GetNode(sum).Name)`
`53`	`55`	`}`
	`56`	`+`
	`57`	`+ // the message is quite big,`
	`58`	`+ // but it is exchanged only 1 time when a node joins`
	`59`	`+ bs, _ := json.Marshal(tokens.Mappings)`
	`60`	`+ // sending only the checksum can save a lot of space`
	`61`	`+ fmt.Printf("%x", md5.Sum(bs))`
`54`	`62`	`}`
`55`	`63`
`56`	`64`	`func NewTokens(nodes []Node, numberOfTokenRanges int) Tokens {`

Comments

(0)