orm

package

Go to main page

Versions in this module

v1

v1.0.1

Nov 23, 2021

v1.0.0

Oct 19, 2021

v0

v0.10.16-rc1

May 4, 2022

v0.10.16-rc0

Mar 18, 2022

v0.10.15

Oct 14, 2021

v0.10.14

Sep 7, 2021

v0.10.13

Aug 25, 2021

v0.10.12

Aug 16, 2021

v0.10.11

Aug 9, 2021

Changes in this version

+ func NewOrmLogWrapper(logger *logger.Logger, logAllQueries bool, slowThreshold time.Duration) *ormLogWrapper

type ConfigReader

+ TLSDir func() string

type ORM

+ func (orm *ORM) ExternalInitiatorsSorted(offset int, limit int) ([]models.ExternalInitiator, int, error)

v0.10.10

Jul 26, 2021

Changes in this version

type Config

+ func (c Config) BlockHistoryEstimatorBatchSize() (size uint32)

+ func (c Config) BlockHistoryEstimatorBlockDelay() uint16

+ func (c Config) BlockHistoryEstimatorBlockHistorySize() uint16

+ func (c Config) BlockHistoryEstimatorTransactionPercentile() uint16

+ func (c Config) GasEstimatorMode() string

+ func (c Config) P2PNetworkingStack() (n ocrnetworking.NetworkingStack)

+ func (c Config) P2PNetworkingStackRaw() string

+ func (c Config) P2PV2AnnounceAddresses() []string

+ func (c Config) P2PV2AnnounceAddressesRaw() []string

+ func (c Config) P2PV2Bootstrappers() (locators []ocrtypes.BootstrapperLocator)

+ func (c Config) P2PV2BootstrappersRaw() []string

+ func (c Config) P2PV2DeltaDial() models.Duration

+ func (c Config) P2PV2DeltaReconcile() models.Duration

+ func (c Config) P2PV2ListenAddresses() []string

type ConfigReader

+ BlockHistoryEstimatorBlockDelay func() uint16

+ BlockHistoryEstimatorBlockHistorySize func() uint16

+ BlockHistoryEstimatorTransactionPercentile func() uint16

type ConfigSchema

+ BlockHistoryEstimatorBatchSize uint32

+ BlockHistoryEstimatorBlockDelay uint16

+ BlockHistoryEstimatorBlockHistorySize uint16

+ BlockHistoryEstimatorTransactionPercentile uint16

+ GasEstimatorMode string

+ P2PNetworkingStack ocrnetworking.NetworkingStack

+ P2PV2AnnounceAddresses []string

+ P2PV2Bootstrappers []string

+ P2PV2DeltaDial models.Duration

+ P2PV2DeltaReconcile models.Duration

+ P2PV2ListenAddresses []string

v0.10.9

Jul 6, 2021

Changes in this version

type Config

+ func (c Config) Chain() *chains.Chain

+ func (c Config) FMDefaultTransactionQueueDepth() uint32

+ func (c Config) KeeperDefaultTransactionQueueDepth() uint32

+ func (c Config) KeeperRegistryCheckGasOverhead() uint64

+ func (c Config) KeeperRegistryPerformGasOverhead() uint64

+ func (c Config) OCRDefaultTransactionQueueDepth() uint32

type ConfigReader

+ KeeperDefaultTransactionQueueDepth func() uint32

+ KeeperMaximumGracePeriod func() int64

+ KeeperMinimumRequiredConfirmations func() uint64

+ KeeperRegistryCheckGasOverhead func() uint64

+ KeeperRegistryPerformGasOverhead func() uint64

+ KeeperRegistrySyncInterval func() time.Duration

type ConfigSchema

+ FMDefaultTransactionQueueDepth uint32

+ KeeperDefaultTransactionQueueDepth uint32

+ KeeperRegistryCheckGasOverhead uint64

+ KeeperRegistryPerformGasOverhead uint64

+ OCRDefaultTransactionQueueDepth uint32

v0.10.8

Jun 21, 2021

Changes in this version

+ func BulkDeleteRuns(db *gorm.DB, bulkQuery *models.BulkDeleteRunRequest) error

type ChainSpecificDefaultSet

+ EthGasLimitDefault uint64

+ EthGasLimitTransfer uint64

+ EthMaxInFlightTransactions uint32

+ EthMaxQueuedTransactions uint64

+ LinkContractAddress string

+ MinimumContractPayment *assets.Link

type Config

+ func (c Config) DatabaseBackupDir() string

+ func (c Config) EthGasLimitTransfer() uint64

+ func (c Config) EthMaxInFlightTransactions() uint32

+ func (c Config) EthMaxQueuedTransactions() uint64

+ func (c Config) FeatureWebhookV2() bool

+ func (c Config) InsecureSkipVerify() bool

type ConfigReader

+ InsecureSkipVerify func() bool

type ConfigSchema

+ DatabaseBackupDir string

+ EthGasLimitTransfer uint64

+ EthMaxInFlightTransactions uint64

+ EthMaxQueuedTransactions uint64

+ FeatureWebhookV2 bool

+ InsecureSkipVerify bool

v0.10.7

May 24, 2021

Changes in this version

+ type BatchFunc func(offset, limit uint) (count uint, err error)

type ChainSpecificDefaultSet

+ EnableLegacyJobPipeline bool

+ EthHeadTrackerSamplingInterval time.Duration

+ EthMinGasPriceWei big.Int

type Config

+ func (c Config) EnableLegacyJobPipeline() bool

+ func (c Config) EthGasLimitMultiplier() float32

+ func (c Config) EthHeadTrackerSamplingInterval() time.Duration

+ func (c Config) EthMinGasPriceWei() *big.Int

+ func (c Config) EthTxReaperInterval() time.Duration

+ func (c Config) EthTxReaperThreshold() time.Duration

+ func (c Config) P2PListenPortRaw() string

type ConfigReader

+ EthGasLimitMultiplier func() float32

