Documentation
¶
Index ¶
- func FilterName(addr common.Address) string
- func NewORM(db *sqlx.DB, lggr logger.Logger, cfg pg.QConfig) *orm
- type Config
- type Forwarder
- type 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
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func FilterName ¶ added in v2.1.0
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 (*FwdMgr) ConvertPayload ¶
func (*FwdMgr) ForwarderFor ¶
func (*FwdMgr) HealthReport ¶
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 int64, cleanup func(tx pg.Queryer, evmChainId int64, addr common.Address) error) error
FindForwardersInListByChain(evmChainId utils.Big, addrs []common.Address) ([]Forwarder, error)
}
Click to show internal directories.
Click to hide internal directories.