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

	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.