+ EthTxReaperInterval func() time.Duration

+ EthTxReaperThreshold func() time.Duration

type ConfigSchema

+ EnableLegacyJobPipeline bool

+ EthGasLimitMultiplier float32

+ EthHeadTrackerSamplingInterval time.Duration

+ EthMinGasPriceWei big.Int

+ EthTxReaperInterval time.Duration

+ EthTxReaperThreshold time.Duration

v0.10.6

May 10, 2021

Changes in this version

type ChainSpecificDefaultSet

+ GasUpdaterEnabled bool

+ OptimismGasFees bool

type Config

+ func (c Config) EthereumHTTPURL() (uri *url.URL)

+ func (c Config) OptimismGasFees() bool

+ func (c Config) P2PPeerIDRaw() string

type ConfigReader

+ OptimismGasFees func() bool

type ConfigSchema

+ EthereumHTTPURL string

+ OptimismGasFees bool

v0.10.5

Apr 26, 2021

Changes in this version

+ var ChainSpecificDefaults map[int64]ChainSpecificDefaultSet

+ var GeneralDefaults ChainSpecificDefaultSet

+ type ChainSpecificDefaultSet struct

+ EthBalanceMonitorBlockDelay uint16

+ EthFinalityDepth uint

+ EthGasBumpThreshold uint64

+ EthGasBumpWei *big.Int

+ EthGasPriceDefault *big.Int

+ EthHeadTrackerHistoryDepth uint

+ EthMaxGasPriceWei *big.Int

+ EthTxResendAfterThreshold time.Duration

+ GasUpdaterBatchSize *uint32

+ GasUpdaterBlockDelay uint16

+ GasUpdaterBlockHistorySize uint16

+ HeadTimeBudget time.Duration

+ MinIncomingConfirmations uint32

+ MinRequiredOutgoingConfirmations uint64

type Config

+ func (c Config) FeatureCronV2() bool

+ func (c Config) GasUpdaterBatchSize() uint32

type ConfigSchema

+ FeatureCronV2 bool

+ GasUpdaterBatchSize uint32

type ORM

+ func (orm *ORM) JobRunsCountForGivenStatus(jobSpecID models.JobID, status string) (int, error)

v0.10.4

Apr 12, 2021

Changes in this version

type Config

+ func (c Config) DatabaseBackupFrequency() time.Duration

+ func (c Config) DatabaseBackupMode() DatabaseBackupMode

+ func (c Config) DatabaseBackupURL() *url.URL

+ func (c Config) EthLogBackfillBatchSize() uint32

+ func (c Config) EthNonceAutoSync() bool

+ func (c Config) EthRPCDefaultBatchSize() uint32

+ func (c Config) EthTxResendAfterThreshold() time.Duration

+ func (c Config) HeadTimeBudget() time.Duration

+ func (c Config) KeeperMaximumGracePeriod() int64

+ func (c Config) KeeperMinimumRequiredConfirmations() uint64

+ func (c Config) SetLogLevel(ctx context.Context, value string) error

+ func (c Config) SetLogSQLStatements(ctx context.Context, sqlEnabled bool) error

+ func (c Config) StatsPusherLogging() bool

type ConfigReader

+ EthLogBackfillBatchSize func() uint32

+ EthNonceAutoSync func() bool

+ EthRPCDefaultBatchSize func() uint32

+ EthTxResendAfterThreshold func() time.Duration

type ConfigSchema

+ DatabaseBackupFrequency time.Duration

+ DatabaseBackupMode string

+ DatabaseBackupURL *url.URL

+ EthLogBackfillBatchSize uint32

+ EthNonceAutoSync bool

+ EthRPCDefaultBatchSize uint32

+ EthTxResendAfterThreshold time.Duration

+ HeadTimeBudget time.Duration

+ KeeperMaximumGracePeriod int64

+ KeeperMinimumRequiredConfirmations uint64

+ StatsPusherLogging string

+ type DatabaseBackupMode string

+ var DatabaseBackupModeFull DatabaseBackupMode = "full"

+ var DatabaseBackupModeLite DatabaseBackupMode = "lite"

+ var DatabaseBackupModeNone DatabaseBackupMode = "none"

type ORM

+ func (orm *ORM) FindLatestNodeVersion() (*models.NodeVersion, error)

+ func (orm *ORM) GetConfigBoolValue(field string) (*bool, error)

+ func (orm *ORM) SetConfigStrValue(ctx context.Context, field string, value string) error

+ func (orm *ORM) UpsertNodeVersion(version models.NodeVersion) error

v0.10.3

Mar 22, 2021

Changes in this version

type Config

+ func (c Config) AdminCredentialsFile() string

+ func (c Config) EthMaxUnconfirmedTransactions() uint64

+ func (c Config) FeatureFluxMonitorV2() bool

+ func (c Config) JobPipelineResultWriteQueueDepth() uint64

+ func (c Config) KeeperRegistrySyncInterval() time.Duration

+ func (c Config) OCRObservationGracePeriod() time.Duration

type ConfigSchema

+ AdminCredentialsFile string

+ EthMaxUnconfirmedTransactions uint64

+ FeatureFluxMonitorV2 bool

+ JobPipelineResultWriteQueueDepth uint64

+ KeeperRegistrySyncInterval time.Duration

+ OCRObservationGracePeriod time.Duration

type ORM

+ func (orm *ORM) FindJobIDsWithBridge(bridgeName string) ([]models.JobID, error)

+ func (orm *ORM) RawDBWithAdvisoryLock(fn func(*gorm.DB) error) error

v0.10.2

Mar 8, 2021

v0.10.1

Feb 25, 2021

v0.10.0

Feb 24, 2021

Changes in this version

type Config

+ func (c Config) EthReceiptFetchBatchSize() uint32

+ func (c Config) HTTPServerWriteTimeout() time.Duration

type ConfigReader

+ EthReceiptFetchBatchSize func() uint32

