93
}
94
96
>
treeID := uuid.NewString()
97
>
branchID := uuid.NewString()
98
>
branchToken, err := s.store.GetHistoryBranchUtil().NewHistoryBranch(
99
>
uuid.NewString(),
100
>
uuid.NewString(),
101
>
uuid.NewString(),
102
>
treeID,
103
>
&branchID,
104
>
[]*persistencespb.HistoryBranchRange{},
105
>
time.Duration(0),
106
>
time.Duration(0),
107
>
time.Duration(0),
108
>
)
109
>
s.NoError(err)
110
>
111
>
eventsPacket := s.newHistoryEvents(
112
>
[]int64{1, 2, 3},
113
>
rand.Int63(),
114
>
0,
115
>
)
116
>
s.appendHistoryEvents(s.ShardID, branchToken, eventsPacket)
117
>
118
>
protorequire.ProtoSliceEqual(s.T(), eventsPacket.events, s.listHistoryEvents(s.ShardID, branchToken, common.FirstEventID, 4))
119
>
protorequire.ProtoSliceEqual(s.T(), eventsPacket.events, s.listAllHistoryEvents(s.ShardID, branchToken))
120
>
}
121
122
func (s *HistoryEventsSuite) TestAppendSelect_NonShadowing() {