watcher

Documentation

Index

• Variables
• func ReadBlockNumberFromFile(filePath string) (*big.Int, error)
• func WriteCheckpointBlockNumberToFile(filePath string, blkNumber *big.Int) error
• type EthEventLogWatcher
  • func NewEthEventLogWatcher(c *rpc.Client, ethCfg *config.EthCfg, blkFile string, ldb *db.Ldb) (*EthEventLogWatcher, error)
  • func (logW *EthEventLogWatcher) CheckLogs(blkNumber *big.Int) error
  • func (logW *EthEventLogWatcher) DelKey(key []byte) error
  • func (logW *EthEventLogWatcher) Initial(events map[common.Hash]EventHandler) error
  • func (logW *EthEventLogWatcher) Listen()
  • func (logW *EthEventLogWatcher) PutByte(key, value []byte) error
  • func (logW *EthEventLogWatcher) ReSendGrpcStream() error
  • func (logW *EthEventLogWatcher) SetGrpcStreamDB(isSendOK bool, infoType string, keyIndex string, value []byte) error
  • func (logW *EthEventLogWatcher) Stop()
• type EventHandler

Variables

var (
	PubEventMap = map[common.Hash]EventHandler{
				// contains filtered or unexported fields
	}
	PriEventMap = map[common.Hash]EventHandler{
				// contains filtered or unexported fields
	}
)

Functions

func ReadBlockNumberFromFile

func ReadBlockNumberFromFile(filePath string) (*big.Int, error)

func WriteCheckpointBlockNumberToFile

func WriteCheckpointBlockNumberToFile(filePath string, blkNumber *big.Int) error

Types

type EthEventLogWatcher

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

func NewEthEventLogWatcher

func NewEthEventLogWatcher(c *rpc.Client, ethCfg *config.EthCfg, blkFile string, ldb *db.Ldb) (*EthEventLogWatcher, error)

func (*EthEventLogWatcher) CheckLogs

func (logW *EthEventLogWatcher) CheckLogs(blkNumber *big.Int) error

待修改

func (*EthEventLogWatcher) DelKey

func (logW *EthEventLogWatcher) DelKey(key []byte) error

func (*EthEventLogWatcher) Initial

func (logW *EthEventLogWatcher) Initial(events map[common.Hash]EventHandler) error

func (*EthEventLogWatcher) Listen

func (logW *EthEventLogWatcher) Listen()

func (*EthEventLogWatcher) PutByte

func (logW *EthEventLogWatcher) PutByte(key, value []byte) error

func (*EthEventLogWatcher) ReSendGrpcStream

func (logW *EthEventLogWatcher) ReSendGrpcStream() error

GRPC重发检测

func (*EthEventLogWatcher) SetGrpcStreamDB

func (logW *EthEventLogWatcher) SetGrpcStreamDB(isSendOK bool, infoType string, keyIndex string, value []byte) error

func (*EthEventLogWatcher) Stop

func (logW *EthEventLogWatcher) Stop()

type EventHandler

type EventHandler func(logW *EthEventLogWatcher, log *types.Log) error