158
}
159
160
>
func (s *HistoryEventsSuite) TestAppendSelect_Shadowing() {
history_store.go
161
>
treeID := uuid.NewString()
162
>
branchID := uuid.NewString()
163
>
branchToken, err := s.store.GetHistoryBranchUtil().NewHistoryBranch(
164
>
uuid.NewString(),
165
>
uuid.NewString(),
166
>
uuid.NewString(),
167
>
treeID,
168
>
&branchID,
169
>
[]*persistencespb.HistoryBranchRange{},
170
>
time.Duration(0),
171
>
time.Duration(0),
172
>
time.Duration(0),
173
>
)
174
>
s.NoError(err)
175
>
var events0 []*historypb.HistoryEvent
176
>
var events1 []*historypb.HistoryEvent
177
>
178
>
eventsPacket0 := s.newHistoryEvents(
179
>
[]int64{1, 2, 3},
180
>
rand.Int63(),
181
>
0,
182
>
)
183
>
s.appendHistoryEvents(s.ShardID, branchToken, eventsPacket0)
184
>
events0 = append(events0, eventsPacket0.events...)
185
>
events1 = append(events1, eventsPacket0.events...)
186
>
187
>
eventsPacket10 := s.newHistoryEvents(
188
>
[]int64{4, 5},
189
>
eventsPacket0.transactionID+1,
190
>
eventsPacket0.transactionID,
191
>
)
192
>
s.appendHistoryEvents(s.ShardID, branchToken, eventsPacket10)
193
>
events0 = append(events0, eventsPacket10.events...)
194
>
195
>
protorequire.ProtoSliceEqual(s.T(), events0, s.listAllHistoryEvents(s.ShardID, branchToken))
196
>
197
>
eventsPacket11 := s.newHistoryEvents(
198
>
[]int64{4, 5},
199
>
eventsPacket0.transactionID+2,
200
>
eventsPacket0.transactionID,
201
>
)
202
>
s.appendHistoryEvents(s.ShardID, branchToken, eventsPacket11)
203
>
events1 = append(events1, eventsPacket11.events...)
204
>
205
>
protorequire.ProtoSliceEqual(s.T(), eventsPacket0.events, s.listHistoryEvents(s.ShardID, branchToken, common.FirstEventID, 4))
206
>
protorequire.ProtoSliceEqual(s.T(), eventsPacket11.events, s.listHistoryEvents(s.ShardID, branchToken, 4, 6))
207
>
protorequire.ProtoSliceEqual(s.T(), events1, s.listAllHistoryEvents(s.ShardID, branchToken))
208
>
}
209
210
func (s *HistoryEventsSuite) TestAppendForkSelect_NoShadowing() {