scanner

Documentation

Index

• func CheckDataCorruptionWorkflow(ctx workflow.Context, fixList []entity.Execution) error
• func EmitResultMetricsActivity(ctx context.Context, fixResults []invariant.FixResult) error
• func ExecutionFixerActivity(ctx context.Context, fixList []entity.Execution) ([]invariant.FixResult, error)
• func HistoryScannerWorkflow(ctx workflow.Context) error
• func HistoryScavengerActivity(activityCtx context.Context) (history.ScavengerHeartbeatDetails, error)
• func NewScannerContext(ctx context.Context, workflowName string, scannerContext scannerContext) context.Context
• func TaskListScannerWorkflow(ctx workflow.Context) error
• func TaskListScavengerActivity(activityCtx context.Context) error
• type BootstrapParams
• type Config
• type Scanner
  • func New(resource resource.Resource, params *BootstrapParams) *Scanner
  • func NewDataCorruptionWorkflowWorker(resource resource.Resource, params *BootstrapParams) *Scanner
  • func (s *Scanner) Start() error
  • func (s *Scanner) StartDataCorruptionWorkflowWorker() error

Functions

func CheckDataCorruptionWorkflow

func CheckDataCorruptionWorkflow(ctx workflow.Context, fixList []entity.Execution) error

CheckDataCorruptionWorkflow is invoked by remote cluster via signals

func EmitResultMetricsActivity

func EmitResultMetricsActivity(ctx context.Context, fixResults []invariant.FixResult) error

func ExecutionFixerActivity

func ExecutionFixerActivity(ctx context.Context, fixList []entity.Execution) ([]invariant.FixResult, error)

func HistoryScannerWorkflow

func HistoryScannerWorkflow(
	ctx workflow.Context,
) error

HistoryScannerWorkflow is the workflow that runs the history scanner background daemon

func HistoryScavengerActivity

func HistoryScavengerActivity(
	activityCtx context.Context,
) (history.ScavengerHeartbeatDetails, error)

HistoryScavengerActivity is the activity that runs history scavenger

func NewScannerContext

func NewScannerContext(ctx context.Context, workflowName string, scannerContext scannerContext) context.Context

NewScannerContext provides context to be used as background activity context it uses typed, private key to reduce access scope

func TaskListScannerWorkflow

func TaskListScannerWorkflow(
	ctx workflow.Context,
) error

TaskListScannerWorkflow is the workflow that runs the task-list scanner background daemon

func TaskListScavengerActivity

func TaskListScavengerActivity(
	activityCtx context.Context,
) error

TaskListScavengerActivity is the activity that runs task list scavenger

Types

type BootstrapParams

type BootstrapParams struct {
	// Config contains the configuration for scanner
	Config Config
	// TallyScope is an instance of tally metrics scope
	TallyScope tally.Scope
}

BootstrapParams contains the set of params needed to bootstrap the scanner sub-system

type Config

type Config struct {
	// ScannerPersistenceMaxQPS the max rate of calls to persistence
	// Right now is being used by historyScanner to determine the rate of persistence API calls
	ScannerPersistenceMaxQPS dynamicconfig.IntPropertyFn
	// TaskListScannerEnabled indicates if taskList scanner should be started as part of scanner
	TaskListScannerEnabled dynamicconfig.BoolPropertyFn
	// TaskListScannerOptions contains options for TaskListScanner
	TaskListScannerOptions tasklist.Options
	// Persistence contains the persistence configuration
	Persistence *config.Persistence
	// ClusterMetadata contains the metadata for this cluster
	ClusterMetadata cluster.Metadata
	// HistoryScannerEnabled indicates if history scanner should be started as part of scanner
	HistoryScannerEnabled dynamicconfig.BoolPropertyFn
	// ShardScanners is a list of shard scanner configs
	ShardScanners              []*shardscanner.ScannerConfig
	MaxWorkflowRetentionInDays dynamicconfig.IntPropertyFn
}

Config defines the configuration for scanner

type Scanner

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

Scanner is the background sub-system that does full scans of database tables to cleanup resources, monitor anomalies and emit stats for analytics

func New

func New(
	resource resource.Resource,
	params *BootstrapParams,
) *Scanner

New returns a new instance of scanner daemon Scanner is the background sub-system that does full scans of database tables in an attempt to cleanup resources, monitor system anamolies and emit stats for analysis and alerting

func NewDataCorruptionWorkflowWorker

func NewDataCorruptionWorkflowWorker(
	resource resource.Resource,
	params *BootstrapParams,
) *Scanner

func (*Scanner) Start

func (s *Scanner) Start() error

Start starts the scanner

func (*Scanner) StartDataCorruptionWorkflowWorker

func (s *Scanner) StartDataCorruptionWorkflowWorker() error