584
}
585
586
>
func (b *EventFactory) CreateWorkflowExecutionCancelRequestedEvent(request *historyservice.RequestCancelWorkflowExecutionRequest) *historypb.HistoryEvent {
event_factory.go
587
>
event := b.createHistoryEvent(enumspb.EVENT_TYPE_WORKFLOW_EXECUTION_CANCEL_REQUESTED, b.timeSource.Now())
588
>
event.Attributes = &historypb.HistoryEvent_WorkflowExecutionCancelRequestedEventAttributes{
589
>
WorkflowExecutionCancelRequestedEventAttributes: &historypb.WorkflowExecutionCancelRequestedEventAttributes{
590
>
Cause: request.CancelRequest.Reason,
591
>
Identity: request.CancelRequest.Identity,
592
>
ExternalInitiatedEventId: request.ExternalInitiatedEventId,
593
>
ExternalWorkflowExecution: request.ExternalWorkflowExecution,
594
>
},
595
>
}
596
>
event.Links = request.CancelRequest.Links
597
>
return event
598
>
}
599
600
func (b *EventFactory) CreateWorkflowExecutionCanceledEvent(