972
}
973
974
>
func (ms *MutableStateImpl) CloneToProto() *persistencespb.WorkflowMutableState {
mutable_state_impl.go
975
>
msProto := &persistencespb.WorkflowMutableState{
976
>
ActivityInfos: ms.pendingActivityInfoIDs,
977
>
TimerInfos: ms.pendingTimerInfoIDs,
978
>
ChildExecutionInfos: ms.pendingChildExecutionInfoIDs,
979
>
RequestCancelInfos: ms.pendingRequestCancelInfoIDs,
980
>
SignalInfos: ms.pendingSignalInfoIDs,
981
>
ChasmNodes: ms.chasmTree.Snapshot(nil).Nodes,
982
>
SignalRequestedIds: convert.StringSetToSlice(ms.pendingSignalRequestedIDs),
983
>
ExecutionInfo: ms.executionInfo,
984
>
ExecutionState: ms.executionState,
985
>
NextEventId: ms.hBuilder.NextEventID(),
986
>
BufferedEvents: ms.bufferEventsInDB,
987
>
Checksum: ms.checksum,
988
>
}
989
>
990
>
return common.CloneProto(msProto)
991
>
}
992
993
func (ms *MutableStateImpl) GetWorkflowKey() definition.WorkflowKey {