Versions in this module Expand all Collapse all v0 v0.5.0 Jun 23, 2023 v0.4.0 Jun 22, 2023 v0.3.0 Jun 22, 2023 v0.2.0 Jun 22, 2023 Changes in this version + var DatabaseBackupModeEnvVar = envvar.New("DatabaseBackupMode", parseDatabaseBackupMode) + var ErrEnvInvalid = errors.New("env var invalid") + var ErrEnvUnset = errors.New("env var unset") + var ErrInvalidChainType = fmt.Errorf("must be one of %s or omitted", strings.Join([]string{ ... }, ", ")) + func FriendlyBigInt(n *big.Int) string + func ValidateDBURL(dbURI url.URL) error + type BasicConfig interface + AdvisoryLockCheckInterval func() time.Duration + AdvisoryLockID func() int64 + AllowOrigins func() string + AppID func() uuid.UUID + AuthenticatedRateLimit func() int64 + AuthenticatedRateLimitPeriod func() models.Duration + AutoPprofBlockProfileRate func() int + AutoPprofCPUProfileRate func() int + AutoPprofGatherDuration func() models.Duration + AutoPprofGatherTraceDuration func() models.Duration + AutoPprofGoroutineThreshold func() int + AutoPprofMaxProfileSize func() utils.FileSize + AutoPprofMemProfileRate func() int + AutoPprofMemThreshold func() utils.FileSize + AutoPprofMutexProfileFraction func() int + AutoPprofPollInterval func() models.Duration + AutoPprofProfileRoot func() string + BlockBackfillDepth func() uint64 + BlockBackfillSkip func() bool + BridgeCacheTTL func() time.Duration + BridgeResponseURL func() *url.URL + CertFile func() string + DatabaseBackupDir func() string + DatabaseBackupFrequency func() time.Duration + DatabaseBackupMode func() DatabaseBackupMode + DatabaseBackupOnVersionUpgrade func() bool + DatabaseBackupURL func() *url.URL + DatabaseDefaultIdleInTxSessionTimeout func() time.Duration + DatabaseDefaultLockTimeout func() time.Duration + DatabaseDefaultQueryTimeout func() time.Duration + DatabaseListenerMaxReconnectDuration func() time.Duration + DatabaseListenerMinReconnectInterval func() time.Duration + DatabaseLockingMode func() string + DatabaseURL func() url.URL + DefaultChainID func() *big.Int + DefaultHTTPLimit func() int64 + DefaultHTTPTimeout func() models.Duration + DefaultLogLevel func() zapcore.Level + Dev func() bool + EthereumHTTPURL func() *url.URL + EthereumNodes func() string + EthereumSecondaryURLs func() []url.URL + EthereumURL func() string + ExplorerAccessKey func() string + ExplorerSecret func() string + ExplorerURL func() *url.URL + FMDefaultTransactionQueueDepth func() uint32 + FMSimulateTransactions func() bool + GetAdvisoryLockIDConfiguredOrDefault func() int64 + GetDatabaseDialectConfiguredOrDefault func() dialects.DialectName + HTTPServerWriteTimeout func() time.Duration + InsecureFastScrypt func() bool + JSONConsole func() bool + JobPipelineMaxRunDuration func() time.Duration + JobPipelineMaxSuccessfulRuns func() uint64 + JobPipelineReaperInterval func() time.Duration + JobPipelineReaperThreshold func() time.Duration + JobPipelineResultWriteQueueDepth func() uint64 + KeeperBaseFeeBufferPercent func() uint16 + KeeperDefaultTransactionQueueDepth func() uint32 + KeeperGasPriceBufferPercent func() uint16 + KeeperGasTipCapBufferPercent func() uint16 + KeeperMaximumGracePeriod func() int64 + KeeperRegistryCheckGasOverhead func() uint32 + KeeperRegistryMaxPerformDataSize func() uint32 + KeeperRegistryPerformGasOverhead func() uint32 + KeeperRegistrySyncInterval func() time.Duration + KeeperRegistrySyncUpkeepQueueSize func() uint32 + KeeperTurnLookBack func() int64 + KeyFile func() string + KeystorePassword func() string + LeaseLockDuration func() time.Duration + LeaseLockRefreshInterval func() time.Duration + LogConfiguration func(log LogFn) + LogFileDir func() string + LogFileMaxAge func() int64 + LogFileMaxBackups func() int64 + LogFileMaxSize func() utils.FileSize + LogLevel func() zapcore.Level + LogSQL func() bool + LogUnixTimestamps func() bool + MercuryCredentials func(url string) (username, password string, err error) + MigrateDatabase func() bool + ORMMaxIdleConns func() int + ORMMaxOpenConns func() int + Port func() uint16 + PyroscopeAuthToken func() string + PyroscopeEnvironment func() string + PyroscopeServerAddress func() string + RPID func() string + RPOrigin func() string + ReaperExpiration func() models.Duration + RootDir func() string + SecureCookies func() bool + SentryDSN func() string + SentryDebug func() bool + SentryEnvironment func() string + SentryRelease func() string + SessionOptions func() sessions.Options + SessionTimeout func() models.Duration + SetLogLevel func(lvl zapcore.Level) error + SetLogSQL func(logSQL bool) + SetPasswords func(keystore, vrf *string) + ShutdownGracePeriod func() time.Duration + SolanaNodes func() string + StarkNetNodes func() string + TLSCertPath func() string + TLSDir func() string + TLSHost func() string + TLSKeyPath func() string + TLSPort func() uint16 + TLSRedirect func() bool + TelemetryIngressBufferSize func() uint + TelemetryIngressLogging func() bool + TelemetryIngressMaxBatchSize func() uint + TelemetryIngressSendInterval func() time.Duration + TelemetryIngressSendTimeout func() time.Duration + TelemetryIngressServerPubKey func() string + TelemetryIngressURL func() *url.URL + TelemetryIngressUniConn func() bool + TelemetryIngressUseBatchSend func() bool + TriggerFallbackDBPollInterval func() time.Duration + UnAuthenticatedRateLimit func() int64 + UnAuthenticatedRateLimitPeriod func() models.Duration + VRFPassword func() string + Validate func() error + type ChainType string + const ChainArbitrum + const ChainMetis + const ChainOptimism + const ChainOptimismBedrock + const ChainXDai + func (c ChainType) IsL2() bool + func (c ChainType) IsValid() bool + type ConfigPrinter struct + func NewConfigPrinter(cfg GeneralConfig) ConfigPrinter + func (c *ConfigPrinter) SetID(value string) error + func (c ConfigPrinter) GetID() string + func (c ConfigPrinter) String() string + type DatabaseBackupMode string + var DatabaseBackupModeFull DatabaseBackupMode = "full" + var DatabaseBackupModeLite DatabaseBackupMode = "lite" + var DatabaseBackupModeNone DatabaseBackupMode = "none" + type EnvPrinter struct + AdvisoryLockCheckInterval time.Duration + AdvisoryLockID int64 + AllowOrigins string + AuditLoggerEnabled bool + AuditLoggerForwardToUrl string + AuditLoggerHeaders string + AuditLoggerJsonWrapperKey string + BlockBackfillDepth uint64 + BlockHistoryEstimatorBlockDelay uint16 + BlockHistoryEstimatorBlockHistorySize uint16 + BlockHistoryEstimatorTransactionPercentile uint16 + BridgeCacheTTL time.Duration + BridgeResponseURL string + ChainType string + DatabaseBackupFrequency time.Duration + DatabaseBackupMode string + DatabaseBackupOnVersionUpgrade bool + DatabaseLockingMode string + DefaultChainID string + DefaultHTTPLimit int64 + DefaultHTTPTimeout models.Duration + Dev bool + EVMRPCEnabled bool + EthereumHTTPURL string + EthereumSecondaryURLs []string + EthereumURL string + ExplorerURL string + FMDefaultTransactionQueueDepth uint32 + FeatureExternalInitiators bool + FeatureOffchainReporting bool + FlagsContractAddress string + GasEstimatorMode string + InsecureFastScrypt bool + JSONConsole bool + JobPipelineReaperInterval time.Duration + JobPipelineReaperThreshold time.Duration + KeeperBaseFeeBufferPercent uint16 + KeeperDefaultTransactionQueueDepth uint32 + KeeperGasPriceBufferPercent uint16 + KeeperGasTipCapBufferPercent uint16 + KeeperMaximumGracePeriod int64 + KeeperRegistryCheckGasOverhead uint32 + KeeperRegistryMaxPerformDataSize uint32 + KeeperRegistryPerformGasOverhead uint32 + KeeperRegistrySyncInterval time.Duration + KeeperRegistrySyncUpkeepQueueSize uint32 + KeeperTurnLookBack int64 + LeaseLockDuration time.Duration + LeaseLockRefreshInterval time.Duration + LinkContractAddress string + LogFileDir string + LogFileMaxAge int64 + LogFileMaxBackups int64 + LogFileMaxSize utils.FileSize + LogLevel zapcore.Level + LogSQL bool + OCRContractTransmitterTransmitTimeout time.Duration + OCRDatabaseTimeout time.Duration + OCRDefaultTransactionQueueDepth uint32 + OCRTraceLogging bool + P2PBootstrapCheckInterval time.Duration + P2PBootstrapPeers []string + P2PDHTLookupInterval int + P2PIncomingMessageBufferSize int + P2PListenIP string + P2PListenPort string + P2PNetworkingStack string + P2PNewStreamTimeout time.Duration + P2POutgoingMessageBufferSize int + P2PPeerID string + P2PV2AnnounceAddresses []string + P2PV2Bootstrappers []string + P2PV2DeltaDial models.Duration + P2PV2DeltaReconcile models.Duration + P2PV2ListenAddresses []string + Port uint16 + ReaperExpiration models.Duration + RootDir string + SecureCookies bool + SessionTimeout models.Duration + ShutdownGracePeriod time.Duration + TLSHost string + TLSPort uint16 + TLSRedirect bool + TelemetryIngressLogging bool + TelemetryIngressServerPubKey string + TelemetryIngressURL string + TriggerFallbackDBPollInterval time.Duration + type FeatureFlags interface + AutoPprofEnabled func() bool + EVMEnabled func() bool + EVMRPCEnabled func() bool + FeatureExternalInitiators func() bool + FeatureFeedsManager func() bool + FeatureLogPoller func() bool + FeatureOffchainReporting func() bool + FeatureOffchainReporting2 func() bool + FeatureUICSAKeys func() bool + P2PEnabled func() bool + SolanaEnabled func() bool + StarkNetEnabled func() bool + type GeneralConfig interface + func NewGeneralConfig(lggr logger.Logger) GeneralConfig + type GlobalConfig interface + GlobalBalanceMonitorEnabled func() (bool, bool) + GlobalBlockEmissionIdleWarningThreshold func() (time.Duration, bool) + GlobalBlockHistoryEstimatorBatchSize func() (uint32, bool) + GlobalBlockHistoryEstimatorBlockDelay func() (uint16, bool) + GlobalBlockHistoryEstimatorBlockHistorySize func() (uint16, bool) + GlobalBlockHistoryEstimatorCheckInclusionBlocks func() (uint16, bool) + GlobalBlockHistoryEstimatorCheckInclusionPercentile func() (uint16, bool) + GlobalBlockHistoryEstimatorEIP1559FeeCapBufferBlocks func() (uint16, bool) + GlobalBlockHistoryEstimatorTransactionPercentile func() (uint16, bool) + GlobalChainType func() (string, bool) + GlobalEthTxReaperInterval func() (time.Duration, bool) + GlobalEthTxReaperThreshold func() (time.Duration, bool) + GlobalEthTxResendAfterThreshold func() (time.Duration, bool) + GlobalEvmEIP1559DynamicFees func() (bool, bool) + GlobalEvmFinalityDepth func() (uint32, bool) + GlobalEvmGasBumpPercent func() (uint16, bool) + GlobalEvmGasBumpThreshold func() (uint64, bool) + GlobalEvmGasBumpTxDepth func() (uint16, bool) + GlobalEvmGasBumpWei func() (*assets.Wei, bool) + GlobalEvmGasFeeCapDefault func() (*assets.Wei, bool) + GlobalEvmGasLimitDRJobType func() (uint32, bool) + GlobalEvmGasLimitDefault func() (uint32, bool) + GlobalEvmGasLimitFMJobType func() (uint32, bool) + GlobalEvmGasLimitKeeperJobType func() (uint32, bool) + GlobalEvmGasLimitMax func() (uint32, bool) + GlobalEvmGasLimitMultiplier func() (float32, bool) + GlobalEvmGasLimitOCRJobType func() (uint32, bool) + GlobalEvmGasLimitTransfer func() (uint32, bool) + GlobalEvmGasLimitVRFJobType func() (uint32, bool) + GlobalEvmGasPriceDefault func() (*assets.Wei, bool) + GlobalEvmGasTipCapDefault func() (*assets.Wei, bool) + GlobalEvmGasTipCapMinimum func() (*assets.Wei, bool) + GlobalEvmHeadTrackerHistoryDepth func() (uint32, bool) + GlobalEvmHeadTrackerMaxBufferSize func() (uint32, bool) + GlobalEvmHeadTrackerSamplingInterval func() (time.Duration, bool) + GlobalEvmLogBackfillBatchSize func() (uint32, bool) + GlobalEvmLogKeepBlocksDepth func() (uint32, bool) + GlobalEvmLogPollInterval func() (time.Duration, bool) + GlobalEvmMaxGasPriceWei func() (*assets.Wei, bool) + GlobalEvmMaxInFlightTransactions func() (uint32, bool) + GlobalEvmMaxQueuedTransactions func() (uint64, bool) + GlobalEvmMinGasPriceWei func() (*assets.Wei, bool) + GlobalEvmNonceAutoSync func() (bool, bool) + GlobalEvmRPCDefaultBatchSize func() (uint32, bool) + GlobalEvmUseForwarders func() (bool, bool) + GlobalFlagsContractAddress func() (string, bool) + GlobalGasEstimatorMode func() (string, bool) + GlobalLinkContractAddress func() (string, bool) + GlobalMinIncomingConfirmations func() (uint32, bool) + GlobalMinimumContractPayment func() (*assets.Link, bool) + GlobalNodeNoNewHeadsThreshold func() (time.Duration, bool) + GlobalNodePollFailureThreshold func() (uint32, bool) + GlobalNodePollInterval func() (time.Duration, bool) + GlobalNodeSelectionMode func() (string, bool) + GlobalNodeSyncThreshold func() (uint32, bool) + GlobalOCR2AutomationGasLimit func() (uint32, bool) + GlobalOCRContractConfirmations func() (uint16, bool) + GlobalOCRContractTransmitterTransmitTimeout func() (time.Duration, bool) + GlobalOCRDatabaseTimeout func() (time.Duration, bool) + GlobalOCRObservationGracePeriod func() (time.Duration, bool) + GlobalOperatorFactoryAddress func() (string, bool) + type LogFn func(...any) + type OCR1Config interface + OCRBlockchainTimeout func() time.Duration + OCRContractPollInterval func() time.Duration + OCRContractSubscribeInterval func() time.Duration + OCRDefaultTransactionQueueDepth func() uint32 + OCRKeyBundleID func() (string, error) + OCRObservationTimeout func() time.Duration + OCRSimulateTransactions func() bool + OCRTraceLogging func() bool + OCRTransmitterAddress func() (ethkey.EIP55Address, error) + type OCR2Config interface + OCR2BlockchainTimeout func() time.Duration + OCR2ContractConfirmations func() uint16 + OCR2ContractPollInterval func() time.Duration + OCR2ContractSubscribeInterval func() time.Duration + OCR2ContractTransmitterTransmitTimeout func() time.Duration + OCR2DatabaseTimeout func() time.Duration + OCR2KeyBundleID func() (string, error) + OCR2TraceLogging func() bool + type P2PDeprecated interface + type P2PNetworking interface + P2PIncomingMessageBufferSize func() int + P2PNetworkingStack func() (n ocrnetworking.NetworkingStack) + P2PNetworkingStackRaw func() string + P2POutgoingMessageBufferSize func() int + P2PPeerID func() p2pkey.PeerID + P2PPeerIDRaw func() string + type P2PV1Networking interface + P2PAnnounceIP func() net.IP + P2PAnnouncePort func() uint16 + P2PBootstrapCheckInterval func() time.Duration + P2PBootstrapPeers func() ([]string, error) + P2PDHTAnnouncementCounterUserPrefix func() uint32 + P2PDHTLookupInterval func() int + P2PListenIP func() net.IP + P2PListenPort func() uint16 + P2PListenPortRaw func() string + P2PNewStreamTimeout func() time.Duration + P2PPeerstoreWriteInterval func() time.Duration + type P2PV2Networking interface + P2PV2AnnounceAddresses func() []string + P2PV2Bootstrappers func() (locators []ocrcommontypes.BootstrapperLocator) + P2PV2BootstrappersRaw func() []string + P2PV2DeltaDial func() models.Duration + P2PV2DeltaReconcile func() models.Duration + P2PV2ListenAddresses func() []string