Versions in this module Expand all Collapse all v2 v2.4.0 Nov 13, 2024 v2.3.0 Nov 13, 2024 v2.1.1 Nov 13, 2024 v2.1.0 Nov 11, 2024 Changes in this version + const ActiveUpkeepIDBatchSize + const UpkeepPrefix + const ZeroPrefix + var ErrContractCallFailure = errors.New("failure in calling contract") + var Registry1_1ABI = types.MustGetABI(keeper_registry_wrapper1_1.KeeperRegistryABI) + var Registry1_2ABI = types.MustGetABI(keeper_registry_wrapper1_2.KeeperRegistryABI) + var Registry1_3ABI = types.MustGetABI(keeper_registry_wrapper1_3.KeeperRegistryABI) + func CalcPositioningConstant(upkeepID *big.Big, registryAddress ethkey.EIP55Address) (int32, error) + func LeastSignificant32(num *big.Int) uint64 + func ParseUpkeepId(upkeepIdStr string) (*big.Int, bool) + func ValidatedKeeperSpec(tomlString string) (job.Job, error) + type Delegate struct + func NewDelegate(db *sqlx.DB, jrm job.ORM, pr pipeline.Runner, logger logger.Logger, ...) *Delegate + func (d *Delegate) AfterJobCreated(spec job.Job) + func (d *Delegate) BeforeJobCreated(spec job.Job) + func (d *Delegate) BeforeJobDeleted(spec job.Job) + func (d *Delegate) JobType() job.Type + func (d *Delegate) OnDeleteJob(spec job.Job, q pg.Queryer) error + func (d *Delegate) ServicesForSpec(spec job.Job) (services []job.ServiceCtx, err error) + type KeeperIndexMap map[ethkey.EIP55Address]int32 + func (k *KeeperIndexMap) Scan(val interface{}) error + func (k *KeeperIndexMap) Value() (driver.Value, error) + type ORM struct + func NewORM(db *sqlx.DB, lggr logger.Logger, config pg.QConfig) ORM + func (korm ORM) AllUpkeepIDsForRegistry(regID int64) (upkeeps []big.Big, err error) + func (korm ORM) BatchDeleteUpkeepsForJob(jobID int32, upkeepIDs []big.Big) (int64, error) + func (korm ORM) EligibleUpkeepsForRegistry(registryAddress ethkey.EIP55Address, blockNumber int64, gracePeriod int64, ...) (upkeeps []UpkeepRegistration, err error) + func (korm ORM) Q() pg.Q + func (korm ORM) Registries() ([]Registry, error) + func (korm ORM) RegistryByContractAddress(registryAddress ethkey.EIP55Address) (Registry, error) + func (korm ORM) RegistryForJob(jobID int32) (Registry, error) + func (korm ORM) SetLastRunInfoForUpkeepOnJob(jobID int32, upkeepID *big.Big, height int64, fromAddress ethkey.EIP55Address, ...) (int64, error) + func (korm ORM) UpdateUpkeepLastKeeperIndex(jobID int32, upkeepID *big.Big, fromAddress ethkey.EIP55Address) error + func (korm ORM) UpsertRegistry(registry *Registry) error + func (korm ORM) UpsertUpkeep(registration *UpkeepRegistration) error + type Registry struct + BlockCountPerTurn int32 + CheckGas uint32 + ContractAddress ethkey.EIP55Address + FromAddress ethkey.EIP55Address + ID int64 + JobID int32 + KeeperIndex int32 + KeeperIndexMap KeeperIndexMap + NumKeepers int32 + type RegistryConfig struct + BlockCountPerTurn int32 + CheckGas uint32 + KeeperAddresses []common.Address + type RegistryGasChecker interface + CheckGasOverhead func() uint32 + MaxPerformDataSize func() uint32 + PerformGasOverhead func() uint32 + type RegistrySynchronizer struct + func NewRegistrySynchronizer(opts RegistrySynchronizerOptions) *RegistrySynchronizer + func (rs *RegistrySynchronizer) Close() error + func (rs *RegistrySynchronizer) HandleLog(broadcast log.Broadcast) + func (rs *RegistrySynchronizer) JobID() int32 + func (rs *RegistrySynchronizer) Start(context.Context) error + type RegistrySynchronizerOptions struct + EffectiveKeeperAddress common.Address + JRM job.ORM + Job job.Job + LogBroadcaster log.Broadcaster + Logger logger.Logger + MailMon *mailbox.Monitor + MinIncomingConfirmations uint32 + ORM ORM + RegistryWrapper RegistryWrapper + SyncInterval time.Duration + SyncUpkeepQueueSize uint32 + type RegistryVersion int32 + const RegistryVersion_1_0 + const RegistryVersion_1_1 + const RegistryVersion_1_2 + const RegistryVersion_1_3 + const RegistryVersion_2_0 + const RegistryVersion_2_1 + func (rv RegistryVersion) String() string + type RegistryWrapper struct + Address ethkey.EIP55Address + Version RegistryVersion + func NewRegistryWrapper(address ethkey.EIP55Address, evmClient evmclient.Client) (*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) 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) + 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 UpkeepCheckDataUpdatedLog struct + NewCheckData []byte + UpkeepID *big.Int + type UpkeepConfig struct + CheckData []byte + ExecuteGas uint32 + LastKeeper common.Address + type UpkeepExecuter struct + func NewUpkeepExecuter(job job.Job, orm ORM, pr pipeline.Runner, ethClient evmclient.Client, ...) *UpkeepExecuter + func (ex *UpkeepExecuter) Close() error + func (ex *UpkeepExecuter) OnNewLongestChain(_ context.Context, head *evmtypes.Head) + func (ex *UpkeepExecuter) Start(context.Context) error + type UpkeepExecuterConfig interface + MaxGracePeriod func() int64 + Registry func() config.Registry + TurnLookBack func() int64 + type UpkeepIdentifier big.Big + func NewUpkeepIdentifier(i *big.Big) *UpkeepIdentifier + func (ui UpkeepIdentifier) String() string + type UpkeepPerformedLog struct + FromKeeper common.Address + UpkeepID *big.Int + type UpkeepRegistration struct + CheckData []byte + ExecuteGas uint32 + ID int32 + LastKeeperIndex null.Int64 + LastRunBlockHeight int64 + PositioningConstant int32 + Registry Registry + RegistryID int64 + UpkeepID *big.Big + func (upkeep UpkeepRegistration) PrettyID() string
Go to main page