ocrbootstrap

Documentation

Index

• func NewDB(sqldb *sql.DB, bootstrapSpecID int32, lggr logger.Logger) *db
• func ValidatedBootstrapSpecToml(tomlString string) (jb job.Job, err error)
• type Delegate
  • func NewDelegateBootstrap(db *sqlx.DB, jobORM job.ORM, peerWrapper *ocrcommon.SingletonPeerWrapper, ...) *Delegate
  • func (d Delegate) AfterJobCreated(spec job.Job)
  • func (d *Delegate) BeforeJobCreated(spec job.Job)
  • func (d Delegate) BeforeJobDeleted(spec job.Job)
  • func (d *Delegate) JobType() job.Type
  • func (d *Delegate) ServicesForSpec(jobSpec job.Job) (services []job.ServiceCtx, err error)

Functions

func NewDB

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

NewDB returns a new DB scoped to this oracleSpecID

func ValidatedBootstrapSpecToml

func ValidatedBootstrapSpecToml(tomlString string) (jb job.Job, err error)

ValidatedBootstrapSpecToml validates a bootstrap spec that came from TOML

Types

type Delegate

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

Delegate creates Bootstrap jobs

func NewDelegateBootstrap

func NewDelegateBootstrap(
	db *sqlx.DB,
	jobORM job.ORM,
	peerWrapper *ocrcommon.SingletonPeerWrapper,
	lggr logger.Logger,
	cfg validate.Config,
	relayers map[relay.Network]types.Relayer,
) *Delegate

NewDelegateBootstrap creates a new Delegate

func (Delegate) AfterJobCreated

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

AfterJobCreated satisfies the job.Delegate interface.

func (*Delegate) BeforeJobCreated

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

func (Delegate) BeforeJobDeleted

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

BeforeJobDeleted satisfies the job.Delegate interface.

func (*Delegate) JobType

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

JobType satisfies the job.Delegate interface.

func (*Delegate) ServicesForSpec

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

ServicesForSpec satisfies the job.Delegate interface.