329
}
330
331
>
func (s *HistoryEventsSuite) TestAppendForkSelect_Shadowing_LastBranch() {
history_store.go
332
>
treeID := uuid.NewString()
333
>
branchID := uuid.NewString()
334
>
branchToken, err := s.store.GetHistoryBranchUtil().NewHistoryBranch(
335
>
uuid.NewString(),
336
>
uuid.NewString(),
337
>
uuid.NewString(),
338
>
treeID,
339
>
&branchID,
340
>
[]*persistencespb.HistoryBranchRange{},
341
>
time.Duration(0),
342
>
time.Duration(0),
343
>
time.Duration(0),
344
>
)
345
>
s.NoError(err)
346
>
var events0 []*historypb.HistoryEvent
347
>
var events1 []*historypb.HistoryEvent
348
>
349
>
eventsPacket0 := s.newHistoryEvents(
350
>
[]int64{1, 2, 3},
351
>
rand.Int63(),
352
>
0,
353
>
)
354
>
s.appendHistoryEvents(s.ShardID, branchToken, eventsPacket0)
355
>
events0 = append(events0, eventsPacket0.events...)
356
>
events1 = append(events1, eventsPacket0.events...)
357
>
358
>
s.appendHistoryEvents(s.ShardID, branchToken, s.newHistoryEvents(
359
>
[]int64{4, 5},
360
>
eventsPacket0.transactionID+1,
361
>
eventsPacket0.transactionID,
362
>
))
363
>
364
>
newBranchToken := s.forkHistoryBranch(s.ShardID, branchToken, 4)
365
>
eventsPacket20 := s.newHistoryEvents(
366
>
[]int64{4, 5},
367
>
eventsPacket0.transactionID+2,
368
>
eventsPacket0.transactionID,
369
>
)
370
>
s.appendHistoryEvents(s.ShardID, newBranchToken, eventsPacket20)
371
>
events0 = append(events0, eventsPacket20.events...)
372
>
373
>
protorequire.ProtoSliceEqual(s.T(), eventsPacket0.events, s.listHistoryEvents(s.ShardID, newBranchToken, common.FirstEventID, 4))
374
>
protorequire.ProtoSliceEqual(s.T(), eventsPacket20.events, s.listHistoryEvents(s.ShardID, newBranchToken, 4, 6))
375
>
protorequire.ProtoSliceEqual(s.T(), events0, s.listAllHistoryEvents(s.ShardID, newBranchToken))
376
>
377
>
eventsPacket21 := s.newHistoryEvents(
378
>
[]int64{4, 5},
379
>
eventsPacket0.transactionID+3,
380
>
eventsPacket0.transactionID,
381
>
)
382
>
s.appendHistoryEvents(s.ShardID, newBranchToken, eventsPacket21)
383
>
events1 = append(events1, eventsPacket21.events...)
384
>
385
>
protorequire.ProtoSliceEqual(s.T(), eventsPacket0.events, s.listHistoryEvents(s.ShardID, newBranchToken, common.FirstEventID, 4))
386
>
protorequire.ProtoSliceEqual(s.T(), eventsPacket21.events, s.listHistoryEvents(s.ShardID, newBranchToken, 4, 6))
387
>
protorequire.ProtoSliceEqual(s.T(), events1, s.listAllHistoryEvents(s.ShardID, newBranchToken))
388
>
}
389
390
func (s *HistoryEventsSuite) TestAppendSelectTrim() {