respondworkflowtaskcompleted

Documentation

Index

• Constants
• type WorkflowTaskCompletedHandler
  • func NewWorkflowTaskCompletedHandler(shardContext shard.Context, tokenSerializer common.TaskTokenSerializer, ...) *WorkflowTaskCompletedHandler
  • func (handler *WorkflowTaskCompletedHandler) Invoke(ctx context.Context, req *historyservice.RespondWorkflowTaskCompletedRequest) (_ *historyservice.RespondWorkflowTaskCompletedResponse, retError error)

Constants

const (
	PendingChildWorkflowExecutionsDescription = "pending child workflow executions"
	PendingActivitiesDescription              = "pending activities"
	PendingCancelRequestsDescription          = "pending requests to cancel external workflows"
	PendingSignalsDescription                 = "pending signals to external workflows"
)

Types

type WorkflowTaskCompletedHandler

type WorkflowTaskCompletedHandler struct {
	// contains filtered or unexported fields
}

func NewWorkflowTaskCompletedHandler

func NewWorkflowTaskCompletedHandler(
	shardContext shard.Context,
	tokenSerializer common.TaskTokenSerializer,
	eventNotifier events.Notifier,
	commandHandlerRegistry *workflow.CommandHandlerRegistry,
	searchAttributesValidator *searchattribute.Validator,
	visibilityManager manager.VisibilityManager,
	workflowConsistencyChecker api.WorkflowConsistencyChecker,
) *WorkflowTaskCompletedHandler

func (*WorkflowTaskCompletedHandler) Invoke

func (handler *WorkflowTaskCompletedHandler) Invoke(
	ctx context.Context,
	req *historyservice.RespondWorkflowTaskCompletedRequest,
) (_ *historyservice.RespondWorkflowTaskCompletedResponse, retError error)