138
eventID int64,
139
version int64,
140
>
) ([]*historyspb.VersionHistoryItem, []byte, *workflowspb.BaseExecutionInfo, error) {
xdc_cache.go
141
>
baseWorkflowInfo := CopyBaseWorkflowInfo(executionInfo.BaseExecutionInfo)
142
>
versionHistories := executionInfo.VersionHistories
143
>
versionHistoryIndex, err := versionhistory.FindFirstVersionHistoryIndexByVersionHistoryItem(
144
>
versionHistories,
145
>
versionhistory.NewVersionHistoryItem(
146
>
eventID,
147
>
version,
148
>
),
149
>
)
150
>
if err != nil {
151
return nil, nil, nil, err
152
}
153
154
>
versionHistoryBranch, err := versionhistory.GetVersionHistory(versionHistories, versionHistoryIndex)
xdc_cache.go
155
>
if err != nil {
156
return nil, nil, nil, err
157
}
158
>
return versionhistory.CopyVersionHistory(versionHistoryBranch).GetItems(), versionHistoryBranch.GetBranchToken(), baseWorkflowInfo, nil
xdc_cache.go
159
}
160
161
func CopyBaseWorkflowInfo(
162
baseWorkflowInfo *workflowspb.BaseExecutionInfo,
164
>
if baseWorkflowInfo == nil {
165
return nil
166
}