type ConfigSchema

+ EthReceiptFetchBatchSize uint32

+ HTTPServerWriteTimeout time.Duration

type ORM

+ func (orm *ORM) FindJobRunIncludingArchived(id uuid.UUID) (jr models.JobRun, err error)

+ func (orm *ORM) FindJobSpecUnscoped(id models.JobID) (job models.JobSpec, err error)

+ func (orm *ORM) MustSQLDB() *sql.DB

v0.9.10

Feb 1, 2021

Changes in this version

type Config

+ func (c Config) JobPipelineMaxRunDuration() time.Duration

type ConfigSchema

+ JobPipelineMaxRunDuration time.Duration

v0.9.9

Jan 18, 2021

Changes in this version

type Config

+ func (c Config) AuthenticatedRateLimit() int64

+ func (c Config) AuthenticatedRateLimitPeriod() models.Duration

+ func (c Config) GlobalLockRetryInterval() models.Duration

+ func (c Config) ORMMaxIdleConns() int

+ func (c Config) ORMMaxOpenConns() int

+ func (c Config) P2PPeerIDIsSet() bool

+ func (c Config) UnAuthenticatedRateLimit() int64

+ func (c Config) UnAuthenticatedRateLimitPeriod() models.Duration

type ConfigSchema

+ AuthenticatedRateLimit int64

+ AuthenticatedRateLimitPeriod time.Duration

+ GlobalLockRetryInterval models.Duration

+ ORMMaxIdleConns int

+ ORMMaxOpenConns int

+ UnAuthenticatedRateLimit int64

+ UnAuthenticatedRateLimitPeriod time.Duration

v0.9.8

Dec 16, 2020

v0.9.7

Dec 14, 2020

Changes in this version

+ var ErrInvalid = errors.New("env var invalid")

+ var ErrUnset = errors.New("env var unset")

type Config

+ func (c Config) OCRBlockchainTimeout(override time.Duration) time.Duration

+ func (c Config) OCRContractConfirmations(override uint16) uint16

+ func (c Config) OCRContractPollInterval(override time.Duration) time.Duration

+ func (c Config) OCRContractSubscribeInterval(override time.Duration) time.Duration

+ func (c Config) OCRKeyBundleID(override *models.Sha256Hash) (models.Sha256Hash, error)

+ func (c Config) OCRMonitoringEndpoint(override string) string

+ func (c Config) OCRObservationTimeout(override time.Duration) time.Duration

+ func (c Config) OCRTransmitterAddress(override *models.EIP55Address) (models.EIP55Address, error)

+ func (c Config) P2PBootstrapPeers(override []string) ([]string, error)

+ func (c Config) P2PDHTAnnouncementCounterUserPrefix() uint32

+ func (c Config) P2PPeerID(override models.PeerID) (models.PeerID, error)

type ConfigSchema

+ OCRBlockchainTimeout time.Duration

+ OCRContractConfirmations uint

+ OCRContractPollInterval time.Duration

+ OCRContractSubscribeInterval time.Duration

+ OCRKeyBundleID string

+ OCRMonitoringEndpoint string

+ OCRObservationTimeout time.Duration

+ OCRTransmitterAddress string

+ P2PBootstrapPeers []string

+ P2PDHTAnnouncementCounterUserPrefix uint32

+ P2PPeerID models.PeerID

type ORM

+ func (orm *ORM) FindJobSpec(id *models.ID) (models.JobSpec, error)

+ func (orm *ORM) JobsV2() ([]models.JobSpecV2, error)

+ func (orm *ORM) PipelineRunsByJobID(jobID int32, offset, size int) ([]pipeline.Run, int, error)

v0.9.6

Nov 23, 2020

Changes in this version

type Config

+ func (c Config) EthereumSecondaryURLs() []url.URL

+ func (c Config) P2PAnnounceIP() net.IP

+ func (c Config) P2PAnnouncePort() uint16

+ func (c Config) P2PListenIP() net.IP

+ func (c Config) P2PListenPort() uint16

+ func (c Config) P2PPeerstoreWriteInterval() time.Duration

+ func (c Config) TriggerFallbackDBPollInterval() time.Duration

type ConfigReader

+ EthereumSecondaryURLs func() []url.URL

+ TriggerFallbackDBPollInterval func() time.Duration

type ConfigSchema

+ EthereumSecondaryURLs string

+ P2PAnnounceIP net.IP

+ P2PAnnouncePort uint16

+ P2PListenIP net.IP

+ P2PListenPort uint16

+ P2PPeerstoreWriteInterval time.Duration

+ TriggerFallbackDBPollInterval time.Duration

type ORM

+ func (orm *ORM) EthTransactionsWithAttempts(offset, limit int) ([]models.EthTx, int, error)

+ func (orm *ORM) EthTxAttempts(offset, limit int) ([]models.EthTxAttempt, int, error)

+ func (orm *ORM) FindEthTxAttempt(hash common.Hash) (*models.EthTxAttempt, error)

+ func (orm *ORM) FindOffChainReportingJob(id int32) (models.JobSpecV2, error)

+ func (orm *ORM) OffChainReportingJobRuns(jobID int32, offset, size int) ([]pipeline.Run, int, error)

+ func (orm *ORM) OffChainReportingJobs() ([]models.JobSpecV2, error)

v0.9.5

Nov 12, 2020

v0.9.4

Nov 4, 2020

v0.9.3

Nov 2, 2020

Changes in this version

type Config

+ func (c Config) BalanceMonitorEnabled() bool

+ func (c Config) DatabaseListenerMaxReconnectDuration() time.Duration

+ func (c Config) DatabaseListenerMinReconnectInterval() time.Duration

+ func (c Config) DatabaseMaximumTxDuration() time.Duration

+ func (c Config) DefaultHTTPAllowUnrestrictedNetworkAccess() bool

+ func (c Config) FeatureOffchainReporting() bool

+ func (c Config) InsecureFastScrypt() bool

