Versions in this module Expand all Collapse all v0 v0.0.5 Dec 31, 2021 v0.0.4 Nov 21, 2021 v0.0.3 Oct 26, 2021 v0.0.2 Oct 11, 2021 Changes in this version + var RegistryABI = eth.MustGetABI(keeper_registry_wrapper.KeeperRegistryABI) + func CalcPositioningConstant(upkeepID int64, registryAddress ethkey.EIP55Address) (int32, error) + func ValidatedKeeperSpec(tomlString string) (job.Job, error) + type Delegate struct + func NewDelegate(db *gorm.DB, txm transmitter, jrm job.ORM, pr pipeline.Runner, ...) *Delegate + func (Delegate) OnJobCreated(spec job.Job) + func (Delegate) OnJobDeleted(spec job.Job) + func (d *Delegate) JobType() job.Type + func (d *Delegate) ServicesForSpec(spec job.Job) (services []job.Service, err error) + type MailRoom struct + type ORM struct + DB *gorm.DB + func NewORM(db *gorm.DB, txm transmitter, config orm.ConfigReader, ...) ORM + func (korm ORM) BatchDeleteUpkeepsForJob(ctx context.Context, jobID int32, upkeedIDs []int64) (int64, error) + func (korm ORM) CreateEthTransactionForUpkeep(tx *gorm.DB, upkeep UpkeepRegistration, payload []byte) (models.EthTx, error) + func (korm ORM) EligibleUpkeepsForRegistry(ctx context.Context, registryAddress ethkey.EIP55Address, 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) RegistryForJob(ctx context.Context, jobID int32) (registry Registry, _ error) + func (korm ORM) SetLastRunHeightForUpkeepOnJob(db *gorm.DB, jobID int32, upkeepID int64, height int64) 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 ethkey.EIP55Address + FromAddress ethkey.EIP55Address + ID int32 + JobID int32 + KeeperIndex int32 + NumKeepers int32 + func NewRegistry(address ethkey.EIP55Address, from ethkey.EIP55Address, jobID int32) Registry + func (Registry) TableName() string + type RegistrySynchronizer struct + func NewRegistrySynchronizer(job job.Job, contract *keeper_registry_wrapper.KeeperRegistry, orm ORM, ...) *RegistrySynchronizer + func (rs *RegistrySynchronizer) Close() error + 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) Start() error + type UpkeepExecuter struct + func NewUpkeepExecuter(job job.Job, orm ORM, pr pipeline.Runner, ethClient eth.Client, ...) *UpkeepExecuter + func (executer *UpkeepExecuter) Close() error + func (executer *UpkeepExecuter) Connect(head *models.Head) error + func (executer *UpkeepExecuter) OnNewLongestChain(ctx context.Context, head models.Head) + func (executer *UpkeepExecuter) Start() error + type UpkeepRegistration struct + CheckData []byte + ExecuteGas uint64 + ID int32 + LastRunBlockHeight int64 + PositioningConstant int32 + Registry Registry + RegistryID int32 + UpkeepID int64
Go to main page