upkeepstate

package
v2.7.1-mercury-20231108 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Nov 8, 2023 License: MIT Imports: 19 Imported by: 0

Documentation

Index

Constants

View Source
const (
	UpkeepStateStoreServiceName = "UpkeepStateStore"
	// CacheExpiration is the amount of time that we keep a record in the cache.
	CacheExpiration = 24 * time.Hour
	// GCInterval is the amount of time between cache cleanups.
	GCInterval = 2 * time.Hour
)

Variables

This section is empty.

Functions

func NewORM added in v2.6.0

func NewORM(chainID *big.Int, db *sqlx.DB, lggr logger.Logger, cfg pg.QConfig) *orm

NewORM creates an ORM scoped to chainID.

func NewPerformedEventsScanner

func NewPerformedEventsScanner(
	lggr logger.Logger,
	poller logpoller.LogPoller,
	registryAddress common.Address,
	finalityDepth uint32,
) *performedEventsScanner

func NewUpkeepStateStore

func NewUpkeepStateStore(orm ORM, lggr logger.Logger, scanner PerformedLogsScanner) *upkeepStateStore

NewUpkeepStateStore creates a new state store

Types

type ORM added in v2.6.0

type ORM interface {
	BatchInsertRecords([]persistedStateRecord, ...pg.QOpt) error
	SelectStatesByWorkIDs([]string, ...pg.QOpt) ([]persistedStateRecord, error)
	DeleteExpired(time.Time, ...pg.QOpt) error
}

type PerformedLogsScanner

type PerformedLogsScanner interface {
	ScanWorkIDs(ctx context.Context, workIDs ...string) ([]string, error)

	Start(context.Context) error
	io.Closer
}

type UpkeepStateStore

type UpkeepStateStore interface {
	ocr2keepers.UpkeepStateUpdater
	core.UpkeepStateReader
	Start(context.Context) error
	io.Closer
}

UpkeepStateStore is the interface for managing upkeeps final state in a local store.

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL