services

Documentation

Overview

Package services contain the key components of the Chainlink node. This includes the Application, JobRunner, LogListener, and Scheduler.

Application

The Application is the main component used for starting and stopping the Chainlink node.

JobRunner

The JobRunner keeps track of Runs within a Job and ensures that they're executed in order. Within each Run, the tasks are also executed from the JobRunner.

JobSubscriber

The JobSubscriber coordinates running job events with the EventLog in the Store, and also subscribes to the given address on the Ethereum blockchain.

Scheduler

The Scheduler ensures that recurring events are executed according to their schedule, and one-time events occur only when the specified time has passed.

Index

• func ApproximateFloat64(e *assets.Eth) (float64, error)
• func NewPromReporter(db *sql.DB, opts ...PrometheusBackend) *promReporter
• func NewSessionReaper(db *gorm.DB, config SessionReaperConfig) utils.SleeperTask
• func ValidateBridgeType(bt *models.BridgeTypeRequest, store *store.Store) error
• func ValidateBridgeTypeNotExist(bt *models.BridgeTypeRequest, store *store.Store) error
• func ValidateExternalInitiator(exi *models.ExternalInitiatorRequest, store *store.Store) error
• type BalanceMonitor
  • func NewBalanceMonitor(db *gorm.DB, ethClient eth.Client, ethKeyStore keystore.Eth, ...) BalanceMonitor
• type NullBalanceMonitor
  • func (*NullBalanceMonitor) Close() error
  • func (*NullBalanceMonitor) GetEthBalance(gethCommon.Address) *assets.Eth
  • func (*NullBalanceMonitor) Healthy() error
  • func (*NullBalanceMonitor) OnNewLongestChain(ctx context.Context, head models.Head)
  • func (*NullBalanceMonitor) Ready() error
  • func (*NullBalanceMonitor) Start() error
• type PrometheusBackend
• type SessionReaperConfig

Functions

func ApproximateFloat64

func ApproximateFloat64(e *assets.Eth) (float64, error)

func NewPromReporter

func NewPromReporter(db *sql.DB, opts ...PrometheusBackend) *promReporter

func NewSessionReaper

func NewSessionReaper(db *gorm.DB, config SessionReaperConfig) utils.SleeperTask

NewSessionReaper creates a reaper that cleans stale sessions from the store.

func ValidateBridgeType

func ValidateBridgeType(bt *models.BridgeTypeRequest, store *store.Store) error

ValidateBridgeType checks that the bridge type doesn't have a duplicate or invalid name or invalid url

func ValidateBridgeTypeNotExist

func ValidateBridgeTypeNotExist(bt *models.BridgeTypeRequest, store *store.Store) error

ValidateBridgeTypeNotExist checks that a bridge has not already been created

func ValidateExternalInitiator

func ValidateExternalInitiator(
	exi *models.ExternalInitiatorRequest,
	store *store.Store,
) error

ValidateExternalInitiator checks whether External Initiator parameters are safe for processing.

Types

type BalanceMonitor

type BalanceMonitor interface {
	httypes.HeadTrackable
	GetEthBalance(gethCommon.Address) *assets.Eth
	service.Service
}

BalanceMonitor checks the balance for each key on every new head

func NewBalanceMonitor

func NewBalanceMonitor(db *gorm.DB, ethClient eth.Client, ethKeyStore keystore.Eth, logger *logger.Logger) BalanceMonitor

NewBalanceMonitor returns a new balanceMonitor

type NullBalanceMonitor

type NullBalanceMonitor struct{}

func (*NullBalanceMonitor) Close

func (*NullBalanceMonitor) Close() error

func (*NullBalanceMonitor) GetEthBalance

func (*NullBalanceMonitor) GetEthBalance(gethCommon.Address) *assets.Eth

func (*NullBalanceMonitor) Healthy

func (*NullBalanceMonitor) Healthy() error

func (*NullBalanceMonitor) OnNewLongestChain

func (*NullBalanceMonitor) OnNewLongestChain(ctx context.Context, head models.Head)

func (*NullBalanceMonitor) Ready

func (*NullBalanceMonitor) Ready() error

func (*NullBalanceMonitor) Start

func (*NullBalanceMonitor) Start() error

type PrometheusBackend

type PrometheusBackend interface {
	SetUnconfirmedTransactions(int64)
	SetMaxUnconfirmedAge(float64)
	SetMaxUnconfirmedBlocks(int64)
	SetPipelineRunsQueued(n int)
	SetPipelineTaskRunsQueued(n int)
}

type SessionReaperConfig

type SessionReaperConfig interface {
	SessionTimeout() models.Duration
	ReaperExpiration() models.Duration
}