forwarders

Documentation

Index

• func NewORM(db *sqlx.DB, lggr logger.Logger, cfg pg.LogConfig) *orm
• type Forwarder
• type FwdMgr
  • func NewFwdMgr(db *sqlx.DB, client evmclient.Client, logpoller evmlogpoller.LogPoller, ...) *FwdMgr
  • func (f *FwdMgr) MaybeForwardTransaction(from common.Address, to common.Address, encodedPayload []byte) (fwdAddr common.Address, fwdPayload []byte, err error)
  • func (f *FwdMgr) Start() error
  • func (f *FwdMgr) Stop() error
• type ORM

Functions

func NewORM

func NewORM(db *sqlx.DB, lggr logger.Logger, cfg pg.LogConfig) *orm

Types

type Forwarder

type Forwarder struct {
	ID         int64
	Address    common.Address
	EVMChainID utils.Big
	CreatedAt  time.Time
	UpdatedAt  time.Time
}

Forwarder is the struct for Forwarder Addresses

type FwdMgr

type FwdMgr struct {
	utils.StartStopOnce
	ORM ORM
	// contains filtered or unexported fields
}

func NewFwdMgr

func NewFwdMgr(db *sqlx.DB, client evmclient.Client, logpoller evmlogpoller.LogPoller, l logger.Logger, cfg pg.LogConfig) *FwdMgr

func (*FwdMgr) MaybeForwardTransaction

func (f *FwdMgr) MaybeForwardTransaction(from common.Address, to common.Address, encodedPayload []byte) (fwdAddr common.Address, fwdPayload []byte, err error)

TODO(samhassan): this should be aware of job type to decide how to fetch senders list.

This is necessary to support ocr1 jobs.
https://app.shortcut.com/chainlinklabs/story/15448/ocr1-feeds-jobs-should-detect-if-they-are-configured-to-use-a-forwarder-contract

func (*FwdMgr) Start

func (f *FwdMgr) Start() error

Start starts Forwarder Manager.

func (*FwdMgr) Stop

func (f *FwdMgr) Stop() error

Stop cancels all outgoings calls and stops internal ticker loop.

type ORM

type ORM interface {
	CreateForwarder(addr common.Address, evmChainId utils.Big) (fwd Forwarder, err error)
	FindForwarders(offset, limit int) ([]Forwarder, int, error)
	FindForwardersByChain(evmChainId utils.Big) ([]Forwarder, error)
	DeleteForwarder(id int32) error
	FindForwardersInListByChain(evmChainId utils.Big, addrs []common.Address) ([]Forwarder, error)
}