()
| 274 | } |
| 275 | |
| 276 | func testZRangeByScore() { |
| 277 | if err := db.Update( |
| 278 | func(tx *nutsdb.Tx) error { |
| 279 | bucket := "myZSet1" |
| 280 | key := []byte("key1") |
| 281 | return tx.ZAdd(bucket, key, 70, []byte("val1")) |
| 282 | }); err != nil { |
| 283 | log.Fatal(err) |
| 284 | } |
| 285 | |
| 286 | if err := db.Update( |
| 287 | func(tx *nutsdb.Tx) error { |
| 288 | bucket := "myZSet1" |
| 289 | key := []byte("key1") |
| 290 | return tx.ZAdd(bucket, key, 90, []byte("val2")) |
| 291 | }); err != nil { |
| 292 | log.Fatal(err) |
| 293 | } |
| 294 | |
| 295 | if err := db.Update( |
| 296 | func(tx *nutsdb.Tx) error { |
| 297 | bucket := "myZSet1" |
| 298 | key := []byte("key1") |
| 299 | return tx.ZAdd(bucket, key, 86, []byte("val3")) |
| 300 | }); err != nil { |
| 301 | log.Fatal(err) |
| 302 | } |
| 303 | |
| 304 | if err := db.View( |
| 305 | func(tx *nutsdb.Tx) error { |
| 306 | bucket := "myZSet1" |
| 307 | key := []byte("key1") |
| 308 | nodes, err := tx.ZRangeByScore(bucket, key, 80, 100, nil) |
| 309 | if err != nil { |
| 310 | return err |
| 311 | } |
| 312 | for _, node := range nodes { |
| 313 | fmt.Println("item:", string(node.Value), node.Score) |
| 314 | } |
| 315 | return nil |
| 316 | }); err != nil { |
| 317 | log.Fatal(err) |
| 318 | } |
| 319 | } |
| 320 | |
| 321 | func testZRank() { |
| 322 | if err := db.View( |
no test coverage detected