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, lggr logger.Logger, opts ...interface{}) *promReporter
• type BalanceMonitor
  • func NewBalanceMonitor(ethClient eth.Client, ethKeyStore keystore.Eth, logger logger.Logger) 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 *eth.Head)
  • func (*NullBalanceMonitor) Ready() error
  • func (*NullBalanceMonitor) Start() error
• type PrometheusBackend

Functions

func ApproximateFloat64

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

func NewPromReporter

func NewPromReporter(db *sql.DB, lggr logger.Logger, opts ...interface{}) *promReporter

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(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 *eth.Head)

func (*NullBalanceMonitor) Ready

func (*NullBalanceMonitor) Ready() error

func (*NullBalanceMonitor) Start

func (*NullBalanceMonitor) Start() error

type PrometheusBackend

type PrometheusBackend interface {
	SetUnconfirmedTransactions(*big.Int, int64)
	SetMaxUnconfirmedAge(*big.Int, float64)
	SetMaxUnconfirmedBlocks(*big.Int, int64)
	SetPipelineRunsQueued(n int)
	SetPipelineTaskRunsQueued(n int)
}