Versions in this module Expand all Collapse all v2 v2.4.0 Nov 13, 2024 v2.3.0 Nov 13, 2024 v2.1.1 Nov 13, 2024 v2.1.0 Nov 11, 2024 Changes in this version + func FilterName(addr common.Address) string + func NewORM(db *sqlx.DB, lggr logger.Logger, cfg pg.QConfig) *orm + type Config interface + FinalityDepth func() uint32 + type Forwarder struct + Address common.Address + CreatedAt time.Time + EVMChainID big.Big + ID int64 + UpdatedAt time.Time + type FwdMgr struct + ORM ORM + func NewFwdMgr(db *sqlx.DB, client evmclient.Client, logpoller evmlogpoller.LogPoller, ...) *FwdMgr + func (f *FwdMgr) Close() error + func (f *FwdMgr) ConvertPayload(dest common.Address, origPayload []byte) ([]byte, error) + func (f *FwdMgr) ForwarderFor(addr common.Address) (forwarder common.Address, err error) + func (f *FwdMgr) HealthReport() map[string]error + func (f *FwdMgr) Name() string + func (f *FwdMgr) Start(ctx context.Context) error + type ORM interface + CreateForwarder func(addr common.Address, evmChainId big.Big) (fwd Forwarder, err error) + DeleteForwarder func(id int64, ...) error + FindForwarders func(offset, limit int) ([]Forwarder, int, error) + FindForwardersByChain func(evmChainId big.Big) ([]Forwarder, error) + FindForwardersInListByChain func(evmChainId big.Big, addrs []common.Address) ([]Forwarder, error)