scanner

Documentation

Index

• func ExecutionsScannerWorkflow(ctx workflow.Context) error
• func ExecutionsScavengerActivity(activityCtx context.Context) error
• func HistoryScannerWorkflow(ctx workflow.Context) error
• func HistoryScavengerActivity(activityCtx context.Context) (history.ScavengerHeartbeatDetails, error)
• func TaskQueueScannerWorkflow(ctx workflow.Context) error
• func TaskQueueScavengerActivity(activityCtx context.Context) error
• type Config
• type Scanner
  • func New(logger log.Logger, cfg *Config, sdkSystemClient sdkclient.Client, ...) *Scanner
  • func (s *Scanner) Start() error

Functions

func ExecutionsScannerWorkflow

func ExecutionsScannerWorkflow(
	ctx workflow.Context,
) error

ExecutionsScannerWorkflow is the workflow that runs the executions scanner background daemon

func ExecutionsScavengerActivity

func ExecutionsScavengerActivity(
	activityCtx context.Context,
) error

ExecutionsScavengerActivity is the activity that runs executions scavenger

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 TaskQueueScannerWorkflow

func TaskQueueScannerWorkflow(
	ctx workflow.Context,
) error

TaskQueueScannerWorkflow is the workflow that runs the task queue scanner background daemon

func TaskQueueScavengerActivity

func TaskQueueScavengerActivity(
	activityCtx context.Context,
) error

TaskQueueScavengerActivity is the activity that runs task queue scavenger

Types

type Config

type Config struct {
	MaxConcurrentActivityExecutionSize     dynamicconfig.IntPropertyFn
	MaxConcurrentWorkflowTaskExecutionSize dynamicconfig.IntPropertyFn
	MaxConcurrentActivityTaskPollers       dynamicconfig.IntPropertyFn
	MaxConcurrentWorkflowTaskPollers       dynamicconfig.IntPropertyFn

	// PersistenceMaxQPS the max rate of calls to persistence
	PersistenceMaxQPS dynamicconfig.IntPropertyFn
	// Persistence contains the persistence configuration
	Persistence *config.Persistence
	// TaskQueueScannerEnabled indicates if taskQueue scanner should be started as part of scanner
	TaskQueueScannerEnabled dynamicconfig.BoolPropertyFn
	// HistoryScannerEnabled indicates if history scanner should be started as part of scanner
	HistoryScannerEnabled dynamicconfig.BoolPropertyFn
	// ExecutionsScannerEnabled indicates if executions scanner should be started as part of scanner
	ExecutionsScannerEnabled dynamicconfig.BoolPropertyFn
	// HistoryScannerDataMinAge indicates the cleanup threshold of history branch data
	// Only clean up history branches that older than this threshold
	HistoryScannerDataMinAge dynamicconfig.DurationPropertyFn
}

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 anamolies and emit stats for analytics

func New

func New(
	logger log.Logger,
	cfg *Config,
	sdkSystemClient sdkclient.Client,
	metricsClient metrics.Client,
	executionManager persistence.ExecutionManager,
	taskManager persistence.TaskManager,
	historyClient historyservice.HistoryServiceClient,
) *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 (*Scanner) Start

func (s *Scanner) Start() error

Start starts the scanner