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 ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
Types ¶
type Checker ¶
type Checker interface { // Register a service for health checks. Register(service services.HealthReporter) error // Unregister a service. Unregister(name string) error // IsReady returns the current readiness of the system. // A system is considered ready if all checks are passing (no errors) IsReady() (ready bool, errors map[string]error) // IsHealthy returns the current health of the system. // A system is considered healthy if all checks are passing (no errors) IsHealthy() (healthy bool, errors map[string]error) Start() error Close() error }
Checker provides a service which can be probed for system health.
type Config ¶
type Config interface { BlockProfileRate() int CPUProfileRate() int GatherDuration() commonconfig.Duration GatherTraceDuration() commonconfig.Duration GoroutineThreshold() int MaxProfileSize() utils.FileSize MemProfileRate() int MemThreshold() utils.FileSize MutexProfileFraction() int PollInterval() commonconfig.Duration ProfileRoot() string }
type InBackupHealthReport ¶ added in v2.4.0
type InBackupHealthReport struct {
// contains filtered or unexported fields
}
func NewInBackupHealthReport ¶ added in v2.4.0
func NewInBackupHealthReport(port uint16, lggr logger.Logger) *InBackupHealthReport
NewInBackupHealthReport creates a new InBackupHealthReport that will serve the /health endpoint, useful for preventing shutdowns due to health-checks when running long backup tasks
func (*InBackupHealthReport) Start ¶ added in v2.4.0
func (i *InBackupHealthReport) Start()
func (*InBackupHealthReport) Stop ¶ added in v2.4.0
func (i *InBackupHealthReport) Stop()
type MultiStart ¶
type MultiStart = services.MultiStart
MultiStart is a utility for starting multiple services together. The set of started services is tracked internally, so that they can be closed if any single service fails to start.
type Nurse ¶
type Nurse struct { services.StateMachine // contains filtered or unexported fields }
func (*Nurse) GatherVitals ¶
type ServiceCtx ¶
type StartClose ¶
type StartClose = services.StartClose
StartClose is a subset of the ServiceCtx interface.
Directories ¶
Path | Synopsis |
---|---|
The blockhash store package provides a service that stores blockhashes such that they are available for on-chain proofs beyond the EVM 256 block limit.
|
The blockhash store package provides a service that stores blockhashes such that they are available for on-chain proofs beyond the EVM 256 block limit. |
The block header feeder package enables automated lookback and blockhash filling beyond the EVM 256 block lookback window to catch missed block hashes.
|
The block header feeder package enables automated lookback and blockhash filling beyond the EVM 256 block lookback window to catch missed block hashes. |
plugins/promwrapper
promwrapper wraps another OCR2 reporting plugin and provides standardized prometheus metrics for each of the OCR2 phases (Query, Observation, Report, ShouldAcceptFinalizedReport, ShouldTransmitAcceptedReport, and Close).
|
promwrapper wraps another OCR2 reporting plugin and provides standardized prometheus metrics for each of the OCR2 phases (Query, Observation, Report, ShouldAcceptFinalizedReport, ShouldTransmitAcceptedReport, and Close). |
relay
|
|
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 //////////////////////////////////////////////////////////////////////////////
|
Package ethdss implements the Distributed Schnorr Signature protocol from the ////////////////////////////////////////////////////////////////////////////// |
ethschnorr
Package ethschnorr implements a version of the Schnorr signature which is //////////////////////////////////////////////////////////////////////////////
|
Package ethschnorr implements a version of the Schnorr signature which is ////////////////////////////////////////////////////////////////////////////// |
secp256k1
Package secp256k1 is an implementation of the kyber.{Group,Point,Scalar} //////////////////////////////////////////////////////////////////////////////
|
Package secp256k1 is an implementation of the kyber.{Group,Point,Scalar} ////////////////////////////////////////////////////////////////////////////// |