recordworkflowtaskstarted

Documentation

Index

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

Functions

func CreateRecordWorkflowTaskStartedResponse

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

func CreateRecordWorkflowTaskStartedResponseWithRawHistory

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

func Invoke

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)