subscriber

Documentation

Index

• type SimpleSubscriber
  • func NewSimpleSubscriber(contract common.Address, chain chainRetriever, journalPath string) *SimpleSubscriber
  • func (s *SimpleSubscriber) NotifyBlockReorg(number *big.Int, deletedLogs [][]*types.Log, rebirthLogs [][]*types.Log)
  • func (s *SimpleSubscriber) Stop()
  • func (s *SimpleSubscriber) StoreCrossContractLog(blockNumber uint64, hash common.Hash, logs []*types.Log)
  • func (s *SimpleSubscriber) SubscribeBlockEvent(ch chan<- cc.CrossBlockEvent) event.Subscription

Types

type SimpleSubscriber

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

func NewSimpleSubscriber

func NewSimpleSubscriber(contract common.Address, chain chainRetriever, journalPath string) *SimpleSubscriber

func (*SimpleSubscriber) NotifyBlockReorg

func (s *SimpleSubscriber) NotifyBlockReorg(number *big.Int, deletedLogs [][]*types.Log, rebirthLogs [][]*types.Log)

func (*SimpleSubscriber) Stop

func (s *SimpleSubscriber) Stop()

func (*SimpleSubscriber) StoreCrossContractLog

func (s *SimpleSubscriber) StoreCrossContractLog(blockNumber uint64, hash common.Hash, logs []*types.Log)

func (*SimpleSubscriber) SubscribeBlockEvent

func (s *SimpleSubscriber) SubscribeBlockEvent(ch chan<- cc.CrossBlockEvent) event.Subscription