keeper

Feb 14, 2023

Changes in this version

type RegistrySynchronizerOptions

+ MailMon *utils.MailboxMonitor

Dec 8, 2022

Changes in this version

type Delegate

+ func (d *Delegate) BeforeJobCreated(spec job.Job)

Nov 3, 2022

Changes in this version

type RegistryVersion

+ const RegistryVersion_2_0

Sep 30, 2022

Changes in this version

+ var Registry1_3ABI = types.MustGetABI(keeper_registry_wrapper1_3.KeeperRegistryABI)

type Config

+ KeeperRegistryMaxPerformDataSize func() uint32

type RegistryGasChecker

+ KeeperRegistryMaxPerformDataSize func() uint32

type RegistrySynchronizerOptions

+ EffectiveKeeperAddress common.Address

type RegistryVersion

+ const RegistryVersion_1_3

type RegistryWrapper

+ func (rw *RegistryWrapper) GetUpkeepIdFromUpkeepPausedLog(broadcast log.Broadcast) (*big.Int, error)

+ func (rw *RegistryWrapper) GetUpkeepIdFromUpkeepUnpausedLog(broadcast log.Broadcast) (*big.Int, error)

+ func (rw *RegistryWrapper) ParseUpkeepCheckDataUpdatedLog(broadcast log.Broadcast) (*UpkeepCheckDataUpdatedLog, error)

+ type UpkeepCheckDataUpdatedLog struct

+ NewCheckData []byte

+ UpkeepID *big.Int

Sep 1, 2022

Changes in this version

+ var ErrContractCallFailure = errors.New("failure in calling contract")

+ type RegistryGasChecker interface

+ KeeperRegistryCheckGasOverhead func() uint32

+ KeeperRegistryPerformGasOverhead func() uint32

type RegistryVersion

+ func (rv RegistryVersion) String() string

+ type UpkeepIdentifier utils.Big

+ func NewUpkeepIdentifier(i *utils.Big) *UpkeepIdentifier

+ func (ui UpkeepIdentifier) String() string

Aug 8, 2022

Changes in this version

+ const UpkeepPrefix

+ const ZeroPrefix

+ func LeastSignificant32(num *big.Int) uint64

+ func ParseUpkeepId(upkeepIdStr string) (*big.Int, bool)

Jul 20, 2022

Changes in this version

+ const ActiveUpkeepIDBatchSize

Jun 27, 2022

Changes in this version

type Config

+ KeySpecificMaxGasPriceWei func(addr gethcommon.Address) *big.Int

Jun 21, 2022

Changes in this version

+ var Registry1_1ABI = evmtypes.MustGetABI(keeper_registry_wrapper1_1.KeeperRegistryABI)

+ var Registry1_2ABI = evmtypes.MustGetABI(keeper_registry_wrapper1_2.KeeperRegistryABI)

type ORM

+ func (korm ORM) AllUpkeepIDsForRegistry(regID int64) (upkeeps []utils.Big, err error)

+ func (korm ORM) UpdateUpkeepLastKeeperIndex(jobID int32, upkeepID *utils.Big, fromAddress ethkey.EIP55Address) error

+ type RegistryConfig struct

+ BlockCountPerTurn int32

+ CheckGas int32

+ KeeperAddresses []common.Address

type RegistrySynchronizer

+ func (rs *RegistrySynchronizer) HandleUpkeepReceived(broadcast log.Broadcast, registry Registry)

type RegistrySynchronizerOptions

+ RegistryWrapper RegistryWrapper

+ type RegistryVersion int32

+ const RegistryVersion_1_0

+ const RegistryVersion_1_1

+ const RegistryVersion_1_2

+ type RegistryWrapper struct

+ Address ethkey.EIP55Address

+ Version RegistryVersion

+ func NewRegistryWrapper(address ethkey.EIP55Address, backend bind.ContractBackend) (*RegistryWrapper, error)

+ func (rw *RegistryWrapper) AddFunds(opts *bind.TransactOpts, id *big.Int, amount *big.Int) (*types.Transaction, error)

+ func (rw *RegistryWrapper) CancelUpkeep(opts *bind.TransactOpts, id *big.Int) (*types.Transaction, error)

+ func (rw *RegistryWrapper) GetActiveUpkeepIDs(opts *bind.CallOpts) ([]*big.Int, error)

+ func (rw *RegistryWrapper) GetCancelledUpkeepIDFromLog(broadcast log.Broadcast) (*big.Int, error)

+ func (rw *RegistryWrapper) GetConfig(opts *bind.CallOpts) (*RegistryConfig, error)

+ func (rw *RegistryWrapper) GetIDFromGasLimitSetLog(broadcast log.Broadcast) (*big.Int, error)

+ func (rw *RegistryWrapper) GetLogListenerOpts(minIncomingConfirmations uint32, upkeepPerformedFilter [][]log.Topic) (*log.ListenerOpts, error)

