logprovider

Oct 18, 2023

Changes in this version

+ var LogBackfillBuffer = 100

+ var LogProviderServiceName = "LogEventProvider"

+ var LogRecovererServiceName = "LogRecoverer"

+ var MaxPayloads = 100

+ var MaxProposals = 20

+ var RecoveryInterval = 5 * time.Second

+ type LogTriggersOptions struct

+ BlockLimitBurst int

+ BlockRateLimit rate.Limit

+ FinalityDepth int64

+ LookbackBlocks int64

+ ReadInterval time.Duration

+ func NewOptions(finalityDepth int64) LogTriggersOptions

+ func (o *LogTriggersOptions) Defaults(finalityDepth int64)

Sep 13, 2023

Changes in this version

+ var AllowedLogsPerBlock = 128

+ var AllowedLogsPerUpkeep = 5

+ var BufferMaxBlockSize = 1024

+ var DefaultRecoveryInterval = 5 * time.Second

+ var ErrBlockLimitExceeded = fmt.Errorf("block limit exceeded")

+ var ErrNotFound = errors.New("not found")

+ var GCInterval = time.Hour

+ var LogRetention = 24 * time.Hour

+ var RecoveryCacheTTL = 24*time.Hour - time.Second

+ func NewLogProvider(lggr logger.Logger, poller logpoller.LogPoller, packer LogDataPacker, ...) *logEventProvider

+ func NewLogRecoverer(lggr logger.Logger, poller logpoller.LogPoller, client client.Client, ...) *logRecoverer

+ func NewUpkeepFilterStore() *upkeepFilterStore

+ type FilterOptions struct

+ TriggerConfig LogTriggerConfig

+ UpdateBlock uint64

+ UpkeepID *big.Int

type LogEventProvider

+ RefreshActiveUpkeeps func(ids ...*big.Int) ([]*big.Int, error)

type LogEventProviderOptions

+ LookbackBlocks int64

+ ReadBatchSize int

+ ReorgBuffer int64

type LogEventProviderTest

+ CurrentPartitionIdx func() uint64

+ type LogRecoverer interface

+ GetProposalData func(context.Context, ocr2keepers.CoordinatedBlockProposal) ([]byte, error)

+ Start func(context.Context) error

+ type LogTriggersLifeCycle interface

+ RegisterFilter func(opts FilterOptions) error

+ UnregisterFilter func(upkeepID *big.Int) error

+ type UpkeepFilterStore interface

+ AddActiveUpkeeps func(filters ...upkeepFilter)

+ Get func(id *big.Int) *upkeepFilter

+ GetFilters func(selector func(upkeepFilter) bool) []upkeepFilter

+ GetIDs func(selector func(upkeepFilter) bool) []*big.Int

+ Has func(id *big.Int) bool

+ RangeFiltersByIDs func(iterator func(int, upkeepFilter), ids ...*big.Int)

+ RemoveActiveUpkeeps func(filters ...upkeepFilter)

+ Size func() int

+ UpdateFilters func(updater func(upkeepFilter, upkeepFilter) upkeepFilter, filters ...upkeepFilter)

Aug 21, 2023

Changes in this version

+ const BlockLimitExceeded

+ var ErrHeadNotAvailable = fmt.Errorf("head not available")

+ func New(lggr logger.Logger, poller logpoller.LogPoller, packer LogDataPacker, ...) *logEventProvider

+ func NewLogEventsPacker(utilsABI abi.ABI) *logEventsPacker

+ type LogDataPacker interface

+ PackLogData func(log logpoller.Log) ([]byte, error)

+ type LogEventProvider interface

+ Close func() error

+ GetLogs func(context.Context) ([]ocr2keepers.UpkeepPayload, error)

+ RegisterFilter func(upkeepID *big.Int, cfg LogTriggerConfig) error

+ Start func(ctx context.Context) error

+ UnregisterFilter func(upkeepID *big.Int) error

+ type LogEventProviderOptions struct

+ AllowedLogsPerBlock int

+ BlockLimitBurst int

+ BlockRateLimit rate.Limit

+ BufferMaxBlockSize int

+ LogBlocksLookback int64

+ LogBufferSize int

+ LogRetention time.Duration

+ LookbackBuffer int64

+ ReadInterval time.Duration

+ ReadMaxBatchSize int

+ Readers int

+ func (o *LogEventProviderOptions) Defaults()

+ type LogEventProviderTest interface

+ ReadLogs func(ctx context.Context, force bool, ids ...*big.Int) error

+ type LogTriggerConfig automation_utils_2_1.LogTriggerConfig

+ type LogTriggerExtension struct

+ LogIndex int64

+ TxHash string