vrf

Documentation

Index

• Variables
• func ValidatedVRFSpec(tomlString string) (job.Job, error)
• type Config
• type Delegate
  • func NewDelegate(db *gorm.DB, txm bulletprooftxmanager.TxManager, ks *keystore.Master, ...) *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(jb job.Job) ([]job.Service, error)
• type GethKeyStore

Variables

var (
	ErrKeyNotSet = errors.New("key not set")
)

Functions

func ValidatedVRFSpec

func ValidatedVRFSpec(tomlString string) (job.Job, error)

Types

type Config

type Config interface {
	MinIncomingConfirmations() uint32
	EthGasLimitDefault() uint64
}

type Delegate

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

func NewDelegate

func NewDelegate(
	db *gorm.DB,
	txm bulletprooftxmanager.TxManager,
	ks *keystore.Master,
	pr pipeline.Runner,
	porm pipeline.ORM,
	lb log.Broadcaster,
	headBroadcaster httypes.HeadBroadcasterRegistry,
	ec eth.Client,
	cfg Config) *Delegate

func (*Delegate) AfterJobCreated

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

func (*Delegate) BeforeJobDeleted

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

func (*Delegate) JobType

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

func (*Delegate) ServicesForSpec

func (d *Delegate) ServicesForSpec(jb job.Job) ([]job.Service, error)

type GethKeyStore

type GethKeyStore interface {
	GetRoundRobinAddress(addresses ...common.Address) (common.Address, error)
}