upkeepstate

Documentation

Index

• Variables
• func NewPerformedEventsScanner(lggr logger.Logger, poller logpoller.LogPoller, registryAddress common.Address) *performedEventsScanner
• func NewUpkeepStateStore(lggr logger.Logger, scanner PerformedLogsScanner) *upkeepStateStore
• type PerformedLogsScanner
• type UpkeepStateReader
• type UpkeepStateStore

Variables

var (
	// 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 NewPerformedEventsScanner

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

func NewUpkeepStateStore

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

NewUpkeepStateStore creates a new state store

Types

type PerformedLogsScanner

type PerformedLogsScanner interface {
	WorkIDsInRange(ctx context.Context, start, end int64) ([]string, error)
}

type UpkeepStateReader

type UpkeepStateReader interface {
	SelectByWorkIDsInRange(ctx context.Context, start, end int64, workIDs ...string) ([]ocr2keepers.UpkeepState, error)
}

UpkeepStateReader is the interface for reading the current state of upkeeps.

type UpkeepStateStore

type UpkeepStateStore interface {
	ocr2keepers.UpkeepStateUpdater
	UpkeepStateReader
}

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