+ func (c Config) JobPipelineDBPollInterval() time.Duration

+ func (c Config) JobPipelineMaxTaskDuration() time.Duration

+ func (c Config) JobPipelineParallelism() uint8

+ func (c Config) JobPipelineReaperInterval() time.Duration

+ func (c Config) JobPipelineReaperThreshold() time.Duration

+ func (c Config) OCRBootstrapCheckInterval() time.Duration

+ func (c Config) OCRContractTransmitterTransmitTimeout() time.Duration

+ func (c Config) OCRDHTLookupInterval() int

+ func (c Config) OCRDatabaseTimeout() time.Duration

+ func (c Config) OCRIncomingMessageBufferSize() int

+ func (c Config) OCRListenIP() net.IP

+ func (c Config) OCRListenPort() uint16

+ func (c Config) OCRNewStreamTimeout() time.Duration

+ func (c Config) OCROutgoingMessageBufferSize() int

+ func (c Config) OCRTraceLogging() bool

type ConfigReader

+ DatabaseMaximumTxDuration func() time.Duration

+ DefaultHTTPAllowUnrestrictedNetworkAccess func() bool

+ FeatureOffchainReporting func() bool

+ OCRTraceLogging func() bool

type ConfigSchema

+ BalanceMonitorEnabled bool

+ DatabaseListenerMaxReconnectDuration time.Duration

+ DatabaseListenerMinReconnectInterval time.Duration

+ DatabaseMaximumTxDuration time.Duration

+ DefaultHTTPAllowUnrestrictedNetworkAccess bool

+ FeatureOffchainReporting bool

+ InsecureFastScrypt bool

+ JobPipelineDBPollInterval time.Duration

+ JobPipelineMaxTaskDuration time.Duration

+ JobPipelineParallelism uint8

+ JobPipelineReaperInterval time.Duration

+ JobPipelineReaperThreshold time.Duration

+ OCRBootstrapCheckInterval time.Duration

+ OCRContractTransmitterTransmitTimeout time.Duration

+ OCRDHTLookupInterval int

+ OCRDatabaseTimeout time.Duration

+ OCRIncomingMessageBufferSize int

+ OCRListenIP net.IP

+ OCRListenPort uint16

+ OCRNewStreamTimeout time.Duration

+ OCROutgoingMessageBufferSize int

+ OCRTraceLogging bool

type ORM

+ func (orm *ORM) ArchiveEncryptedSecretVRFKey(k *vrfkey.EncryptedVRFKey) error

+ func (orm *ORM) ArchiveKey(address []byte) error

+ func (orm *ORM) HasConsumedLogV2(blockHash common.Hash, logIndex uint, jobID int32) (bool, error)

+ func (orm *ORM) MarkLogConsumedV2(blockHash common.Hash, logIndex uint, jobID int32, blockNumber uint64) error

+ func (orm *ORM) RemoveUnstartedTransactions() error

v0.9.2

Oct 15, 2020

v0.9.0

Oct 12, 2020

Changes in this version

type Config

+ func (c Config) FlagsContractAddress() string

+ func (c Config) OperatorContractAddress() common.Address

type ConfigReader

+ OperatorContractAddress func() common.Address

type ConfigSchema

+ FlagsContractAddress string

+ OperatorContractAddress common.Address

type ORM

+ func (orm *ORM) AllKeys() ([]models.Key, error)

+ func (orm *ORM) DeleteEncryptedP2PKey(key *p2pkey.EncryptedP2PKey) error

+ func (orm *ORM) FindEncryptedP2PKeyByID(id int32) (*p2pkey.EncryptedP2PKey, error)

+ func (orm *ORM) SendKeys() ([]models.Key, error)

v0.8.18

Oct 1, 2020

v0.8.17

Sep 28, 2020

Changes in this version

type Config

+ func (c Config) EthereumSecondaryURL() string

type ConfigReader

+ EthereumSecondaryURL func() string

type ConfigSchema

+ EthereumSecondaryURL string

type ORM

+ func (orm *ORM) CreateEncryptedOCRKeyBundle(keys *ocrkey.EncryptedKeyBundle) error

+ func (orm *ORM) DeleteEncryptedOCRKeyBundle(key *ocrkey.EncryptedKeyBundle) (err error)

+ func (orm *ORM) FindEncryptedOCRKeyBundleByID(id string) (*ocrkey.EncryptedKeyBundle, error)

+ func (orm *ORM) FindEncryptedOCRKeyBundles() (keys []ocrkey.EncryptedKeyBundle, err error)

v0.8.16

Sep 22, 2020

Changes in this version

type Config

+ func (c Config) EthGasBumpTxDepth() uint64

type ConfigReader

+ EthGasBumpTxDepth func() uint64

type ConfigSchema

+ EthGasBumpTxDepth uint16

v0.8.15

Sep 15, 2020

Changes in this version

type Config

+ func (c Config) EthHeadTrackerMaxBufferSize() uint

type ConfigReader

+ EthHeadTrackerMaxBufferSize func() uint

type ConfigSchema

+ EthHeadTrackerMaxBufferSize uint

v0.8.14

Sep 2, 2020

v0.8.13

Aug 26, 2020

Changes in this version

type ORM

+ func (orm *ORM) MarkLogConsumed(blockHash common.Hash, logIndex uint, jobID *models.ID) error

+ func (orm *ORM) UpdateFluxMonitorRoundStats(aggregator common.Address, roundID uint32, jobRunID *models.ID) error

v0.8.12

Aug 10, 2020

Changes in this version

type Config

+ func (c Config) EthBalanceMonitorBlockDelay() uint16

type ConfigReader

+ EthBalanceMonitorBlockDelay func() uint16

type ConfigSchema

+ EthBalanceMonitorBlockDelay uint16

type ORM

+ func (orm *ORM) CreateKeyIfNotExists(k models.Key) error

+ func (orm *ORM) FindEncryptedP2PKeys() (keys []p2pkey.EncryptedP2PKey, err error)

