ocr2

package
v2.12.0-rc3 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Jun 5, 2024 License: MIT Imports: 74 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func GetEVMEffectiveTransmitterID added in v2.4.0

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

func NewDB

func NewDB(ds sqlutil.DataSource, oracleSpecID int32, pluginID int32, lggr logger.Logger) *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(
	ds sqlutil.DataSource,
	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 core.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) 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
	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, 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 types.RelayID) (loop.Relayer, error)
	GetIDToRelayerMap() (map[types.RelayID]loop.Relayer, error)
}

Jump to

Keyboard shortcuts

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