Documentation
¶
Index ¶
- func HistoryScannerWorkflow(ctx workflow.Context) error
- func HistoryScavengerActivity(aCtx context.Context) (history.ScavengerHeartbeatDetails, error)
- func TaskListScannerWorkflow(ctx workflow.Context) error
- func TaskListScavengerActivity(aCtx context.Context) error
- type BootstrapParams
- type Config
- type Scanner
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
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(aCtx 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
// SDKClient is an instance of cadence sdk client
SDKClient workflowserviceclient.Interface
// clientBean is an instance of ClientBean
ClientBean client.Bean
// MetricsClient is an instance of metrics object for emitting stats
MetricsClient metrics.Client
Logger log.Logger
// 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
}
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(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