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) 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) 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.