resetworkflow

Documentation

Index

• func GetResetReapplyExcludeTypes(excludeTypes []enumspb.ResetReapplyExcludeType, ...) map[enumspb.ResetReapplyExcludeType]struct{}
• func Invoke(ctx context.Context, ...) (_ *historyservice.ResetWorkflowExecutionResponse, retError error)

Functions

func GetResetReapplyExcludeTypes

func GetResetReapplyExcludeTypes(
	excludeTypes []enumspb.ResetReapplyExcludeType,
	includeType enumspb.ResetReapplyType,
) map[enumspb.ResetReapplyExcludeType]struct{}

GetResetReapplyExcludeTypes computes the set of requested exclude types. It uses the reset_reapply_exclude_types request field (a set of event types to exclude from reapply), as well as the deprecated reset_reapply_type request field (a specification of what to include).

func Invoke

func Invoke(
	ctx context.Context,
	resetRequest *historyservice.ResetWorkflowExecutionRequest,
	shard shard.Context,
	workflowConsistencyChecker api.WorkflowConsistencyChecker,
) (_ *historyservice.ResetWorkflowExecutionResponse, retError error)