Documentation ¶
Index ¶
- type 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
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
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 ¶ added in v1.0.6
func (*SimpleSubscriber) Stop ¶
func (s *SimpleSubscriber) Stop()
func (*SimpleSubscriber) StoreCrossContractLog ¶
func (*SimpleSubscriber) SubscribeBlockEvent ¶ added in v1.0.6
func (s *SimpleSubscriber) SubscribeBlockEvent(ch chan<- cc.CrossBlockEvent) event.Subscription
Click to show internal directories.
Click to hide internal directories.