listener

Documentation

Index

• Constants
• func ParseRelayPackage(abi *abi.ABI, log *types.Log, timestamp uint64, ...) (*model.BscRelayPackage, error)
• func ParseZkmeSBTRelayPackage(abi *abi.ABI, log *types.Log, timestamp uint64, ...) (*model.GreenfieldRelayTransaction, 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"
	ZkmeSBTCrossChainPackageEventName = "ZkmeSBTCrossChainPackage"
	CrossChainPackageEventHex         = "0x64998dc5a229e7324e622192f111c691edccc3534bbea4b2bd90fbaec936845a"
	ZkmeSBTCrossChainPackageEventHex  = "0xc9f87fd9c5d4247a74066dab91cf75ddcd8d8ffd96b65be03729ffb11c9aed7f"
)

Functions

func ParseRelayPackage

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

func ParseZkmeSBTRelayPackage

func ParseZkmeSBTRelayPackage(abi *abi.ABI, log *types.Log, timestamp uint64, greenfieldChainId, bscChainId sdk.ChainID) (*model.GreenfieldRelayTransaction, 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()