diagnostics

Documentation

Index

• Constants
• type DiagnosticsStarterWorkflowInput
• type DiagnosticsStarterWorkflowResult
• type DiagnosticsWorkflow
  • func New(params Params) DiagnosticsWorkflow
• type DiagnosticsWorkflowInput
• type DiagnosticsWorkflowResult
• type Params

Constants

const (
	WfDiagnosticsAppName = "workflow-diagnostics"
)

Types

type DiagnosticsStarterWorkflowInput

type DiagnosticsStarterWorkflowInput struct {
	Domain     string
	Identity   string
	WorkflowID string
	RunID      string
}

type DiagnosticsStarterWorkflowResult

type DiagnosticsStarterWorkflowResult struct {
	DiagnosticsResult *DiagnosticsWorkflowResult
}

type DiagnosticsWorkflow

type DiagnosticsWorkflow interface {
	Start() error
	Stop()
}

func New

func New(params Params) DiagnosticsWorkflow

New creates a new diagnostics workflow.

type DiagnosticsWorkflowInput

type DiagnosticsWorkflowInput struct {
	Domain     string
	WorkflowID string
	RunID      string
}

type DiagnosticsWorkflowResult

type DiagnosticsWorkflowResult struct {
	Timeouts *timeoutDiagnostics
	Failures *failureDiagnostics
	Retries  *retryDiagnostics
}

type Params

type Params struct {
	ServiceClient workflowserviceclient.Interface
	ClientBean    client.Bean
	MetricsClient metrics.Client
	Logger        log.Logger
	TallyScope    tally.Scope
	KafkaCfg      config.KafkaConfig
}