Documentation ¶
Index ¶
- func FilterName(addr common.Address) string
- type Config
- type DbORM
- func (o *DbORM) CreateForwarder(ctx context.Context, addr common.Address, evmChainId big.Big) (fwd Forwarder, err error)
- func (o *DbORM) DeleteForwarder(ctx context.Context, id int64, ...) (err error)
- func (o *DbORM) FindForwarders(ctx context.Context, offset, limit int) (fwds []Forwarder, count int, err error)
- func (o *DbORM) FindForwardersByChain(ctx context.Context, evmChainId big.Big) (fwds []Forwarder, err error)
- func (o *DbORM) FindForwardersInListByChain(ctx context.Context, evmChainId big.Big, addrs []common.Address) ([]Forwarder, error)
- func (o *DbORM) Transaction(ctx context.Context, fn func(*DbORM) error) (err error)
- 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 DbORM ¶ added in v2.11.0
type DbORM struct {
// contains filtered or unexported fields
}
func NewORM ¶
func NewORM(db sqlutil.DataSource) *DbORM
func (*DbORM) CreateForwarder ¶ added in v2.11.0
func (o *DbORM) CreateForwarder(ctx context.Context, addr common.Address, evmChainId big.Big) (fwd Forwarder, err error)
CreateForwarder creates the Forwarder address associated with the current EVM chain id.
func (*DbORM) DeleteForwarder ¶ added in v2.11.0
func (o *DbORM) DeleteForwarder(ctx context.Context, id int64, cleanup func(tx sqlutil.DataSource, evmChainID int64, addr common.Address) error) (err error)
DeleteForwarder removes a forwarder address. If cleanup is non-nil, it can be used to perform any chain- or contract-specific cleanup that need to happen atomically on forwarder deletion. If cleanup returns an error, forwarder deletion will be aborted.
func (*DbORM) FindForwarders ¶ added in v2.11.0
func (o *DbORM) FindForwarders(ctx context.Context, offset, limit int) (fwds []Forwarder, count int, err error)
FindForwarders returns all forwarder addresses from offset up until limit.
func (*DbORM) FindForwardersByChain ¶ added in v2.11.0
func (o *DbORM) FindForwardersByChain(ctx context.Context, evmChainId big.Big) (fwds []Forwarder, err error)
FindForwardersByChain returns all forwarder addresses for a chain.
func (*DbORM) FindForwardersInListByChain ¶ added in v2.11.0
type Forwarder ¶
type Forwarder struct { ID int64 Address common.Address EVMChainID big.Big CreatedAt time.Time UpdatedAt time.Time }
Forwarder is the struct for Forwarder Addresses
type FwdMgr ¶
type FwdMgr struct { services.StateMachine ORM ORM // contains filtered or unexported fields }
func NewFwdMgr ¶
func NewFwdMgr(db sqlutil.DataSource, client evmclient.Client, logpoller evmlogpoller.LogPoller, l logger.Logger, cfg Config) *FwdMgr
func (*FwdMgr) ConvertPayload ¶
func (*FwdMgr) ForwarderFor ¶
func (*FwdMgr) HealthReport ¶
type ORM ¶
type ORM interface { CreateForwarder(ctx context.Context, addr common.Address, evmChainId big.Big) (fwd Forwarder, err error) FindForwarders(ctx context.Context, offset, limit int) ([]Forwarder, int, error) FindForwardersByChain(ctx context.Context, evmChainId big.Big) ([]Forwarder, error) DeleteForwarder(ctx context.Context, id int64, cleanup func(tx sqlutil.DataSource, evmChainId int64, addr common.Address) error) error FindForwardersInListByChain(ctx context.Context, evmChainId big.Big, addrs []common.Address) ([]Forwarder, error) }
Click to show internal directories.
Click to hide internal directories.