120
}
121
122
>
func (s *HistoryEventsSuite) TestAppendSelect_NonShadowing() {
history_store.go
123
>
treeID := uuid.NewString()
124
>
branchID := uuid.NewString()
125
>
branchToken, err := s.store.GetHistoryBranchUtil().NewHistoryBranch(
126
>
uuid.NewString(),
127
>
uuid.NewString(),
128
>
uuid.NewString(),
129
>
treeID,
130
>
&branchID,
131
>
[]*persistencespb.HistoryBranchRange{},
132
>
time.Duration(0),
133
>
time.Duration(0),
134
>
time.Duration(0),
135
>
)
136
>
s.NoError(err)
137
>
var events []*historypb.HistoryEvent
138
>
139
>
eventsPacket0 := s.newHistoryEvents(
140
>
[]int64{1, 2, 3},
141
>
rand.Int63(),
142
>
0,
143
>
)
144
>
s.appendHistoryEvents(s.ShardID, branchToken, eventsPacket0)
145
>
events = append(events, eventsPacket0.events...)
146
>
147
>
eventsPacket1 := s.newHistoryEvents(
148
>
[]int64{4, 5},
149
>
eventsPacket0.transactionID+1,
150
>
eventsPacket0.transactionID,
151
>
)
152
>
s.appendHistoryEvents(s.ShardID, branchToken, eventsPacket1)
153
>
events = append(events, eventsPacket1.events...)
154
>
155
>
protorequire.ProtoSliceEqual(s.T(), eventsPacket0.events, s.listHistoryEvents(s.ShardID, branchToken, common.FirstEventID, 4))
156
>
protorequire.ProtoSliceEqual(s.T(), eventsPacket1.events, s.listHistoryEvents(s.ShardID, branchToken, 4, 6))
157
>
protorequire.ProtoSliceEqual(s.T(), events, s.listAllHistoryEvents(s.ShardID, branchToken))
158
>
}
159
160
func (s *HistoryEventsSuite) TestAppendSelect_Shadowing() {