+ func (rw *RegistryWrapper) GetUpkeep(opts *bind.CallOpts, id *big.Int) (*UpkeepConfig, error)

+ func (rw *RegistryWrapper) GetUpkeepIdFromMigratedLog(broadcast log.Broadcast) (*big.Int, error)

+ func (rw *RegistryWrapper) GetUpkeepIdFromReceivedLog(broadcast log.Broadcast) (*big.Int, error)

+ func (rw *RegistryWrapper) GetUpkeepIdFromRegistrationLog(broadcast log.Broadcast) (*big.Int, error)

+ func (rw *RegistryWrapper) ParseUpkeepPerformedLog(broadcast log.Broadcast) (*UpkeepPerformedLog, error)

+ func (rw *RegistryWrapper) PerformUpkeep(opts *bind.TransactOpts, id *big.Int, performData []byte) (*types.Transaction, error)

+ func (rw *RegistryWrapper) RegisterUpkeep(opts *bind.TransactOpts, target common.Address, gasLimit uint32, ...) (*types.Transaction, error)

+ func (rw *RegistryWrapper) SetKeepers(opts *bind.TransactOpts, keepers []common.Address, payees []common.Address) (*types.Transaction, error)

+ type UpkeepConfig struct

+ CheckData []byte

+ ExecuteGas uint32

+ LastKeeper common.Address

+ type UpkeepPerformedLog struct

+ FromKeeper common.Address

+ UpkeepID *big.Int

type UpkeepRegistration

+ func (upkeep UpkeepRegistration) PrettyID() string

May 2, 2022

Changes in this version

type Config

+ KeeperTurnFlagEnabled func() bool

+ KeeperTurnLookBack func() int64

+ type KeeperIndexMap map[ethkey.EIP55Address]int32

+ func (k *KeeperIndexMap) Scan(val interface{}) error

+ func (k *KeeperIndexMap) Value() (driver.Value, error)

type ORM

+ func (korm ORM) NewEligibleUpkeepsForRegistry(registryAddress ethkey.EIP55Address, blockNumber int64, gracePeriod int64, ...) (upkeeps []UpkeepRegistration, err error)

+ func (korm ORM) RegistryByContractAddress(registryAddress ethkey.EIP55Address) (Registry, error)

+ func (korm ORM) SetLastRunInfoForUpkeepOnJob(jobID int32, upkeepID, height int64, fromAddress ethkey.EIP55Address, ...) error

type Registry

+ KeeperIndexMap KeeperIndexMap

type UpkeepRegistration

+ LastKeeperIndex null.Int64

Apr 18, 2022

Changes in this version

type Config

+ KeeperBaseFeeBufferPercent func() uint32

Jan 25, 2022

Changes in this version

+ const ExpectedObservationSource

type Config

+ EvmEIP1559DynamicFees func() bool

+ KeeperCheckUpkeepGasPriceFeatureEnabled func() bool

+ KeeperGasPriceBufferPercent func() uint32

+ KeeperGasTipCapBufferPercent func() uint32

+ KeeperRegistrySyncUpkeepQueueSize func() uint32

+ LogSQL func() bool

type ORM

+ func (korm ORM) Q() pg.Q

+ type RegistrySynchronizerOptions struct

+ Contract *keeper_registry_wrapper.KeeperRegistry

+ JRM job.ORM

+ Job job.Job

+ LogBroadcaster log.Broadcaster

+ Logger logger.Logger

+ MinIncomingConfirmations uint32

+ ORM ORM

+ SyncInterval time.Duration

+ SyncUpkeepQueueSize uint32

Oct 19, 2021

Changes in this version

type ORM

+ func (korm ORM) WithTransaction(cb func(ctx context.Context) error) error

+ type RevertReason string

+ const CheckTargetFailedReason

+ const InsufficientFundsReason

+ const OutOfTurnReason

+ const PerformUpkeepFailedReason

+ const UpkeepNotNeededReason

+ func (rr RevertReason) IsOneOf(revertReasons ...RevertReason) bool

Aug 9, 2021

Changes in this version

+ type Config interface

+ KeeperDefaultTransactionQueueDepth func() uint32

+ KeeperMaximumGracePeriod func() int64

+ KeeperMinimumRequiredConfirmations func() uint64

+ KeeperRegistryCheckGasOverhead func() uint64

+ KeeperRegistryPerformGasOverhead func() uint64

+ KeeperRegistrySyncInterval func() time.Duration

type Delegate

+ func (Delegate) AfterJobCreated(spec job.Job)

+ func (Delegate) BeforeJobDeleted(spec job.Job)

type RegistrySynchronizer

+ func (rs *RegistrySynchronizer) HandleUpkeepRegistered(broadcast log.Broadcast, registry Registry)

Jun 21, 2021

Changes in this version

type Delegate

+ func (Delegate) OnJobCreated(spec job.Job)

+ func (Delegate) OnJobDeleted(spec job.Job)

type ORM

