services

package

v1.10.17 Latest Latest Go to latest Published: Oct 18, 2021 License: MIT Imports: 22 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/DCMMC/chainlink

Links

Open Source Insights

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 ...interface{}) *promReporter
type BalanceMonitor
- func NewBalanceMonitor(db *gorm.DB, ethClient eth.Client, ethKeyStore keystore.Eth, ...) BalanceMonitor
type NullBalanceMonitor
type PrometheusBackend

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

func ApproximateFloat64 ¶ added in v1.10.16

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

func NewPromReporter ¶ added in v1.10.16

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

Types ¶

type BalanceMonitor ¶ added in v1.10.16

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 ¶ added in v1.10.16

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

NewBalanceMonitor returns a new balanceMonitor

type NullBalanceMonitor ¶ added in v1.10.16

type NullBalanceMonitor struct{}

func (*NullBalanceMonitor) Close ¶ added in v1.10.16

func (*NullBalanceMonitor) Close() error

func (*NullBalanceMonitor) GetEthBalance ¶ added in v1.10.16

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

func (*NullBalanceMonitor) Healthy ¶ added in v1.10.16

func (*NullBalanceMonitor) Healthy() error

func (*NullBalanceMonitor) OnNewLongestChain ¶ added in v1.10.16

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

func (*NullBalanceMonitor) Ready ¶ added in v1.10.16

func (*NullBalanceMonitor) Ready() error

func (*NullBalanceMonitor) Start ¶ added in v1.10.16

func (*NullBalanceMonitor) Start() error

type PrometheusBackend ¶ added in v1.10.16

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

Source Files ¶

View all Source files

Directories ¶

Path	Synopsis
bulletprooftxmanager
mocks
chainlink
cron
directrequest
eth
mocks
feeds
mocks
proto
fluxmonitorv2
mocks
promfm
gas
mocks
headtracker
mocks
types
health
job
mocks
keeper
keystore
keys/csakey
keys/ethkey
keys/ocrkey
keys/p2pkey
keys/vrfkey
mocks
log
mocks
offchainreporting
mocks
periodicbackup
pipeline
mocks
postgres
mocks
signatures
cryptotest Package cryptotest provides convenience functions for kyber-based APIs.	Package cryptotest provides convenience functions for kyber-based APIs.
ethdss Package ethdss implements the Distributed Schnorr Signature protocol from the ////////////////////////////////////////////////////////////////////////////// XXX: Do not use in production until this code has been audited.	Package ethdss implements the Distributed Schnorr Signature protocol from the ////////////////////////////////////////////////////////////////////////////// XXX: Do not use in production until this code has been audited.
ethschnorr Package ethschnorr implements a version of the Schnorr signature which is ////////////////////////////////////////////////////////////////////////////// XXX: Do not use in production until this code has been audited.	Package ethschnorr implements a version of the Schnorr signature which is ////////////////////////////////////////////////////////////////////////////// XXX: Do not use in production until this code has been audited.
secp256k1 Package secp256k1 is an implementation of the kyber.{Group,Point,Scalar} ////////////////////////////////////////////////////////////////////////////// XXX: Do not use in production until this code has been audited.	Package secp256k1 is an implementation of the kyber.{Group,Point,Scalar} ////////////////////////////////////////////////////////////////////////////// XXX: Do not use in production until this code has been audited.
synchronization
mocks
telem
telemetry
versioning
vrf
mocks
proof
webhook
mocks

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