+ func (orm *ORM) UpsertEncryptedP2PKey(k *p2pkey.EncryptedP2PKey) error

v0.8.11

Jul 27, 2020

Changes in this version

type ORM

+ func (orm *ORM) GetRoundRobinAddress(addresses ...common.Address) (address common.Address, err error)

+ func (orm *ORM) KeyByAddress(address common.Address) (models.Key, error)

v0.8.10

Jul 14, 2020

v0.8.9

Jul 13, 2020

Changes in this version

type ORM

+ func (orm *ORM) DeleteJobSpecError(ID int64) error

+ func (orm *ORM) FindJobSpecError(jobID *models.ID, description string) (*models.JobSpecError, error)

+ func (orm *ORM) FindJobWithErrors(id *models.ID) (models.JobSpec, error)

+ func (orm *ORM) UpsertErrorFor(jobID *models.ID, description string)

+ func (orm *ORM) UpsertKey(k models.Key) error

v0.8.8

Jun 29, 2020

Changes in this version

type Config

+ func (c Config) MinRequiredOutgoingConfirmations() uint64

type ConfigReader

+ MinRequiredOutgoingConfirmations func() uint64

type ConfigSchema

+ MinRequiredOutgoingConfirmations uint64

type ORM

+ func (orm *ORM) HeadByHash(hash common.Hash) (*models.Head, error)

v0.8.7

Jun 15, 2020

Changes in this version

type Config

+ func (c Config) EnableBulletproofTxManager() bool

+ func (c Config) EthFinalityDepth() uint

+ func (c Config) EthHeadTrackerHistoryDepth() uint

type ConfigReader

+ EnableBulletproofTxManager func() bool

+ EthFinalityDepth func() uint

+ EthHeadTrackerHistoryDepth func() uint

type ConfigSchema

+ EnableBulletproofTxManager bool

+ EthFinalityDepth uint

+ EthHeadTrackerHistoryDepth uint

type ORM

+ func (orm *ORM) DeleteFluxMonitorRoundsBackThrough(aggregator common.Address, roundID uint32) error

+ func (orm *ORM) FindEthTaskRunTxByTaskRunID(taskRunID uuid.UUID) (*models.EthTaskRunTx, error)

+ func (orm *ORM) FindEthTxWithAttempts(etxID int64) (models.EthTx, error)

+ func (orm *ORM) FindOrCreateFluxMonitorRoundStats(aggregator common.Address, roundID uint32) (models.FluxMonitorRoundStats, error)

+ func (orm *ORM) GetDefaultAddress() (common.Address, error)

+ func (orm *ORM) IdempotentInsertEthTaskRunTx(taskRunID models.ID, fromAddress common.Address, toAddress common.Address, ...) error

+ func (orm *ORM) KeyExists(address []byte) (bool, error)

+ func (orm *ORM) MostRecentFluxMonitorRoundID(aggregator common.Address) (uint32, error)

+ func (orm *ORM) Transaction(fc func(tx *gorm.DB) error) (err error)

v0.8.6

Jun 11, 2020

Changes in this version

type ORM

+ func (orm *ORM) FindFluxMonitorRoundStats(aggregator common.Address, roundID uint32) (models.FluxMonitorRoundStats, error)

+ func (orm *ORM) IncrFluxMonitorNewRoundLogs(aggregator common.Address, roundID uint32) error

+ func (orm *ORM) IncrFluxMonitorRoundSubmissions(aggregator common.Address, roundID uint32) error

v0.8.5

Jun 1, 2020

Changes in this version

+ var ErrOptimisticUpdateConflict = errors.New("conflict while updating record")

type Config

+ func (c Config) BlockBackfillDepth() uint64

type ConfigReader

+ BlockBackfillDepth func() uint64

type ConfigSchema

+ BlockBackfillDepth string

+ type Connection struct

+ func NewConnection(dialect DialectName, uri string, advisoryLockID int64) (Connection, error)

type DialectName

+ const DialectPostgresWithoutLock

type ORM

+ func (orm *ORM) Chain(hash common.Hash, lookback uint) (*models.Head, error)

+ func (orm *ORM) GetRawDB() *gorm.DB

+ func (orm *ORM) IdempotentInsertHead(h models.Head) error

+ func (orm *ORM) TrimOldHeads(n int) (err error)

v0.8.4

May 18, 2020

Changes in this version

type Config

+ AdvisoryLockID int64

+ Dialect DialectName

+ func (c Config) GetAdvisoryLockIDConfiguredOrDefault() int64

+ func (c Config) GetDatabaseDialectConfiguredOrDefault() DialectName

+ func (c Config) MigrateDatabase() bool

type ConfigReader

+ MigrateDatabase func() bool

type ConfigSchema

+ MigrateDatabase bool

type DialectName

+ const DialectTransactionWrappedPostgres

type ORM

+ func (orm *ORM) DeleteKey(address []byte) error

v0.8.3

May 4, 2020

Changes in this version

type Config

+ func (c Config) EthereumDisabled() bool

type ConfigSchema

+ EthereumDisabled bool

type ORM

+ func (orm *ORM) CreateLogConsumption(lc *models.LogConsumption) error

+ func (orm *ORM) FindLogConsumer(lc *models.LogConsumption) (models.JobSpec, error)

+ func (orm *ORM) HasConsumedLog(rawLog eth.RawLog, JobID *models.ID) (bool, error)

+ func (orm *ORM) LogConsumptionExists(lc *models.LogConsumption) (bool, error)

v0.8.2

Apr 20, 2020

Changes in this version

+ const BatchSize

+ var ErrNoAdvisoryLock = errors.New("can't acquire advisory lock")

+ var ErrReleaseLockFailed = errors.New("advisory lock release failed")

+ var ErrorConflict = errors.New("record already exists")

+ var OptimisticUpdateConflictError = errors.New("conflict while updating record")

type Config

