80
}
81
82
>
func (s *ShardSuite) TestGetOrCreateShard_Get() {
shard.go
83
>
rangeID := rand.Int63()
84
>
shardInfo := RandomShardInfo(s.ShardID, rangeID)
85
>
86
>
resp, err := s.ShardManager.GetOrCreateShard(s.Ctx, &p.GetOrCreateShardRequest{
87
>
ShardID: s.ShardID,
88
>
InitialShardInfo: shardInfo,
89
>
})
90
>
s.NoError(err)
91
>
s.ProtoEqual(shardInfo, resp.ShardInfo)
92
>
93
>
resp, err = s.ShardManager.GetOrCreateShard(s.Ctx, &p.GetOrCreateShardRequest{
94
>
ShardID: s.ShardID,
95
>
InitialShardInfo: RandomShardInfo(s.ShardID, rand.Int63()),
96
>
})
97
>
s.NoError(err)
98
>
s.ProtoEqual(shardInfo, resp.ShardInfo)
99
>
}
100
101
func (s *ShardSuite) TestUpdateShard_OwnershipLost() {