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 + const BatchSize + var ErrInvalid = errors.New("env var invalid") + var ErrNoAdvisoryLock = errors.New("can't acquire advisory lock") + var ErrOptimisticUpdateConflict = errors.New("conflict while updating record") + var ErrReleaseLockFailed = errors.New("advisory lock release failed") + var ErrUnset = errors.New("env var unset") + var ErrorNotFound = gorm.ErrRecordNotFound + func Batch(cb BatchFunc) error + func BulkDeleteRuns(db *gorm.DB, bulkQuery *models.BulkDeleteRunRequest) error + func EnvVarName(field string) string + type BatchFunc func(offset, limit uint) (count uint, err error) + type Config struct + AdvisoryLockID int64 + Dialect dialects.DialectName + SecretGenerator SecretGenerator + func NewConfig() *Config + func (c *Config) P2PListenPort() uint16 + func (c *Config) SetRuntimeStore(orm *ORM) + func (c *Config) Validate() error + func (c Config) AdminCredentialsFile() string + func (c Config) AllowOrigins() string + func (c Config) AuthenticatedRateLimit() int64 + func (c Config) AuthenticatedRateLimitPeriod() models.Duration + func (c Config) BalanceMonitorEnabled() bool + func (c Config) BlockBackfillDepth() uint64 + func (c Config) BridgeResponseURL() *url.URL + func (c Config) CertFile() string + func (c Config) Chain() *chains.Chain + func (c Config) ChainID() *big.Int + func (c Config) ClientNodeURL() string + func (c Config) CreateProductionLogger() *logger.Logger + func (c Config) DatabaseBackupDir() string + func (c Config) DatabaseBackupFrequency() time.Duration + func (c Config) DatabaseBackupMode() DatabaseBackupMode + func (c Config) DatabaseBackupURL() *url.URL + func (c Config) DatabaseListenerMaxReconnectDuration() time.Duration + func (c Config) DatabaseListenerMinReconnectInterval() time.Duration + func (c Config) DatabaseMaximumTxDuration() time.Duration + func (c Config) DatabaseTimeout() models.Duration + func (c Config) DatabaseURL() url.URL + func (c Config) DefaultHTTPAllowUnrestrictedNetworkAccess() bool + func (c Config) DefaultHTTPLimit() int64 + func (c Config) DefaultHTTPTimeout() models.Duration + func (c Config) DefaultMaxHTTPAttempts() uint + func (c Config) Dev() bool + func (c Config) EnableExperimentalAdapters() bool + func (c Config) EnableLegacyJobPipeline() bool + func (c Config) EthBalanceMonitorBlockDelay() uint16 + func (c Config) EthFinalityDepth() uint + func (c Config) EthGasBumpPercent() uint16 + func (c Config) EthGasBumpThreshold() uint64 + func (c Config) EthGasBumpTxDepth() uint16 + func (c Config) EthGasBumpWei() *big.Int + func (c Config) EthGasLimitDefault() uint64 + func (c Config) EthGasLimitMultiplier() float32 + func (c Config) EthGasLimitTransfer() uint64 + func (c Config) EthGasPriceDefault() *big.Int + func (c Config) EthHeadTrackerHistoryDepth() uint + func (c Config) EthHeadTrackerMaxBufferSize() uint + func (c Config) EthHeadTrackerSamplingInterval() time.Duration + func (c Config) EthLogBackfillBatchSize() uint32 + func (c Config) EthMaxGasPriceWei() *big.Int + func (c Config) EthMaxInFlightTransactions() uint32 + func (c Config) EthMaxQueuedTransactions() uint64 + func (c Config) EthMinGasPriceWei() *big.Int + func (c Config) EthNonceAutoSync() bool + func (c Config) EthRPCDefaultBatchSize() uint32 + func (c Config) EthTxReaperInterval() time.Duration + func (c Config) EthTxReaperThreshold() time.Duration + func (c Config) EthTxResendAfterThreshold() time.Duration + func (c Config) EthereumDisabled() bool + func (c Config) EthereumHTTPURL() (uri *url.URL) + func (c Config) EthereumSecondaryURLs() []url.URL + func (c Config) EthereumURL() string + func (c Config) ExplorerAccessKey() string + func (c Config) ExplorerSecret() string + func (c Config) ExplorerURL() *url.URL + func (c Config) FMDefaultTransactionQueueDepth() uint32 + func (c Config) FeatureCronV2() bool + func (c Config) FeatureExternalInitiators() bool + func (c Config) FeatureFluxMonitor() bool + func (c Config) FeatureFluxMonitorV2() bool + func (c Config) FeatureOffchainReporting() bool + func (c Config) FeatureWebhookV2() bool + func (c Config) FlagsContractAddress() string + func (c Config) GasUpdaterBatchSize() (size uint32) + func (c Config) GasUpdaterBlockDelay() uint16 + func (c Config) GasUpdaterBlockHistorySize() uint16 + func (c Config) GasUpdaterEnabled() bool + func (c Config) GasUpdaterTransactionPercentile() uint16 + func (c Config) GetAdvisoryLockIDConfiguredOrDefault() int64 + func (c Config) GetDatabaseDialectConfiguredOrDefault() dialects.DialectName + func (c Config) GlobalLockRetryInterval() models.Duration + func (c Config) HTTPServerWriteTimeout() time.Duration + func (c Config) InsecureFastScrypt() bool + func (c Config) InsecureSkipVerify() bool + func (c Config) JSONConsole() bool + func (c Config) JobPipelineMaxRunDuration() time.Duration + func (c Config) JobPipelineReaperInterval() time.Duration + func (c Config) JobPipelineReaperThreshold() time.Duration + func (c Config) JobPipelineResultWriteQueueDepth() uint64 + func (c Config) KeeperDefaultTransactionQueueDepth() uint32 + func (c Config) KeeperMaximumGracePeriod() int64 + func (c Config) KeeperMinimumRequiredConfirmations() uint64 + func (c Config) KeeperRegistryCheckGasOverhead() uint64 + func (c Config) KeeperRegistryPerformGasOverhead() uint64 + func (c Config) KeeperRegistrySyncInterval() time.Duration + func (c Config) KeyFile() 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) MaximumServiceDuration() models.Duration + func (c Config) MigrateDatabase() bool + func (c Config) MinIncomingConfirmations() uint32 + func (c Config) MinRequiredOutgoingConfirmations() uint64 + func (c Config) MinimumContractPayment() *assets.Link + func (c Config) MinimumRequestExpiration() uint64 + func (c Config) MinimumServiceDuration() models.Duration + func (c Config) OCRBlockchainTimeout(override time.Duration) time.Duration + func (c Config) OCRBootstrapCheckInterval() 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) OCRContractTransmitterTransmitTimeout() time.Duration + func (c Config) OCRDHTLookupInterval() int + func (c Config) OCRDatabaseTimeout() time.Duration + func (c Config) OCRDefaultTransactionQueueDepth() uint32 + func (c Config) OCRIncomingMessageBufferSize() int + func (c Config) OCRKeyBundleID(override *models.Sha256Hash) (models.Sha256Hash, error) + func (c Config) OCRMonitoringEndpoint(override string) string + func (c Config) OCRNewStreamTimeout() time.Duration + func (c Config) OCRObservationGracePeriod() time.Duration + func (c Config) OCRObservationTimeout(override time.Duration) time.Duration + func (c Config) OCROutgoingMessageBufferSize() int + func (c Config) OCRTraceLogging() bool + func (c Config) OCRTransmitterAddress(override *ethkey.EIP55Address) (ethkey.EIP55Address, error) + func (c Config) ORMMaxIdleConns() int + func (c Config) ORMMaxOpenConns() int + func (c Config) OperatorContractAddress() common.Address + func (c Config) OptimismGasFees() bool + func (c Config) P2PAnnounceIP() net.IP + func (c Config) P2PAnnouncePort() uint16 + func (c Config) P2PBootstrapPeers(override []string) ([]string, error) + func (c Config) P2PDHTAnnouncementCounterUserPrefix() uint32 + func (c Config) P2PListenIP() net.IP + func (c Config) P2PListenPortRaw() string + func (c Config) P2PPeerID(override *p2pkey.PeerID) (p2pkey.PeerID, error) + func (c Config) P2PPeerIDIsSet() bool + func (c Config) P2PPeerIDRaw() string + func (c Config) P2PPeerstoreWriteInterval() time.Duration + func (c Config) Port() uint16 + func (c Config) ReaperExpiration() models.Duration + func (c Config) ReplayFromBlock() int64 + 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() models.Duration + func (c Config) Set(name string, value interface{}) + func (c Config) SetEthGasPriceDefault(value *big.Int) error + 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 + 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) TriggerFallbackDBPollInterval() time.Duration + func (c Config) UnAuthenticatedRateLimit() int64 + func (c Config) UnAuthenticatedRateLimitPeriod() models.Duration + type ConfigReader interface + AllowOrigins func() string + BlockBackfillDepth func() uint64 + BridgeResponseURL func() *url.URL + CertFile func() string + ChainID func() *big.Int + ClientNodeURL func() string + CreateProductionLogger func() *logger.Logger + DatabaseMaximumTxDuration func() time.Duration + DatabaseTimeout func() models.Duration + DatabaseURL func() url.URL + DefaultHTTPAllowUnrestrictedNetworkAccess func() bool + DefaultHTTPLimit func() int64 + DefaultHTTPTimeout func() models.Duration + DefaultMaxHTTPAttempts func() uint + Dev func() bool + EnableExperimentalAdapters func() bool + EthBalanceMonitorBlockDelay func() uint16 + EthFinalityDepth func() uint + EthGasBumpPercent func() uint16 + EthGasBumpThreshold func() uint64 + EthGasBumpTxDepth func() uint16 + EthGasBumpWei func() *big.Int + EthGasLimitDefault func() uint64 + EthGasLimitMultiplier func() float32 + EthGasPriceDefault func() *big.Int + EthHeadTrackerHistoryDepth func() uint + EthHeadTrackerMaxBufferSize func() uint + EthLogBackfillBatchSize func() uint32 + EthMaxGasPriceWei func() *big.Int + EthNonceAutoSync func() bool + EthRPCDefaultBatchSize func() uint32 + EthTxReaperInterval func() time.Duration + EthTxReaperThreshold func() time.Duration + EthTxResendAfterThreshold func() time.Duration + EthereumSecondaryURLs func() []url.URL + EthereumURL func() string + ExplorerAccessKey func() string + ExplorerSecret func() string + ExplorerURL func() *url.URL + FeatureExternalInitiators func() bool + FeatureFluxMonitor func() bool + FeatureOffchainReporting func() bool + GasUpdaterBlockDelay func() uint16 + GasUpdaterBlockHistorySize func() uint16 + GasUpdaterTransactionPercentile func() uint16 + InsecureSkipVerify func() bool + JSONConsole func() bool + KeeperDefaultTransactionQueueDepth func() uint32 + KeeperMaximumGracePeriod func() int64 + KeeperMinimumRequiredConfirmations func() uint64 + KeeperRegistryCheckGasOverhead func() uint64 + KeeperRegistryPerformGasOverhead func() uint64 + KeeperRegistrySyncInterval func() time.Duration + KeyFile func() string + LinkContractAddress func() string + LogLevel func() LogLevel + LogSQLStatements func() bool + LogToDisk func() bool + MaximumServiceDuration func() models.Duration + MigrateDatabase func() bool + MinIncomingConfirmations func() uint32 + MinRequiredOutgoingConfirmations func() uint64 + MinimumContractPayment func() *assets.Link + MinimumRequestExpiration func() uint64 + MinimumServiceDuration func() models.Duration + OCRTraceLogging func() bool + OperatorContractAddress func() common.Address + OptimismGasFees func() bool + Port func() uint16 + ReaperExpiration func() models.Duration + RootDir func() string + SecureCookies func() bool + SessionOptions func() sessions.Options + SessionSecret func() ([]byte, error) + SessionTimeout func() models.Duration + SetEthGasPriceDefault func(value *big.Int) error + TLSCertPath func() string + TLSHost func() string + TLSKeyPath func() string + TLSPort func() uint16 + TLSRedirect func() bool + TriggerFallbackDBPollInterval func() time.Duration + type ConfigSchema struct + AdminCredentialsFile string + AllowOrigins string + AuthenticatedRateLimit int64 + AuthenticatedRateLimitPeriod time.Duration + BalanceMonitorEnabled bool + BlockBackfillDepth string + BridgeResponseURL url.URL + ChainID big.Int + ClientNodeURL string + DatabaseBackupDir string + DatabaseBackupFrequency time.Duration + DatabaseBackupMode string + DatabaseBackupURL *url.URL + DatabaseListenerMaxReconnectDuration time.Duration + DatabaseListenerMinReconnectInterval time.Duration + DatabaseMaximumTxDuration time.Duration + DatabaseTimeout models.Duration + DatabaseURL string + DefaultHTTPAllowUnrestrictedNetworkAccess bool + DefaultHTTPLimit int64 + DefaultHTTPTimeout models.Duration + DefaultMaxHTTPAttempts uint + Dev bool + EnableExperimentalAdapters bool + EnableLegacyJobPipeline bool + EthBalanceMonitorBlockDelay uint16 + EthFinalityDepth uint + EthGasBumpPercent uint16 + EthGasBumpThreshold uint64 + EthGasBumpTxDepth uint16 + EthGasBumpWei big.Int + EthGasLimitDefault uint64 + EthGasLimitMultiplier float32 + EthGasLimitTransfer uint64 + EthGasPriceDefault big.Int + EthHeadTrackerHistoryDepth uint + EthHeadTrackerMaxBufferSize uint + EthHeadTrackerSamplingInterval time.Duration + EthLogBackfillBatchSize uint32 + EthMaxGasPriceWei big.Int + EthMaxInFlightTransactions uint64 + EthMaxQueuedTransactions uint64 + EthMinGasPriceWei big.Int + EthNonceAutoSync bool + EthRPCDefaultBatchSize uint32 + EthTxReaperInterval time.Duration + EthTxReaperThreshold time.Duration + EthTxResendAfterThreshold time.Duration + EthereumDisabled bool + EthereumHTTPURL string + EthereumSecondaryURL string + EthereumSecondaryURLs string + EthereumURL string + ExplorerAccessKey string + ExplorerSecret string + ExplorerURL *url.URL + FMDefaultTransactionQueueDepth uint32 + FeatureCronV2 bool + FeatureExternalInitiators bool + FeatureFluxMonitor bool + FeatureFluxMonitorV2 bool + FeatureOffchainReporting bool + FeatureWebhookV2 bool + FlagsContractAddress string + GasUpdaterBatchSize uint32 + GasUpdaterBlockDelay uint16 + GasUpdaterBlockHistorySize uint16 + GasUpdaterEnabled bool + GasUpdaterTransactionPercentile uint16 + GlobalLockRetryInterval models.Duration + HTTPServerWriteTimeout time.Duration + InsecureFastScrypt bool + InsecureSkipVerify bool + JSONConsole bool + JobPipelineMaxRunDuration time.Duration + JobPipelineReaperInterval time.Duration + JobPipelineReaperThreshold time.Duration + JobPipelineResultWriteQueueDepth uint64 + KeeperDefaultTransactionQueueDepth uint32 + KeeperMaximumGracePeriod int64 + KeeperMinimumRequiredConfirmations uint64 + KeeperRegistryCheckGasOverhead uint64 + KeeperRegistryPerformGasOverhead uint64 + KeeperRegistrySyncInterval time.Duration + LinkContractAddress string + LogLevel LogLevel + LogSQLMigrations bool + LogSQLStatements bool + LogToDisk bool + MaximumServiceDuration models.Duration + MigrateDatabase bool + MinIncomingConfirmations uint32 + MinRequiredOutgoingConfirmations uint64 + MinimumContractPayment assets.Link + MinimumRequestExpiration uint64 + MinimumServiceDuration models.Duration + OCRBlockchainTimeout time.Duration + OCRBootstrapCheckInterval time.Duration + OCRContractConfirmations uint + OCRContractPollInterval time.Duration + OCRContractSubscribeInterval time.Duration + OCRContractTransmitterTransmitTimeout time.Duration + OCRDHTLookupInterval int + OCRDatabaseTimeout time.Duration + OCRDefaultTransactionQueueDepth uint32 + OCRIncomingMessageBufferSize int + OCRKeyBundleID string + OCRMonitoringEndpoint string + OCRNewStreamTimeout time.Duration + OCRObservationGracePeriod time.Duration + OCRObservationTimeout time.Duration + OCROutgoingMessageBufferSize int + OCRTraceLogging bool + OCRTransmitterAddress string + ORMMaxIdleConns int + ORMMaxOpenConns int + OperatorContractAddress common.Address + OptimismGasFees bool + P2PAnnounceIP net.IP + P2PAnnouncePort uint16 + P2PBootstrapPeers []string + P2PDHTAnnouncementCounterUserPrefix uint32 + P2PListenIP net.IP + P2PListenPort uint16 + P2PPeerID p2pkey.PeerID + P2PPeerstoreWriteInterval time.Duration + Port uint16 + ReaperExpiration models.Duration + ReplayFromBlock int64 + RootDir string + SecureCookies bool + SessionTimeout models.Duration + StatsPusherLogging string + TLSCertPath string + TLSHost string + TLSKeyPath string + TLSPort uint16 + TLSRedirect bool + TriggerFallbackDBPollInterval time.Duration + UnAuthenticatedRateLimit int64 + UnAuthenticatedRateLimitPeriod time.Duration + type Connection struct + func NewConnection(dialect dialects.DialectName, uri string, advisoryLockID int64, ...) (Connection, error) + type DatabaseBackupMode string + var DatabaseBackupModeFull DatabaseBackupMode = "full" + var DatabaseBackupModeLite DatabaseBackupMode = "lite" + var DatabaseBackupModeNone DatabaseBackupMode = "none" + type LockingStrategy interface + Lock func(timeout models.Duration) error + Unlock func(timeout models.Duration) error + func NewLockingStrategy(ct Connection) (LockingStrategy, error) + func NewPostgresLockingStrategy(ct Connection) (LockingStrategy, error) + type LogLevel struct + type ORM struct + DB *gorm.DB + func NewORM(uri string, timeout models.Duration, shutdownSignal gracefulpanic.Signal, ...) (*ORM, error) + func (orm *ORM) AnyJobWithType(taskTypeName string) (bool, error) + func (orm *ORM) ArchiveJob(ID models.JobID) error + 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) Chain(ctx context.Context, hash common.Hash, lookback uint) (models.Head, error) + func (orm *ORM) ClearNonCurrentSessions(sessionID string) error + func (orm *ORM) ClearSessions() error + func (orm *ORM) Close() error + func (orm *ORM) CountOf(t interface{}) (int, 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) DeleteBridgeType(bt *models.BridgeType) error + func (orm *ORM) DeleteExternalInitiator(name string) error + func (orm *ORM) DeleteFluxMonitorRoundsBackThrough(aggregator common.Address, roundID uint32) error + func (orm *ORM) DeleteJobSpecError(ID int64) error + func (orm *ORM) DeleteStaleSessions(before time.Time) error + func (orm *ORM) DeleteUser() error + func (orm *ORM) DeleteUserSession(sessionID string) error + 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) FindBridge(name models.TaskType) (bt models.BridgeType, err error) + func (orm *ORM) FindBridgesByNames(names []string) ([]models.BridgeType, error) + func (orm *ORM) FindEthTaskRunTxByTaskRunID(taskRunID uuid.UUID) (*models.EthTaskRunTx, error) + func (orm *ORM) FindEthTxAttempt(hash common.Hash) (*models.EthTxAttempt, error) + func (orm *ORM) FindEthTxWithAttempts(etxID int64) (models.EthTx, error) + func (orm *ORM) FindExternalInitiator(eia *auth.Token) (*models.ExternalInitiator, error) + func (orm *ORM) FindExternalInitiatorByName(iname string) (exi models.ExternalInitiator, err error) + func (orm *ORM) FindInitiator(ID int64) (initr models.Initiator, err error) + func (orm *ORM) FindJobIDsWithBridge(bridgeName string) ([]models.JobID, error) + func (orm *ORM) FindJobRun(id uuid.UUID) (jr models.JobRun, err error) + func (orm *ORM) FindJobRunIncludingArchived(id uuid.UUID) (jr models.JobRun, err error) + func (orm *ORM) FindJobSpec(id models.JobID) (job models.JobSpec, err error) + func (orm *ORM) FindJobSpecError(jobID models.JobID, description string) (*models.JobSpecError, error) + func (orm *ORM) FindJobSpecUnscoped(id models.JobID) (job models.JobSpec, err error) + func (orm *ORM) FindJobWithErrors(id models.JobID) (models.JobSpec, error) + func (orm *ORM) FindLatestNodeVersion() (*models.NodeVersion, error) + func (orm *ORM) FindOrCreateFluxMonitorRoundStats(aggregator common.Address, roundID uint32) (stats models.FluxMonitorRoundStats, err error) + func (orm *ORM) FindServiceAgreement(id string) (sa models.ServiceAgreement, err error) + func (orm *ORM) FindUser() (models.User, error) + func (orm *ORM) GetConfigBoolValue(field string) (*bool, error) + func (orm *ORM) GetConfigValue(field string, value encoding.TextUnmarshaler) error + func (orm *ORM) HeadByHash(ctx context.Context, hash common.Hash) (*models.Head, error) + func (orm *ORM) IdempotentInsertEthTaskRunTx(meta models.EthTxMeta, fromAddress common.Address, toAddress common.Address, ...) error + func (orm *ORM) IdempotentInsertHead(ctx context.Context, h models.Head) error + func (orm *ORM) JobRunsCountFor(jobSpecID models.JobID) (int, error) + func (orm *ORM) JobRunsCountForGivenStatus(jobSpecID models.JobID, status string) (int, error) + func (orm *ORM) JobRunsFor(jobSpecID models.JobID, limit ...int) ([]models.JobRun, error) + func (orm *ORM) JobRunsSorted(sort SortType, offset int, limit int) ([]models.JobRun, int, error) + func (orm *ORM) JobRunsSortedFor(id models.JobID, order SortType, offset int, limit int) ([]models.JobRun, int, int, int, error) + func (orm *ORM) Jobs(cb func(*models.JobSpec) bool, initrTypes ...string) error + func (orm *ORM) JobsSorted(sort SortType, offset int, limit int) ([]models.JobSpec, int, error) + func (orm *ORM) LastHead(ctx context.Context) (*models.Head, error) + func (orm *ORM) LinkEarnedFor(spec *models.JobSpec) (*assets.Link, error) + func (orm *ORM) MarkRan(i models.Initiator, ran bool) error + func (orm *ORM) MostRecentFluxMonitorRoundID(aggregator common.Address) (uint32, error) + func (orm *ORM) MustEnsureAdvisoryLock() error + func (orm *ORM) MustSQLDB() *sql.DB + func (orm *ORM) PendingBridgeType(jr models.JobRun) (bt models.BridgeType, err error) + func (orm *ORM) RawDBWithAdvisoryLock(fn func(*gorm.DB) error) error + func (orm *ORM) RemoveUnstartedTransactions() 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) SetConfigStrValue(ctx context.Context, field string, value string) error + func (orm *ORM) SetConfigValue(field string, value encoding.TextMarshaler) error + func (orm *ORM) SetLogging(enabled bool) + func (orm *ORM) Transaction(fc func(tx *gorm.DB) error) (err error) + func (orm *ORM) TrimOldHeads(ctx context.Context, n uint) (err 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) UpdateFluxMonitorRoundStats(aggregator common.Address, roundID uint32, jobRunID uuid.UUID) error + func (orm *ORM) UpsertErrorFor(jobID models.JobID, description string) + func (orm *ORM) UpsertNodeVersion(version models.NodeVersion) error + type PostgresLockingStrategy struct + func (s *PostgresLockingStrategy) Lock(timeout models.Duration) error + func (s *PostgresLockingStrategy) Unlock(timeout models.Duration) error + type SecretGenerator interface + Generate func(Config) ([]byte, error) + type SortType int + const Ascending + const Descending + func (s SortType) String() string
Go to main page