+ func (c *Config) Validate() error

+ func (c Config) DefaultHTTPTimeout() time.Duration

+ func (c Config) DefaultMaxHTTPAttempts() uint

+ func (c Config) EnableExperimentalAdapters() bool

+ func (c Config) EthGasBumpPercent() uint16

+ func (c Config) EthGasLimitDefault() uint64

+ func (c Config) EthMaxGasPriceWei() *big.Int

+ func (c Config) FeatureExternalInitiators() bool

+ func (c Config) FeatureFluxMonitor() bool

+ func (c Config) GasUpdaterBlockDelay() uint16

+ func (c Config) GasUpdaterBlockHistorySize() uint16

+ func (c Config) GasUpdaterEnabled() bool

+ func (c Config) GasUpdaterTransactionPercentile() uint16

type ConfigReader

+ DefaultHTTPTimeout func() time.Duration

+ DefaultMaxHTTPAttempts func() uint

+ EnableExperimentalAdapters func() bool

+ EthGasBumpPercent func() uint16

+ EthGasLimitDefault func() uint64

+ EthMaxGasPriceWei func() *big.Int

+ FeatureExternalInitiators func() bool

+ FeatureFluxMonitor func() bool

+ GasUpdaterBlockDelay func() uint16

+ GasUpdaterBlockHistorySize func() uint16

+ GasUpdaterTransactionPercentile func() uint16

type ConfigSchema

+ DefaultHTTPTimeout time.Duration

+ DefaultMaxHTTPAttempts uint

+ EnableExperimentalAdapters bool

+ EthGasBumpPercent uint16

+ EthGasLimitDefault uint64

+ EthMaxGasPriceWei uint64

+ FeatureExternalInitiators bool

+ FeatureFluxMonitor bool

+ GasUpdaterBlockDelay uint16

+ GasUpdaterBlockHistorySize uint16

+ GasUpdaterEnabled bool

+ GasUpdaterTransactionPercentile uint16

type ORM

+ func (orm *ORM) CountOf(t interface{}) (int, error)

+ func (orm *ORM) DeleteEncryptedSecretVRFKey(k *models.EncryptedSecretVRFKey) error

+ func (orm *ORM) FindAllTxsInNonceRange(beginningNonce uint, endingNonce uint) ([]models.Tx, error)

+ func (orm *ORM) FindBridgesByNames(names []string) ([]models.BridgeType, error)

+ func (orm *ORM) FindEncryptedSecretVRFKeys(where ...models.EncryptedSecretVRFKey) (retrieved []*models.EncryptedSecretVRFKey, err error)

+ func (orm *ORM) FindLogCursor(name string) (models.LogCursor, error)

+ func (orm *ORM) FindTxsBySenderAndRecipient(sender, recipient common.Address, offset, limit uint) ([]models.Tx, error)

+ func (orm *ORM) FirstOrCreateEncryptedSecretVRFKey(k *models.EncryptedSecretVRFKey) error

+ func (orm *ORM) MustEnsureAdvisoryLock()

+ func (orm *ORM) RawDB(fn func(*gorm.DB) error) error

+ func (orm *ORM) SaveLogCursor(logCursor *models.LogCursor) error

v0.6.10

Nov 13, 2019

Changes in this version

type Config

+ func (c Config) ReplayFromBlock() int64

type ConfigSchema

+ ReplayFromBlock int64

type ORM

+ func (orm *ORM) UnconfirmedTxAttempts() ([]models.TxAttempt, error)

v0.6.9

Oct 3, 2019

v0.6.8

Sep 19, 2019

Changes in this version

type ORM

+ func (orm *ORM) SaveTx(tx *models.Tx) error

v0.6.7

Sep 11, 2019

v0.6.6

Sep 9, 2019

Changes in this version

+ func EnvVarName(field string) string

+ func NormalizedDatabaseURL(c ConfigReader) string

+ type Config struct

+ SecretGenerator SecretGenerator

+ func NewConfig() *Config

+ func (c *Config) SetRuntimeStore(orm *ORM)

+ func (c Config) AllowOrigins() string

+ func (c Config) BridgeResponseURL() *url.URL

+ func (c Config) CertFile() string

+ func (c Config) ChainID() *big.Int

+ func (c Config) ClientNodeURL() string

+ func (c Config) CreateProductionLogger() *zap.Logger

+ func (c Config) DatabaseTimeout() time.Duration

+ func (c Config) DatabaseURL() string

+ func (c Config) DefaultHTTPLimit() int64

+ func (c Config) Dev() bool

+ func (c Config) EthGasBumpThreshold() uint64

+ func (c Config) EthGasBumpWei() *big.Int

+ func (c Config) EthGasPriceDefault() *big.Int

+ func (c Config) EthereumURL() string

+ func (c Config) ExplorerAccessKey() string

+ func (c Config) ExplorerSecret() string

+ func (c Config) ExplorerURL() *url.URL

+ func (c Config) JSONConsole() bool

+ func (c Config) KeyFile() string

+ func (c Config) KeysDir() string

+ func (c Config) LinkContractAddress() string

+ func (c Config) LogLevel() LogLevel

+ func (c Config) LogSQLMigrations() bool

+ func (c Config) LogSQLStatements() bool

+ func (c Config) LogToDisk() bool

+ func (c Config) MaxRPCCallsPerSecond() uint64

+ func (c Config) MaximumServiceDuration() time.Duration

+ func (c Config) MinIncomingConfirmations() uint32

+ func (c Config) MinOutgoingConfirmations() uint64

+ func (c Config) MinimumContractPayment() *assets.Link

+ func (c Config) MinimumRequestExpiration() uint64

+ func (c Config) MinimumServiceDuration() time.Duration

+ func (c Config) OracleContractAddress() *common.Address

+ func (c Config) Port() uint16

+ func (c Config) ReaperExpiration() time.Duration

+ func (c Config) RootDir() string

+ func (c Config) SecureCookies() bool

