relayer

Documentation

Index

• type BSCRelayer
  • func NewBSCRelayer(listener *listener.BSCListener, ...) *BSCRelayer
  • func (r *BSCRelayer) AssemblePackagesLoop()
  • func (r *BSCRelayer) ClaimRewardLoop()
  • func (r *BSCRelayer) CollectVotesLoop()
  • func (r *BSCRelayer) MonitorEventsLoop()
  • func (r *BSCRelayer) PurgeLoop()
  • func (r *BSCRelayer) SignAndBroadcastVoteLoop()
  • func (r *BSCRelayer) Start()
  • func (r *BSCRelayer) UpdateCachedLatestValidatorsLoop()
  • func (r *BSCRelayer) UpdateClientLoop()
• type GreenfieldRelayer
  • func NewGreenfieldRelayer(listener *listener.GreenfieldListener, ...) *GreenfieldRelayer
  • func (r *GreenfieldRelayer) AssembleTransactionsLoop()
  • func (r *GreenfieldRelayer) CollectVotesLoop()
  • func (r *GreenfieldRelayer) MonitorEventsLoop()
  • func (r *GreenfieldRelayer) PurgeLoop()
  • func (r *GreenfieldRelayer) SignAndBroadcastLoop()
  • func (r *GreenfieldRelayer) Start()
  • func (r *GreenfieldRelayer) UpdateCachedLatestValidatorsLoop()

Types

type BSCRelayer

type BSCRelayer struct {
	Listener           *listener.BSCListener
	GreenfieldExecutor *executor.GreenfieldExecutor
	// contains filtered or unexported fields
}

func NewBSCRelayer

func NewBSCRelayer(listener *listener.BSCListener, greenfieldExecutor *executor.GreenfieldExecutor,
	bscExecutor *executor.BSCExecutor, voteProcessor *vote.BSCVoteProcessor,
	bscAssembler *assembler.BSCAssembler,
) *BSCRelayer

func (*BSCRelayer) AssemblePackagesLoop

func (r *BSCRelayer) AssemblePackagesLoop()

func (*BSCRelayer) ClaimRewardLoop

func (r *BSCRelayer) ClaimRewardLoop()

func (*BSCRelayer) CollectVotesLoop

func (r *BSCRelayer) CollectVotesLoop()

func (*BSCRelayer) MonitorEventsLoop

func (r *BSCRelayer) MonitorEventsLoop()

MonitorEventsLoop will monitor cross chain events for every block and persist into DB

func (*BSCRelayer) PurgeLoop

func (r *BSCRelayer) PurgeLoop()

func (*BSCRelayer) SignAndBroadcastVoteLoop

func (r *BSCRelayer) SignAndBroadcastVoteLoop()

func (*BSCRelayer) Start

func (r *BSCRelayer) Start()

func (*BSCRelayer) UpdateCachedLatestValidatorsLoop

func (r *BSCRelayer) UpdateCachedLatestValidatorsLoop()

func (*BSCRelayer) UpdateClientLoop

func (r *BSCRelayer) UpdateClientLoop()

type GreenfieldRelayer

type GreenfieldRelayer struct {
	Listener           *listener.GreenfieldListener
	GreenfieldExecutor *executor.GreenfieldExecutor
	// contains filtered or unexported fields
}

func NewGreenfieldRelayer

func NewGreenfieldRelayer(listener *listener.GreenfieldListener, greenfieldExecutor *executor.GreenfieldExecutor, bscExecutor *executor.BSCExecutor, voteProcessor *vote.GreenfieldVoteProcessor, greenfieldAssembler *assembler.GreenfieldAssembler,
) *GreenfieldRelayer

func (*GreenfieldRelayer) AssembleTransactionsLoop

func (r *GreenfieldRelayer) AssembleTransactionsLoop()

func (*GreenfieldRelayer) CollectVotesLoop

func (r *GreenfieldRelayer) CollectVotesLoop()

func (*GreenfieldRelayer) MonitorEventsLoop

func (r *GreenfieldRelayer) MonitorEventsLoop()

MonitorEventsLoop will monitor cross chain events for every block and persist into DB

func (*GreenfieldRelayer) PurgeLoop

func (r *GreenfieldRelayer) PurgeLoop()

func (*GreenfieldRelayer) SignAndBroadcastLoop

func (r *GreenfieldRelayer) SignAndBroadcastLoop()

func (*GreenfieldRelayer) Start

func (r *GreenfieldRelayer) Start()

func (*GreenfieldRelayer) UpdateCachedLatestValidatorsLoop

func (r *GreenfieldRelayer) UpdateCachedLatestValidatorsLoop()