in common/types/mapper/proto/api.go [5652:5791]
func ToHistoryEvent(e *apiv1.HistoryEvent) *types.HistoryEvent {
if e == nil {
return nil
}
event := types.HistoryEvent{
ID: e.EventId,
Timestamp: timeToUnixNano(e.EventTime),
Version: e.Version,
TaskID: e.TaskId,
}
switch attr := e.Attributes.(type) {
case *apiv1.HistoryEvent_WorkflowExecutionStartedEventAttributes:
event.EventType = types.EventTypeWorkflowExecutionStarted.Ptr()
event.WorkflowExecutionStartedEventAttributes = ToWorkflowExecutionStartedEventAttributes(attr.WorkflowExecutionStartedEventAttributes)
case *apiv1.HistoryEvent_WorkflowExecutionCompletedEventAttributes:
event.EventType = types.EventTypeWorkflowExecutionCompleted.Ptr()
event.WorkflowExecutionCompletedEventAttributes = ToWorkflowExecutionCompletedEventAttributes(attr.WorkflowExecutionCompletedEventAttributes)
case *apiv1.HistoryEvent_WorkflowExecutionFailedEventAttributes:
event.EventType = types.EventTypeWorkflowExecutionFailed.Ptr()
event.WorkflowExecutionFailedEventAttributes = ToWorkflowExecutionFailedEventAttributes(attr.WorkflowExecutionFailedEventAttributes)
case *apiv1.HistoryEvent_WorkflowExecutionTimedOutEventAttributes:
event.EventType = types.EventTypeWorkflowExecutionTimedOut.Ptr()
event.WorkflowExecutionTimedOutEventAttributes = ToWorkflowExecutionTimedOutEventAttributes(attr.WorkflowExecutionTimedOutEventAttributes)
case *apiv1.HistoryEvent_DecisionTaskScheduledEventAttributes:
event.EventType = types.EventTypeDecisionTaskScheduled.Ptr()
event.DecisionTaskScheduledEventAttributes = ToDecisionTaskScheduledEventAttributes(attr.DecisionTaskScheduledEventAttributes)
case *apiv1.HistoryEvent_DecisionTaskStartedEventAttributes:
event.EventType = types.EventTypeDecisionTaskStarted.Ptr()
event.DecisionTaskStartedEventAttributes = ToDecisionTaskStartedEventAttributes(attr.DecisionTaskStartedEventAttributes)
case *apiv1.HistoryEvent_DecisionTaskCompletedEventAttributes:
event.EventType = types.EventTypeDecisionTaskCompleted.Ptr()
event.DecisionTaskCompletedEventAttributes = ToDecisionTaskCompletedEventAttributes(attr.DecisionTaskCompletedEventAttributes)
case *apiv1.HistoryEvent_DecisionTaskTimedOutEventAttributes:
event.EventType = types.EventTypeDecisionTaskTimedOut.Ptr()
event.DecisionTaskTimedOutEventAttributes = ToDecisionTaskTimedOutEventAttributes(attr.DecisionTaskTimedOutEventAttributes)
case *apiv1.HistoryEvent_DecisionTaskFailedEventAttributes:
event.EventType = types.EventTypeDecisionTaskFailed.Ptr()
event.DecisionTaskFailedEventAttributes = ToDecisionTaskFailedEventAttributes(attr.DecisionTaskFailedEventAttributes)
case *apiv1.HistoryEvent_ActivityTaskScheduledEventAttributes:
event.EventType = types.EventTypeActivityTaskScheduled.Ptr()
event.ActivityTaskScheduledEventAttributes = ToActivityTaskScheduledEventAttributes(attr.ActivityTaskScheduledEventAttributes)
case *apiv1.HistoryEvent_ActivityTaskStartedEventAttributes:
event.EventType = types.EventTypeActivityTaskStarted.Ptr()
event.ActivityTaskStartedEventAttributes = ToActivityTaskStartedEventAttributes(attr.ActivityTaskStartedEventAttributes)
case *apiv1.HistoryEvent_ActivityTaskCompletedEventAttributes:
event.EventType = types.EventTypeActivityTaskCompleted.Ptr()
event.ActivityTaskCompletedEventAttributes = ToActivityTaskCompletedEventAttributes(attr.ActivityTaskCompletedEventAttributes)
case *apiv1.HistoryEvent_ActivityTaskFailedEventAttributes:
event.EventType = types.EventTypeActivityTaskFailed.Ptr()
event.ActivityTaskFailedEventAttributes = ToActivityTaskFailedEventAttributes(attr.ActivityTaskFailedEventAttributes)
case *apiv1.HistoryEvent_ActivityTaskTimedOutEventAttributes:
event.EventType = types.EventTypeActivityTaskTimedOut.Ptr()
event.ActivityTaskTimedOutEventAttributes = ToActivityTaskTimedOutEventAttributes(attr.ActivityTaskTimedOutEventAttributes)
case *apiv1.HistoryEvent_TimerStartedEventAttributes:
event.EventType = types.EventTypeTimerStarted.Ptr()
event.TimerStartedEventAttributes = ToTimerStartedEventAttributes(attr.TimerStartedEventAttributes)
case *apiv1.HistoryEvent_TimerFiredEventAttributes:
event.EventType = types.EventTypeTimerFired.Ptr()
event.TimerFiredEventAttributes = ToTimerFiredEventAttributes(attr.TimerFiredEventAttributes)
case *apiv1.HistoryEvent_ActivityTaskCancelRequestedEventAttributes:
event.EventType = types.EventTypeActivityTaskCancelRequested.Ptr()
event.ActivityTaskCancelRequestedEventAttributes = ToActivityTaskCancelRequestedEventAttributes(attr.ActivityTaskCancelRequestedEventAttributes)
case *apiv1.HistoryEvent_RequestCancelActivityTaskFailedEventAttributes:
event.EventType = types.EventTypeRequestCancelActivityTaskFailed.Ptr()
event.RequestCancelActivityTaskFailedEventAttributes = ToRequestCancelActivityTaskFailedEventAttributes(attr.RequestCancelActivityTaskFailedEventAttributes)
case *apiv1.HistoryEvent_ActivityTaskCanceledEventAttributes:
event.EventType = types.EventTypeActivityTaskCanceled.Ptr()
event.ActivityTaskCanceledEventAttributes = ToActivityTaskCanceledEventAttributes(attr.ActivityTaskCanceledEventAttributes)
case *apiv1.HistoryEvent_TimerCanceledEventAttributes:
event.EventType = types.EventTypeTimerCanceled.Ptr()
event.TimerCanceledEventAttributes = ToTimerCanceledEventAttributes(attr.TimerCanceledEventAttributes)
case *apiv1.HistoryEvent_CancelTimerFailedEventAttributes:
event.EventType = types.EventTypeCancelTimerFailed.Ptr()
event.CancelTimerFailedEventAttributes = ToCancelTimerFailedEventAttributes(attr.CancelTimerFailedEventAttributes)
case *apiv1.HistoryEvent_MarkerRecordedEventAttributes:
event.EventType = types.EventTypeMarkerRecorded.Ptr()
event.MarkerRecordedEventAttributes = ToMarkerRecordedEventAttributes(attr.MarkerRecordedEventAttributes)
case *apiv1.HistoryEvent_WorkflowExecutionSignaledEventAttributes:
event.EventType = types.EventTypeWorkflowExecutionSignaled.Ptr()
event.WorkflowExecutionSignaledEventAttributes = ToWorkflowExecutionSignaledEventAttributes(attr.WorkflowExecutionSignaledEventAttributes)
case *apiv1.HistoryEvent_WorkflowExecutionTerminatedEventAttributes:
event.EventType = types.EventTypeWorkflowExecutionTerminated.Ptr()
event.WorkflowExecutionTerminatedEventAttributes = ToWorkflowExecutionTerminatedEventAttributes(attr.WorkflowExecutionTerminatedEventAttributes)
case *apiv1.HistoryEvent_WorkflowExecutionCancelRequestedEventAttributes:
event.EventType = types.EventTypeWorkflowExecutionCancelRequested.Ptr()
event.WorkflowExecutionCancelRequestedEventAttributes = ToWorkflowExecutionCancelRequestedEventAttributes(attr.WorkflowExecutionCancelRequestedEventAttributes)
case *apiv1.HistoryEvent_WorkflowExecutionCanceledEventAttributes:
event.EventType = types.EventTypeWorkflowExecutionCanceled.Ptr()
event.WorkflowExecutionCanceledEventAttributes = ToWorkflowExecutionCanceledEventAttributes(attr.WorkflowExecutionCanceledEventAttributes)
case *apiv1.HistoryEvent_RequestCancelExternalWorkflowExecutionInitiatedEventAttributes:
event.EventType = types.EventTypeRequestCancelExternalWorkflowExecutionInitiated.Ptr()
event.RequestCancelExternalWorkflowExecutionInitiatedEventAttributes = ToRequestCancelExternalWorkflowExecutionInitiatedEventAttributes(attr.RequestCancelExternalWorkflowExecutionInitiatedEventAttributes)
case *apiv1.HistoryEvent_RequestCancelExternalWorkflowExecutionFailedEventAttributes:
event.EventType = types.EventTypeRequestCancelExternalWorkflowExecutionFailed.Ptr()
event.RequestCancelExternalWorkflowExecutionFailedEventAttributes = ToRequestCancelExternalWorkflowExecutionFailedEventAttributes(attr.RequestCancelExternalWorkflowExecutionFailedEventAttributes)
case *apiv1.HistoryEvent_ExternalWorkflowExecutionCancelRequestedEventAttributes:
event.EventType = types.EventTypeExternalWorkflowExecutionCancelRequested.Ptr()
event.ExternalWorkflowExecutionCancelRequestedEventAttributes = ToExternalWorkflowExecutionCancelRequestedEventAttributes(attr.ExternalWorkflowExecutionCancelRequestedEventAttributes)
case *apiv1.HistoryEvent_WorkflowExecutionContinuedAsNewEventAttributes:
event.EventType = types.EventTypeWorkflowExecutionContinuedAsNew.Ptr()
event.WorkflowExecutionContinuedAsNewEventAttributes = ToWorkflowExecutionContinuedAsNewEventAttributes(attr.WorkflowExecutionContinuedAsNewEventAttributes)
case *apiv1.HistoryEvent_StartChildWorkflowExecutionInitiatedEventAttributes:
event.EventType = types.EventTypeStartChildWorkflowExecutionInitiated.Ptr()
event.StartChildWorkflowExecutionInitiatedEventAttributes = ToStartChildWorkflowExecutionInitiatedEventAttributes(attr.StartChildWorkflowExecutionInitiatedEventAttributes)
case *apiv1.HistoryEvent_StartChildWorkflowExecutionFailedEventAttributes:
event.EventType = types.EventTypeStartChildWorkflowExecutionFailed.Ptr()
event.StartChildWorkflowExecutionFailedEventAttributes = ToStartChildWorkflowExecutionFailedEventAttributes(attr.StartChildWorkflowExecutionFailedEventAttributes)
case *apiv1.HistoryEvent_ChildWorkflowExecutionStartedEventAttributes:
event.EventType = types.EventTypeChildWorkflowExecutionStarted.Ptr()
event.ChildWorkflowExecutionStartedEventAttributes = ToChildWorkflowExecutionStartedEventAttributes(attr.ChildWorkflowExecutionStartedEventAttributes)
case *apiv1.HistoryEvent_ChildWorkflowExecutionCompletedEventAttributes:
event.EventType = types.EventTypeChildWorkflowExecutionCompleted.Ptr()
event.ChildWorkflowExecutionCompletedEventAttributes = ToChildWorkflowExecutionCompletedEventAttributes(attr.ChildWorkflowExecutionCompletedEventAttributes)
case *apiv1.HistoryEvent_ChildWorkflowExecutionFailedEventAttributes:
event.EventType = types.EventTypeChildWorkflowExecutionFailed.Ptr()
event.ChildWorkflowExecutionFailedEventAttributes = ToChildWorkflowExecutionFailedEventAttributes(attr.ChildWorkflowExecutionFailedEventAttributes)
case *apiv1.HistoryEvent_ChildWorkflowExecutionCanceledEventAttributes:
event.EventType = types.EventTypeChildWorkflowExecutionCanceled.Ptr()
event.ChildWorkflowExecutionCanceledEventAttributes = ToChildWorkflowExecutionCanceledEventAttributes(attr.ChildWorkflowExecutionCanceledEventAttributes)
case *apiv1.HistoryEvent_ChildWorkflowExecutionTimedOutEventAttributes:
event.EventType = types.EventTypeChildWorkflowExecutionTimedOut.Ptr()
event.ChildWorkflowExecutionTimedOutEventAttributes = ToChildWorkflowExecutionTimedOutEventAttributes(attr.ChildWorkflowExecutionTimedOutEventAttributes)
case *apiv1.HistoryEvent_ChildWorkflowExecutionTerminatedEventAttributes:
event.EventType = types.EventTypeChildWorkflowExecutionTerminated.Ptr()
event.ChildWorkflowExecutionTerminatedEventAttributes = ToChildWorkflowExecutionTerminatedEventAttributes(attr.ChildWorkflowExecutionTerminatedEventAttributes)
case *apiv1.HistoryEvent_SignalExternalWorkflowExecutionInitiatedEventAttributes:
event.EventType = types.EventTypeSignalExternalWorkflowExecutionInitiated.Ptr()
event.SignalExternalWorkflowExecutionInitiatedEventAttributes = ToSignalExternalWorkflowExecutionInitiatedEventAttributes(attr.SignalExternalWorkflowExecutionInitiatedEventAttributes)
case *apiv1.HistoryEvent_SignalExternalWorkflowExecutionFailedEventAttributes:
event.EventType = types.EventTypeSignalExternalWorkflowExecutionFailed.Ptr()
event.SignalExternalWorkflowExecutionFailedEventAttributes = ToSignalExternalWorkflowExecutionFailedEventAttributes(attr.SignalExternalWorkflowExecutionFailedEventAttributes)
case *apiv1.HistoryEvent_ExternalWorkflowExecutionSignaledEventAttributes:
event.EventType = types.EventTypeExternalWorkflowExecutionSignaled.Ptr()
event.ExternalWorkflowExecutionSignaledEventAttributes = ToExternalWorkflowExecutionSignaledEventAttributes(attr.ExternalWorkflowExecutionSignaledEventAttributes)
case *apiv1.HistoryEvent_UpsertWorkflowSearchAttributesEventAttributes:
event.EventType = types.EventTypeUpsertWorkflowSearchAttributes.Ptr()
event.UpsertWorkflowSearchAttributesEventAttributes = ToUpsertWorkflowSearchAttributesEventAttributes(attr.UpsertWorkflowSearchAttributesEventAttributes)
}
return &event
}