+ func (c Config) SessionOptions() sessions.Options

+ func (c Config) SessionSecret() ([]byte, error)

+ func (c Config) SessionTimeout() time.Duration

+ func (c Config) Set(name string, value interface{})

+ func (c Config) SetEthGasPriceDefault(value *big.Int) error

+ func (c Config) TLSCertPath() string

+ func (c Config) TLSHost() string

+ func (c Config) TLSKeyPath() string

+ func (c Config) TLSPort() uint16

+ func (c Config) TLSRedirect() bool

+ func (c Config) TxAttemptLimit() uint16

+ type ConfigReader interface

+ AllowOrigins func() string

+ BridgeResponseURL func() *url.URL

+ CertFile func() string

+ ChainID func() *big.Int

+ ClientNodeURL func() string

+ CreateProductionLogger func() *zap.Logger

+ DatabaseTimeout func() time.Duration

+ DatabaseURL func() string

+ DefaultHTTPLimit func() int64

+ Dev func() bool

+ EthGasBumpThreshold func() uint64

+ EthGasBumpWei func() *big.Int

+ EthGasPriceDefault func() *big.Int

+ EthereumURL func() string

+ ExplorerAccessKey func() string

+ ExplorerSecret func() string

+ ExplorerURL func() *url.URL

+ JSONConsole func() bool

+ KeyFile func() string

+ KeysDir func() string

+ LinkContractAddress func() string

+ LogLevel func() LogLevel

+ LogSQLStatements func() bool

+ LogToDisk func() bool

+ MaximumServiceDuration func() time.Duration

+ MinIncomingConfirmations func() uint32

+ MinOutgoingConfirmations func() uint64

+ MinimumContractPayment func() *assets.Link

+ MinimumRequestExpiration func() uint64

+ MinimumServiceDuration func() time.Duration

+ OracleContractAddress func() *common.Address

+ Port func() uint16

+ ReaperExpiration func() time.Duration

+ RootDir func() string

+ SecureCookies func() bool

+ SessionOptions func() sessions.Options

+ SessionSecret func() ([]byte, error)

+ SessionTimeout func() time.Duration

+ SetEthGasPriceDefault func(value *big.Int) error

+ TLSCertPath func() string

+ TLSHost func() string

+ TLSKeyPath func() string

+ TLSPort func() uint16

+ TLSRedirect func() bool

+ TxAttemptLimit func() uint16

+ type ConfigSchema struct

+ AllowOrigins string

+ BridgeResponseURL url.URL

+ ChainID big.Int

+ ClientNodeURL string

+ DatabaseTimeout time.Duration

+ DatabaseURL string

+ DefaultHTTPLimit int64

+ Dev bool

+ EthGasBumpThreshold uint64

+ EthGasBumpWei big.Int

+ EthGasPriceDefault big.Int

+ EthereumURL string

+ ExplorerAccessKey string

+ ExplorerSecret string

+ ExplorerURL *url.URL

+ JSONConsole bool

+ LinkContractAddress string

+ LogLevel LogLevel

+ LogSQLMigrations bool

+ LogSQLStatements bool

+ LogToDisk bool

+ MaxRPCCallsPerSecond uint64

+ MaximumServiceDuration time.Duration

+ MinIncomingConfirmations uint32

+ MinOutgoingConfirmations uint64

+ MinimumContractPayment assets.Link

+ MinimumRequestExpiration uint64

+ MinimumServiceDuration time.Duration

+ OracleContractAddress common.Address

+ Port uint16

+ ReaperExpiration time.Duration

+ RootDir string

+ SecureCookies bool

+ SessionTimeout time.Duration

+ TLSCertPath string

+ TLSHost string

+ TLSKeyPath string

+ TLSPort uint16

+ TLSRedirect bool

+ TxAttemptLimit uint16

+ type LogLevel struct

+ func (ll LogLevel) ForGin() string

type ORM

+ func (orm *ORM) FindExternalInitiatorByName(name string) (models.ExternalInitiator, error)

+ func (orm *ORM) FirstHead() (*models.Head, error)

+ func (orm *ORM) GetConfigValue(field string, value encoding.TextUnmarshaler) error

+ func (orm *ORM) LinkEarnedFor(spec *models.JobSpec) (*assets.Link, error)

+ func (orm *ORM) SetConfigValue(field string, value encoding.TextMarshaler) error

+ type SecretGenerator interface

+ Generate func(Config) ([]byte, error)

v0.6.4

Jul 24, 2019

v0.6.3

Jul 9, 2019

v0.6.2

Jun 27, 2019

v0.6.1

Jun 26, 2019

Changes in this version

type ORM

+ func (orm *ORM) CreateHead(n *models.Head) error

+ func (orm *ORM) SetLogging(enabled bool)

v0.6.0

Jun 25, 2019

Changes in this version

+ var ErrorNotFound = gorm.ErrRecordNotFound

+ func Batch(chunkSize uint, cb func(offset, limit uint) (uint, error)) error

+ type DialectName string

+ const DialectPostgres

+ const DialectSqlite

+ func DeduceDialect(path string) (DialectName, error)

+ type FileLockingStrategy struct

+ func (s *FileLockingStrategy) Lock(timeout time.Duration) error

+ func (s *FileLockingStrategy) Unlock() error

+ type LockingStrategy interface

+ Lock func(timeout time.Duration) error

+ Unlock func() error

+ func NewFileLockingStrategy(dbpath string) (LockingStrategy, error)

+ func NewLockingStrategy(dialect DialectName, dbpath string) (LockingStrategy, error)

+ func NewPostgresLockingStrategy(path string) (LockingStrategy, error)

+ type ORM struct

+ DB *gorm.DB

+ func NewORM(uri string, timeout time.Duration) (*ORM, error)

+ func (orm *ORM) AddTxAttempt(tx *models.Tx, etx *types.Transaction, blkNum uint64) (*models.TxAttempt, error)

