ocr2

package

v2.11.0 Latest Latest Go to latest Published: May 1, 2024 License: MIT Imports: 76 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/smartcontractkit/chainlink

Links

Open Source Insights

Documentation ¶

Index ¶

func GetEVMEffectiveTransmitterID(jb *job.Job, chain legacyevm.Chain, lggr logger.SugaredLogger) (string, error)
func NewDB(sqlxDB *sqlx.DB, oracleSpecID int32, pluginID int32, lggr logger.Logger, ...) *db
type Delegate
- func NewDelegate(db *sqlx.DB, jobORM job.ORM, bridgeORM bridges.ORM, mercuryORM evmmercury.ORM, ...) *Delegate
type DelegateConfig
- func NewDelegateConfig(ocr2Cfg ocr2Config, m coreconfig.Mercury, t coreconfig.Threshold, ...) DelegateConfig
type ErrJobSpecNoRelayer
- func (e ErrJobSpecNoRelayer) Error() string
- func (e ErrJobSpecNoRelayer) Unwrap() error
type ErrRelayNotEnabled
- func (e ErrRelayNotEnabled) Error() string
- func (e ErrRelayNotEnabled) Unwrap() error
type RelayGetter

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

func GetEVMEffectiveTransmitterID ¶ added in v2.4.0

func GetEVMEffectiveTransmitterID(jb *job.Job, chain legacyevm.Chain, lggr logger.SugaredLogger) (string, error)

func NewDB ¶

func NewDB(sqlxDB *sqlx.DB, oracleSpecID int32, pluginID int32, lggr logger.Logger, cfg pg.QConfig) *db

NewDB returns a new DB scoped to this oracleSpecID

Types ¶

type Delegate ¶

type Delegate struct {
	RelayGetter
	// contains filtered or unexported fields
}

func NewDelegate ¶

func NewDelegate(
	db *sqlx.DB,
	jobORM job.ORM,
	bridgeORM bridges.ORM,
	mercuryORM evmmercury.ORM,
	pipelineRunner pipeline.Runner,
	streamRegistry streams.Getter,
	peerWrapper *ocrcommon.SingletonPeerWrapper,
	monitoringEndpointGen telemetry.MonitoringEndpointGenerator,
	legacyChains legacyevm.LegacyChainContainer,
	lggr logger.Logger,
	cfg DelegateConfig,
	ks keystore.OCR2,
	dkgSignKs keystore.DKGSign,
	dkgEncryptKs keystore.DKGEncrypt,
	ethKs keystore.Eth,
	relayers RelayGetter,
	mailMon *mailbox.Monitor,
	capabilitiesRegistry types.CapabilitiesRegistry,
) *Delegate

func (*Delegate) AfterJobCreated ¶

func (d *Delegate) AfterJobCreated(spec job.Job)

func (*Delegate) BeforeJobCreated ¶

func (d *Delegate) BeforeJobCreated(spec job.Job)

func (*Delegate) BeforeJobDeleted ¶

func (d *Delegate) BeforeJobDeleted(spec job.Job)

func (*Delegate) JobType ¶

func (d *Delegate) JobType() job.Type

func (*Delegate) OnDeleteJob ¶

func (d *Delegate) OnDeleteJob(ctx context.Context, jb job.Job, q pg.Queryer) error

func (*Delegate) ServicesForSpec ¶

func (d *Delegate) ServicesForSpec(ctx context.Context, jb job.Job) ([]job.ServiceCtx, error)

ServicesForSpec returns the OCR2 services that need to run for this job

type DelegateConfig ¶ added in v2.2.0

type DelegateConfig interface {
	plugins.RegistrarConfig
	OCR2() ocr2Config
	JobPipeline() jobPipelineConfig
	Database() pg.QConfig
	Insecure() insecureConfig
	Mercury() coreconfig.Mercury
	Threshold() coreconfig.Threshold
}

func NewDelegateConfig ¶ added in v2.2.0

func NewDelegateConfig(ocr2Cfg ocr2Config, m coreconfig.Mercury, t coreconfig.Threshold, i insecureConfig, jp jobPipelineConfig, qconf pg.QConfig, pluginProcessCfg plugins.RegistrarConfig) DelegateConfig

type ErrJobSpecNoRelayer ¶ added in v2.5.0

type ErrJobSpecNoRelayer struct {
	PluginName string
	Err        error
}

func (ErrJobSpecNoRelayer) Error ¶ added in v2.8.0

func (e ErrJobSpecNoRelayer) Error() string

func (ErrJobSpecNoRelayer) Unwrap ¶ added in v2.8.0

func (e ErrJobSpecNoRelayer) Unwrap() error

type ErrRelayNotEnabled ¶ added in v2.8.0

type ErrRelayNotEnabled struct {
	PluginName string
	Relay      string
	Err        error
}

func (ErrRelayNotEnabled) Error ¶ added in v2.8.0

func (e ErrRelayNotEnabled) Error() string

func (ErrRelayNotEnabled) Unwrap ¶ added in v2.8.0

func (e ErrRelayNotEnabled) Unwrap() error

type RelayGetter ¶ added in v2.5.0

type RelayGetter interface {
	Get(id relay.ID) (loop.Relayer, error)
}

Source Files ¶

View all Source files

Directories ¶

Path	Synopsis
plugins
dkg
dkg/config
dkg/persistence
functions
functions/config
functions/encoding
functions/integration_tests/v1/internal
generic
llo/config
median
median/config
mercury
mercury/config
ocr2keeper
ocr2keeper/evmregistry/v20
ocr2keeper/evmregistry/v20/mocks
ocr2keeper/evmregistry/v21
ocr2keeper/evmregistry/v21/autotelemetry21
ocr2keeper/evmregistry/v21/core
ocr2keeper/evmregistry/v21/core/mocks
ocr2keeper/evmregistry/v21/encoding
ocr2keeper/evmregistry/v21/logprovider
ocr2keeper/evmregistry/v21/mercury
ocr2keeper/evmregistry/v21/mercury/streams
ocr2keeper/evmregistry/v21/mercury/v02
ocr2keeper/evmregistry/v21/mercury/v03
ocr2keeper/evmregistry/v21/mocks
ocr2keeper/evmregistry/v21/prommetrics
ocr2keeper/evmregistry/v21/transmit
ocr2keeper/evmregistry/v21/upkeepstate
ocr2vrf/config
ocr2vrf/coordinator
ocr2vrf/coordinator/mocks
ocr2vrf/juelsfeecoin
ocr2vrf/reasonablegasprice
ocr2vrf/reportserializer
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).
promwrapper/mocks
s4
threshold
threshold/mocks
testhelpers
validate

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