taskvalidator

Documentation

Overview

Package taskvalidator provides a Work in Progress service for workflow validations.

Index

• type Checker
  • func NewWfChecker(logger *zap.Logger, metrics metrics.Client, domainCache cache.DomainCache, ...) (Checker, error)

Types

type Checker

type Checker interface {
	WorkflowCheckforValidation(ctx context.Context, workflowID string, domainID string, domainName string, runID string) error
}

Checker interface for initiating the validation process.

func NewWfChecker

func NewWfChecker(logger *zap.Logger, metrics metrics.Client, domainCache cache.DomainCache, executionManager persistence.ExecutionManager, historymanager persistence.HistoryManager) (Checker, error)

NewWfChecker creates a new instance of a workflow validation checker. It requires a logger, metrics client, domain cache, persistence retryer, and a stale checker implementation to function.