+ func (orm *ORM) AllSyncEvents(cb func(*models.SyncEvent) error) error

+ func (orm *ORM) AnyJobWithType(taskTypeName string) (bool, error)

+ func (orm *ORM) ArchiveJob(ID string) error

+ func (orm *ORM) Archived(ID string) bool

+ func (orm *ORM) AuthorizedUserWithSession(sessionID string, sessionDuration time.Duration) (models.User, error)

+ func (orm *ORM) BridgeTypes(offset int, limit int) ([]models.BridgeType, int, error)

+ func (orm *ORM) BulkDeleteRuns(bulkQuery *models.BulkDeleteRunRequest) error

+ func (orm *ORM) ClearNonCurrentSessions(sessionID string) error

+ func (orm *ORM) ClearSessions() error

+ func (orm *ORM) ClobberDiskKeyStoreWithDBKeys(keysDir string) error

+ func (orm *ORM) Close() error

+ func (orm *ORM) CreateBridgeType(bt *models.BridgeType) error

+ func (orm *ORM) CreateExternalInitiator(externalInitiator *models.ExternalInitiator) error

+ func (orm *ORM) CreateInitiator(initr *models.Initiator) error

+ func (orm *ORM) CreateJob(job *models.JobSpec) error

+ func (orm *ORM) CreateJobRun(run *models.JobRun) error

+ func (orm *ORM) CreateServiceAgreement(sa *models.ServiceAgreement) error

+ func (orm *ORM) CreateSession(sr models.SessionRequest) (string, error)

+ func (orm *ORM) CreateTx(surrogateID null.String, ethTx *types.Transaction, from *common.Address, ...) (*models.Tx, error)

+ func (orm *ORM) DeleteBridgeType(bt *models.BridgeType) error

+ func (orm *ORM) DeleteExternalInitiator(accessKey string) error

+ func (orm *ORM) DeleteJobRun(ID string) error

+ func (orm *ORM) DeleteStaleSessions(before time.Time) error

+ func (orm *ORM) DeleteTransaction(ethtx *models.Tx) error

+ func (orm *ORM) DeleteUser() (models.User, error)

+ func (orm *ORM) DeleteUserSession(sessionID string) error

+ func (orm *ORM) DialectName() DialectName

+ func (orm *ORM) EnableLogging()

+ func (orm *ORM) FindBridge(name models.TaskType) (models.BridgeType, error)

+ func (orm *ORM) FindExternalInitiator(eia *models.ExternalInitiatorAuthentication) (*models.ExternalInitiator, error)

+ func (orm *ORM) FindInitiator(ID uint) (models.Initiator, error)

+ func (orm *ORM) FindJob(id string) (models.JobSpec, error)

+ func (orm *ORM) FindJobRun(id string) (models.JobRun, error)

+ func (orm *ORM) FindServiceAgreement(id string) (models.ServiceAgreement, error)

+ func (orm *ORM) FindTx(ID uint64) (*models.Tx, error)

+ func (orm *ORM) FindTxAttempt(hash common.Hash) (*models.TxAttempt, error)

+ func (orm *ORM) FindTxByAttempt(hash common.Hash) (*models.Tx, *models.TxAttempt, error)

+ func (orm *ORM) FindUser() (models.User, error)

+ func (orm *ORM) FirstOrCreateKey(k *models.Key) error

+ func (orm *ORM) GetLastNonce(address common.Address) (uint64, error)

+ func (orm *ORM) JobRunsCountFor(jobSpecID string) (int, error)

+ func (orm *ORM) JobRunsFor(jobSpecID string, limit ...int) ([]models.JobRun, error)

+ func (orm *ORM) JobRunsSorted(sort SortType, offset int, limit int) ([]models.JobRun, int, error)

+ func (orm *ORM) JobRunsSortedFor(id string, order SortType, offset int, limit int) ([]models.JobRun, int, error)

+ func (orm *ORM) Jobs(cb func(models.JobSpec) bool) error

+ func (orm *ORM) JobsSorted(sort SortType, offset int, limit int) ([]models.JobSpec, int, error)

+ func (orm *ORM) Keys() ([]*models.Key, error)

+ func (orm *ORM) LastHead() (*models.Head, error)

+ func (orm *ORM) MarkRan(i *models.Initiator, ran bool) error

+ func (orm *ORM) MarkTxSafe(tx *models.Tx, txAttempt *models.TxAttempt) error

+ func (orm *ORM) PendingBridgeType(jr models.JobRun) (models.BridgeType, error)

+ func (orm *ORM) SaveHead(n *models.Head) error

+ func (orm *ORM) SaveJobRun(run *models.JobRun) error

+ func (orm *ORM) SaveSession(session *models.Session) error

+ func (orm *ORM) SaveUser(user *models.User) error

+ func (orm *ORM) Sessions(offset, limit int) ([]models.Session, error)

+ func (orm *ORM) Transactions(offset, limit int) ([]models.Tx, int, error)

+ func (orm *ORM) TxAttempts(offset, limit int) ([]models.TxAttempt, int, error)

+ func (orm *ORM) TxFrom(from common.Address) ([]models.Tx, error)

+ func (orm *ORM) Unscoped() *ORM

+ func (orm *ORM) UnscopedJobRunsWithStatus(cb func(*models.JobRun), statuses ...models.RunStatus) error

+ func (orm *ORM) UpdateBridgeType(bt *models.BridgeType, btr *models.BridgeTypeRequest) error

+ func (orm *ORM) UpdateTx(tx *models.Tx, ethTx *types.Transaction, from *common.Address, sentAt uint64) error

+ func (orm *ORM) Where(field string, value interface{}, instance interface{}) error

+ type PostgresLockingStrategy struct

+ func (s *PostgresLockingStrategy) Lock(timeout time.Duration) error

+ func (s *PostgresLockingStrategy) Unlock() error

+ type SortType int

+ const Ascending

+ const Descending

+ func (s SortType) String() string

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL