watchdog

Documentation

Index

• Constants
• type Client
  • func NewClient(logger log.Logger, publicClient workflowserviceclient.Interface) Client
• type Config
• type CorruptWFRequest
• type WatchDog
  • func New(svcClient workflowserviceclient.Interface, frontendClient frontend.Client, ...) *WatchDog
  • func (wd *WatchDog) Start() error
  • func (wd *WatchDog) StartWorkflow(ctx context.Context)
• type Workflow

Constants

const (
	// workflow constants
	WatchdogWFID = "cadence-sys-watchdog"

	// signals
	CorruptWorkflowWatchdogChannelName = "CorruptWorkflowWatchdogChannelName"
)

const (
	SignalTimeout = 400 * time.Millisecond
)

Types

type Client

type Client interface {
	ReportCorruptWorkflow(domainName string, workflowID string, runID string) error
}

Client is used to send request to processor workflow

func NewClient

func NewClient(
	logger log.Logger,
	publicClient workflowserviceclient.Interface,
) Client

NewClient creates a new Client

type Config

type Config struct {
	CorruptWorkflowWatchdogPause dynamicconfig.BoolPropertyFn
}

Config contains all configs for ElasticSearch WatchDog

type CorruptWFRequest

type CorruptWFRequest struct {
	Workflow   types.WorkflowExecution
	DomainName string
}

type WatchDog

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

WatchDog is the background sub-system to maintain the health of a Cadence cluster

func New

func New(
	svcClient workflowserviceclient.Interface,
	frontendClient frontend.Client,
	clientBean client.Bean,
	logger log.Logger,
	metricsClient metrics.Client,
	tallyScope tally.Scope,
	resource resource.Resource,
	domainCache cache.DomainCache,
	config *Config,
) *WatchDog

New returns a new instance as daemon

func (*WatchDog) Start

func (wd *WatchDog) Start() error

Start starts the scanner

func (*WatchDog) StartWorkflow

func (wd *WatchDog) StartWorkflow(ctx context.Context)

type Workflow

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