recordworkflowtaskstarted

func CreateRecordWorkflowTaskStartedResponse(
	ctx context.Context,
	ms historyi.MutableState,
	updateRegistry update.Registry,
	workflowTask *historyi.WorkflowTaskInfo,
	identity string,
	wtHeartbeat bool,
) (*historyservice.RecordWorkflowTaskStartedResponse, error)

func CreateRecordWorkflowTaskStartedResponseWithRawHistory(
	ctx context.Context,
	ms historyi.MutableState,
	updateRegistry update.Registry,
	workflowTask *historyi.WorkflowTaskInfo,
	identity string,
	wtHeartbeat bool,
) (*historyservice.RecordWorkflowTaskStartedResponseWithRawHistory, error)

func Invoke(
	ctx context.Context,
	req *historyservice.RecordWorkflowTaskStartedRequest,
	shardContext historyi.ShardContext,
	config *configs.Config,
	eventNotifier events.Notifier,
	persistenceVisibilityMgr manager.VisibilityManager,
	workflowConsistencyChecker api.WorkflowConsistencyChecker,
) (*historyservice.RecordWorkflowTaskStartedResponseWithRawHistory, error)