recordworkflowtaskstarted

Documentation

Index

• func CreateRecordWorkflowTaskStartedResponse(ctx context.Context, ms workflow.MutableState, updateRegistry update.Registry, ...) (*historyservice.RecordWorkflowTaskStartedResponse, error)
• func Invoke(ctx context.Context, req *historyservice.RecordWorkflowTaskStartedRequest, ...) (*historyservice.RecordWorkflowTaskStartedResponse, error)

Functions

func CreateRecordWorkflowTaskStartedResponse

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

func Invoke

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