listener

Documentation

Index

• Constants
• func ParseRelayPackage(abi *abi.ABI, log *types.Log, timestamp uint64, ...) (*model.BscRelayPackage, error)
• type BSCListener
  • func NewBSCListener(cfg *config.Config, bscExecutor *executor.BSCExecutor, ...) *BSCListener
  • func (l *BSCListener) PurgeLoop()
  • func (l *BSCListener) StartLoop()
• type GreenfieldListener
  • func NewGreenfieldListener(cfg *config.Config, gnfdExecutor *executor.GreenfieldExecutor, ...) *GreenfieldListener
  • func (l *GreenfieldListener) PurgeLoop()
  • func (l *GreenfieldListener) StartLoop()

Constants

const (
	NumOfHistoricalBlocks         = int64(50000) // NumOfHistoricalBlocks is the number of blocks will be kept in DB, all transactions and votes also kept within this range
	PurgeJobInterval              = time.Minute * 1
	DeletionLimit                 = 10000
	GreenfieldEventTypeCrossChain = "cosmos.crosschain.v1.EventCrossChain"
	BSCCrossChainPackageEventName = "CrossChainPackage"
	CrossChainPackageEventHex     = "0x64998dc5a229e7324e622192f111c691edccc3534bbea4b2bd90fbaec936845a"
)

Functions

func ParseRelayPackage

func ParseRelayPackage(abi *abi.ABI, log *types.Log, timestamp uint64, greenfieldChainId, bscChainId sdk.ChainID) (*model.BscRelayPackage, error)

Types

type BSCListener

type BSCListener struct {
	DaoManager *dao.DaoManager
	// contains filtered or unexported fields
}

func NewBSCListener

func NewBSCListener(cfg *config.Config, bscExecutor *executor.BSCExecutor, gnfdExecutor *executor.GreenfieldExecutor, dao *dao.DaoManager, ms *metric.MetricService) *BSCListener

func (*BSCListener) PurgeLoop

func (l *BSCListener) PurgeLoop()

func (*BSCListener) StartLoop

func (l *BSCListener) StartLoop()

type GreenfieldListener

type GreenfieldListener struct {
	DaoManager *dao.DaoManager
	// contains filtered or unexported fields
}

func NewGreenfieldListener

func NewGreenfieldListener(cfg *config.Config, gnfdExecutor *executor.GreenfieldExecutor, bscExecutor *executor.BSCExecutor,
	dao *dao.DaoManager, ms *metric.MetricService) *GreenfieldListener

func (*GreenfieldListener) PurgeLoop

func (l *GreenfieldListener) PurgeLoop()

func (*GreenfieldListener) StartLoop

func (l *GreenfieldListener) StartLoop()