Back to

Package scanner

Latest Go to latest
Published: Aug 27, 2019 | License: MIT | Module:


Package Files

func TaskListScannerWorkflow

func TaskListScannerWorkflow(ctx workflow.Context) error

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

func TaskListScavengerActivity

func TaskListScavengerActivity(aCtx context.Context) error

TaskListScavengerActivity is the activity that runs task list scavenger

type BootstrapParams

type BootstrapParams struct {
	// Config contains the configuration for scanner
	Config Config
	// SDKClient is an instance of cadence sdk client
	SDKClient workflowserviceclient.Interface
	// 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

func (*Scanner) Start

func (s *Scanner) Start() error

Start starts the scanner

Documentation was rendered with GOOS=linux and GOARCH=amd64.

Jump to identifier

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to identifier