relayer

Documentation

Index

• type RelayerBridgeRelation
  • func NewRelayerBridgeRelation(db *database.DB, bridgeRpcService bridge.BridgeRpcService, ...) (*RelayerBridgeRelation, error)
  • func (rbr *RelayerBridgeRelation) ChangeTransferStatus() error
  • func (rbr *RelayerBridgeRelation) CrossChainTransfer() error
  • func (rbr *RelayerBridgeRelation) Start() error
• type RelayerFundingPool
  • func NewRelayerFundingPool(db *database.DB, bridgeRpcService bridge.BridgeRpcService, rpcS []*config.RPC, ...) (*RelayerFundingPool, error)
  • func (rfp *RelayerFundingPool) FundingPoolCross()
  • func (rfp *RelayerFundingPool) ScanL1NeedFundBalance() error
  • func (rfp *RelayerFundingPool) ScanL2NeedFundBalance() error
  • func (rfp *RelayerFundingPool) Start() error
• type RelayerListener
  • func NewRelayerListener(db *database.DB, chainId string, l1Contracts []string, l2Contracts []string, ...) (*RelayerListener, error)
  • func (rl *RelayerListener) Start() error

Types

type RelayerBridgeRelation

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

func NewRelayerBridgeRelation

func NewRelayerBridgeRelation(
	db *database.DB,
	bridgeRpcService bridge.BridgeRpcService,
	shutdown context.CancelCauseFunc) (*RelayerBridgeRelation, error)

func (*RelayerBridgeRelation) ChangeTransferStatus

func (rbr *RelayerBridgeRelation) ChangeTransferStatus() error

func (*RelayerBridgeRelation) CrossChainTransfer

func (rbr *RelayerBridgeRelation) CrossChainTransfer() error

func (*RelayerBridgeRelation) Start

func (rbr *RelayerBridgeRelation) Start() error

type RelayerFundingPool

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

func NewRelayerFundingPool

func NewRelayerFundingPool(
	db *database.DB,
	bridgeRpcService bridge.BridgeRpcService,
	rpcS []*config.RPC,
	shutdown context.CancelCauseFunc) (*RelayerFundingPool, error)

func (*RelayerFundingPool) FundingPoolCross

func (rfp *RelayerFundingPool) FundingPoolCross()

func (*RelayerFundingPool) ScanL1NeedFundBalance

func (rfp *RelayerFundingPool) ScanL1NeedFundBalance() error

func (*RelayerFundingPool) ScanL2NeedFundBalance

func (rfp *RelayerFundingPool) ScanL2NeedFundBalance() error

func (*RelayerFundingPool) Start

func (rfp *RelayerFundingPool) Start() error

type RelayerListener

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

func NewRelayerListener

func NewRelayerListener(
	db *database.DB,
	chainId string,
	l1Contracts []string,
	l2Contracts []string,
	l1EventStartBlock uint64,
	l2EventStartBlock uint64,
	layerType int,
	shutdown context.CancelCauseFunc,
	loopInterval time.Duration, epoch uint64) (*RelayerListener, error)

func (*RelayerListener) Start

func (rl *RelayerListener) Start() error