Documentation ¶
Index ¶
- Constants
- func Config(ctx shardscanner.ScannerContext) shardscanner.CustomScannerConfig
- func FixerHooks() *shardscanner.FixerHooks
- func FixerIterator(ctx context.Context, client blobstore.Client, keys store.Keys, ...) store.ScanOutputIterator
- func FixerManager(_ context.Context, pr persistence.Retryer, ...) invariant.Manager
- func FixerWorkflow(ctx workflow.Context, params shardscanner.FixerWorkflowParams) error
- func Iterator(ctx context.Context, pr persistence.Retryer, ...) pagination.Iterator
- func Manager(_ context.Context, pr persistence.Retryer, ...) invariant.Manager
- func ScannerConfig(dc *dynamicconfig.Collection) *shardscanner.ScannerConfig
- func ScannerHooks() *shardscanner.ScannerHooks
- func ScannerWorkflow(ctx workflow.Context, params shardscanner.ScannerWorkflowParams) error
Constants ¶
View Source
const ( // ScannerWFTypeName defines workflow type name for concrete executions scanner ScannerWFTypeName = "cadence-sys-timers-scanner-workflow" // FixerWFTypeName defines workflow type name for timers fixer FixerWFTypeName = "cadence-sys-timers-fixer-workflow" )
Variables ¶
This section is empty.
Functions ¶
func Config ¶
func Config(ctx shardscanner.ScannerContext) shardscanner.CustomScannerConfig
Config resolves dynamic config for timers scanner.
func FixerHooks ¶
func FixerHooks() *shardscanner.FixerHooks
FixerHooks provides hooks needed for timers fixer.
func FixerIterator ¶
func FixerIterator( ctx context.Context, client blobstore.Client, keys store.Keys, _ shardscanner.FixShardActivityParams, ) store.ScanOutputIterator
FixerIterator provides iterator for timers fixer.
func FixerManager ¶
func FixerManager( _ context.Context, pr persistence.Retryer, _ shardscanner.FixShardActivityParams, cache cache.DomainCache, ) invariant.Manager
FixerManager provides invariant manager for timers fixer.
func FixerWorkflow ¶
func FixerWorkflow( ctx workflow.Context, params shardscanner.FixerWorkflowParams, ) error
FixerWorkflow starts timers executions fixer.
func Iterator ¶
func Iterator( ctx context.Context, pr persistence.Retryer, params shardscanner.ScanShardActivityParams, ) pagination.Iterator
Iterator provides iterator for timers scanner.
func Manager ¶
func Manager( _ context.Context, pr persistence.Retryer, _ shardscanner.ScanShardActivityParams, cache cache.DomainCache, ) invariant.Manager
Manager provides invariant manager for timers scanner.
func ScannerConfig ¶
func ScannerConfig(dc *dynamicconfig.Collection) *shardscanner.ScannerConfig
ScannerConfig configures timers scanner
func ScannerHooks ¶
func ScannerHooks() *shardscanner.ScannerHooks
ScannerHooks provides hooks for timers scanner.
func ScannerWorkflow ¶
func ScannerWorkflow( ctx workflow.Context, params shardscanner.ScannerWorkflowParams, ) error
ScannerWorkflow starts timers scanner.
Types ¶
This section is empty.
Click to show internal directories.
Click to hide internal directories.