+ func (korm ORM) EligibleUpkeepsForRegistry(ctx context.Context, registryAddress ethkey.EIP55Address, blockNumber int64, ...) (upkeeps []UpkeepRegistration, _ error)

type UpkeepExecuter

+ func (executer *UpkeepExecuter) Connect(head *models.Head) error

May 10, 2021

Changes in this version

+ type UpkeepExecuter struct

+ func NewUpkeepExecuter(job job.Job, db *gorm.DB, pr pipeline.Runner, ethClient eth.Client, ...) *UpkeepExecuter

+ func (executer *UpkeepExecuter) Close() error

+ func (executer *UpkeepExecuter) OnNewLongestChain(ctx context.Context, head models.Head)

+ func (executer *UpkeepExecuter) Start() error

Apr 26, 2021

Changes in this version

+ func CalcPositioningConstant(upkeepID int64, registryAddress models.EIP55Address) (int32, error)

Apr 12, 2021

Changes in this version

+ type MailRoom struct

type ORM

+ func (korm ORM) BatchDeleteUpkeepsForJob(ctx context.Context, jobID int32, upkeedIDs []int64) error

+ func (korm ORM) RegistryForJob(ctx context.Context, jobID int32) (registry Registry, _ error)

+ func (korm ORM) SetLastRunHeightForUpkeepOnJob(ctx context.Context, jobID int32, upkeepID int64, height int64) error

type RegistrySynchronizer

+ func (rs *RegistrySynchronizer) HandleLog(broadcast log.Broadcast)

+ func (rs *RegistrySynchronizer) IsV2Job() bool

+ func (rs *RegistrySynchronizer) JobID() models.JobID

+ func (rs *RegistrySynchronizer) JobIDV2() int32

+ func (rs *RegistrySynchronizer) OnConnect()

+ func (rs *RegistrySynchronizer) OnDisconnect()

+ func (rs *RegistrySynchronizer) OnNewLongestChain(ctx context.Context, head models.Head)

type UpkeepRegistration

+ LastRunBlockHeight int64

Mar 22, 2021

Changes in this version

+ var RegistryABI = eth.MustGetABI(keeper_registry_wrapper.KeeperRegistryABI)

+ func ValidatedKeeperSpec(tomlString string) (job.Job, error)

+ type Delegate struct

+ func NewDelegate(db *gorm.DB, ethClient eth.Client, headBroadcaster *services.HeadBroadcaster, ...) *Delegate

+ func (d *Delegate) JobType() job.Type

+ func (d *Delegate) ServicesForSpec(spec job.Job) (services []job.Service, err error)

+ type ORM struct

+ DB *gorm.DB

+ func NewORM(db *gorm.DB) ORM

+ func (korm ORM) BatchDeleteUpkeeps(ctx context.Context, registryID int32, upkeedIDs []int64) error

+ func (korm ORM) CreateEthTransactionForUpkeep(ctx context.Context, upkeep UpkeepRegistration, payload []byte) error

+ func (korm ORM) DeleteRegistryByJobID(ctx context.Context, jobID int32) error

+ func (korm ORM) EligibleUpkeeps(ctx context.Context, blockNumber int64) (upkeeps []UpkeepRegistration, _ error)

+ func (korm ORM) LowestUnsyncedID(ctx context.Context, reg Registry) (nextID int64, err error)

+ func (korm ORM) Registries(ctx context.Context) (registries []Registry, _ error)

+ func (korm ORM) UpsertRegistry(ctx context.Context, registry *Registry) error

+ func (korm ORM) UpsertUpkeep(ctx context.Context, registration *UpkeepRegistration) error

+ type Registry struct

+ BlockCountPerTurn int32

+ CheckGas int32

+ ContractAddress models.EIP55Address

+ FromAddress models.EIP55Address

+ ID int32

+ JobID int32

+ KeeperIndex int32

+ NumKeepers int32

+ func NewRegistry(address models.EIP55Address, from models.EIP55Address, jobID int32) Registry

+ func (Registry) TableName() string

+ type RegistrySynchronizer struct

+ func NewRegistrySynchronizer(job job.Job, contract *keeper_registry_wrapper.KeeperRegistry, db *gorm.DB, ...) *RegistrySynchronizer

+ func (rs *RegistrySynchronizer) Close() error

+ func (rs *RegistrySynchronizer) Start() error

+ type UpkeepExecutor struct

+ func NewUpkeepExecutor(job job.Job, db *gorm.DB, ethClient eth.Client, ...) *UpkeepExecutor

+ func (executor *UpkeepExecutor) Close() error

+ func (executor *UpkeepExecutor) OnNewLongestChain(ctx context.Context, head models.Head)

+ func (executor *UpkeepExecutor) Start() error

+ type UpkeepRegistration struct

+ CheckData []byte

+ ExecuteGas int32

+ ID int32

+ PositioningConstant int32

+ Registry Registry

+ RegistryID int32

+ UpkeepID int64