progress

Documentation

Index

• type Config
• type Metrics
  • func NewMetrics(scope tally.Scope) *Metrics
• type WorkflowProgressCheck
  • func (u *WorkflowProgressCheck) Check()
  • func (u *WorkflowProgressCheck) Register(manager background.Manager) error

Types

type Config

type Config struct {
	WorkflowProgressCheckPeriod time.Duration `yaml:"workflow_progress_check_period"`
	StaleWorkflowThreshold      time.Duration `yaml:"stale_workflow_threshold"`
}

type Metrics

type Metrics struct {
	TotalWorkflow       tally.Gauge
	TotalActiveWorkflow tally.Gauge
	TotalStaleWorkflow  tally.Gauge
	ProcessDuration     tally.Timer

	GetJobRuntimeFailure tally.Gauge
}

func NewMetrics

func NewMetrics(scope tally.Scope) *Metrics

type WorkflowProgressCheck

type WorkflowProgressCheck struct {
	JobFactory cached.JobFactory
	Metrics    *Metrics
	Config     *Config
}

WorkflowProgressCheck checks if workflows are making progress periodically. And emit metrics if any workflow has not been updated within StaleWorkflowThreshold. It is used to catch potential slow workflow and bugs in the system.

func (*WorkflowProgressCheck) Check

func (u *WorkflowProgressCheck) Check()

func (*WorkflowProgressCheck) Register

func (u *WorkflowProgressCheck) Register(manager background.Manager) error