timers

Documentation

Index

• Constants
• func Config(ctx shardscanner.Context) 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

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"
)

Functions

func Config

func Config(ctx shardscanner.Context) 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 concrete execution fixer.

func FixerManager

func FixerManager(
	_ context.Context,
	pr persistence.Retryer,
	_ shardscanner.FixShardActivityParams,
) invariant.Manager

FixerManager provides invariant manager for concrete execution 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,
) 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.