upkeepstate

Documentation

Index

• Constants
• func NewORM(chainID *big.Int, db *sqlx.DB, lggr logger.Logger, cfg pg.QConfig) *orm
• func NewPerformedEventsScanner(lggr logger.Logger, poller logpoller.LogPoller, registryAddress common.Address, ...) *performedEventsScanner
• func NewUpkeepStateStore(orm ORM, lggr logger.Logger, scanner PerformedLogsScanner) *upkeepStateStore
• type ORM
• type PerformedLogsScanner
• type UpkeepStateStore

Constants

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
)

Functions

func NewORM

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

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.