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 TaskListScannerWorkflow(ctx workflow.Context) error
- func TaskListScavengerActivity(activityCtx context.Context) error
- type BootstrapParams
- type Config
- type Scanner
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func ExecutionsScannerWorkflow ¶ added in v0.12.0
func ExecutionsScannerWorkflow( ctx workflow.Context, executionsScannerWorkflowParams executions.ScannerWorkflowParams, ) error
ExecutionsScannerWorkflow is the workflow that runs the executions scanner background daemon
func ExecutionsScavengerActivity ¶ added in v0.12.0
func ExecutionsScavengerActivity( activityCtx context.Context, executionsScannerWorkflowParams executions.ScannerWorkflowParams, ) error
ExecutionsScavengerActivity is the activity that runs executions scavenger
func HistoryScannerWorkflow ¶ added in v0.9.3
HistoryScannerWorkflow is the workflow that runs the history scanner background daemon
func HistoryScavengerActivity ¶ added in v0.9.3
func HistoryScavengerActivity( activityCtx context.Context, ) (history.ScavengerHeartbeatDetails, error)
HistoryScavengerActivity is the activity that runs history scavenger
func TaskListScannerWorkflow ¶
TaskListScannerWorkflow is the workflow that runs the task-list scanner background daemon
func TaskListScavengerActivity ¶
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 {
// PersistenceMaxQPS the max rate of calls to persistence
PersistenceMaxQPS dynamicconfig.IntPropertyFn
// Persistence contains the persistence configuration
Persistence *config.Persistence
// ClusterMetadata contains the metadata for this cluster
ClusterMetadata cluster.Metadata
// TaskListScannerEnabled indicates if taskList scanner should be started as part of scanner
TaskListScannerEnabled 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
}
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( 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
Source Files
Directories