-
Notifications
You must be signed in to change notification settings - Fork 3
/
vshard_test.go
44 lines (35 loc) · 948 Bytes
/
vshard_test.go
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
package vshard_router //nolint:revive
import (
"sync/atomic"
"testing"
"github.com/stretchr/testify/require"
)
func TestRouter_RouterBucketIDStrCRC32(t *testing.T) {
r := Router{
cfg: Config{TotalBucketCount: uint64(256000)},
}
t.Run("deprecated old logic", func(t *testing.T) {
require.Equal(t, uint64(103202), r.RouterBucketID("2707623829"))
})
t.Run("new logic with current hash sum", func(t *testing.T) {
require.Equal(t, uint64(103202), r.RouterBucketIDStrCRC32("2707623829"))
})
}
func TestRouter_RouterBucketCount(t *testing.T) {
bucketCount := uint64(123)
r := Router{
cfg: Config{TotalBucketCount: bucketCount},
}
require.Equal(t, bucketCount, r.RouterBucketCount())
}
func TestRouter_RouteMapClean(t *testing.T) {
r := Router{
cfg: Config{TotalBucketCount: 10},
view: &consistentView{
routeMap: make([]atomic.Pointer[Replicaset], 10),
},
}
require.NotPanics(t, func() {
r.RouteMapClean()
})
}