offchainreporting2

Documentation

Index

• func NewDB(sqldb *sql.DB, oracleSpecID int32, lggr logger.Logger) *db
• func ToLocalConfig(config Config, spec job.OffchainReporting2OracleSpec) types.LocalConfig
• func ValidatedOracleSpecToml(config Config, tomlString string) (job.Job, error)
• type Config
• type Delegate
  • func NewDelegate(db *sqlx.DB, jobORM job.ORM, pipelineRunner pipeline.Runner, ...) *Delegate
  • func (Delegate) AfterJobCreated(spec job.Job)
  • func (Delegate) BeforeJobDeleted(spec job.Job)
  • func (d Delegate) JobType() job.Type
  • func (Delegate) OnJobCreated(spec job.Job)
  • func (Delegate) OnJobDeleted(spec job.Job)
  • func (d Delegate) ServicesForSpec(jobSpec job.Job) (services []job.Service, err error)

Functions

func NewDB

func NewDB(sqldb *sql.DB, oracleSpecID int32, lggr logger.Logger) *db

NewDB returns a new DB scoped to this oracleSpecID

func ToLocalConfig

func ToLocalConfig(config Config, spec job.OffchainReporting2OracleSpec) types.LocalConfig

ToLocalConfig creates a OCR2 LocalConfig from the global config and the OCR2 spec.

func ValidatedOracleSpecToml

func ValidatedOracleSpecToml(config Config, tomlString string) (job.Job, error)

ValidatedOracleSpecToml validates an oracle spec that came from TOML

Types

type Config

type Config interface {
	config.OCR2Config
	Dev() bool
	JobPipelineResultWriteQueueDepth() uint64
}

Config contains OCR2 configurations for a job.

type Delegate

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

func NewDelegate

func NewDelegate(
	db *sqlx.DB,
	jobORM job.ORM,
	pipelineRunner pipeline.Runner,
	peerWrapper *ocrcommon.SingletonPeerWrapper,
	monitoringEndpointGen telemetry.MonitoringEndpointGenerator,
	chainSet evm.ChainSet,
	lggr logger.Logger,
	cfg Config,
	ks keystore.OCR2,
	relayer types.Relayer,
) *Delegate

func (Delegate) AfterJobCreated

func (Delegate) AfterJobCreated(spec job.Job)

func (Delegate) BeforeJobDeleted

func (Delegate) BeforeJobDeleted(spec job.Job)

func (Delegate) JobType

func (d Delegate) JobType() job.Type

func (Delegate) OnJobCreated

func (Delegate) OnJobCreated(spec job.Job)

func (Delegate) OnJobDeleted

func (Delegate) OnJobDeleted(spec job.Job)

func (Delegate) ServicesForSpec

func (d Delegate) ServicesForSpec(jobSpec job.Job) (services []job.Service, err error)