tasks

Documentation

Index

• type ITaskBase
• type SyncChainLogs
  • func NewSyncChainLogs(syncStartBlock int64, addressRpc string, fnCurrSyncBlock func() (int64, error), ...) *SyncChainLogs
  • func (p *SyncChainLogs) AddContracts(contracts ...common.Address)
  • func (obj *SyncChainLogs) AddTopics(tops ...common.Hash)
  • func (p *SyncChainLogs) AddVlogHandler(handler VlogManager)
  • func (obj *SyncChainLogs) InitCfg(addressSer string, fnSyncNumber func() (int64, error), ...)
  • func (obj *SyncChainLogs) Run()
  • func (obj *SyncChainLogs) SyncLogsData(curNumber int64)
• type TaskBase
  • func NewTaskBase(_step int, _job ITaskBase) *TaskBase
  • func (obj *TaskBase) Run()
• type VlogManager

Types

type ITaskBase

type ITaskBase interface {
	Job() (bool, error)
}

type SyncChainLogs

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

func NewSyncChainLogs

func NewSyncChainLogs(syncStartBlock int64,
	addressRpc string,
	fnCurrSyncBlock func() (int64, error),
	fnSetCurrSyncBlock func(int64) error) *SyncChainLogs

syncBlockKey string,

func (*SyncChainLogs) AddContracts

func (p *SyncChainLogs) AddContracts(contracts ...common.Address)

func (*SyncChainLogs) AddTopics

func (obj *SyncChainLogs) AddTopics(tops ...common.Hash)

func (*SyncChainLogs) AddVlogHandler

func (p *SyncChainLogs) AddVlogHandler(handler VlogManager)

func (*SyncChainLogs) InitCfg

func (obj *SyncChainLogs) InitCfg(
	addressSer string,
	fnSyncNumber func() (int64, error),
	fnSetSyncNumber func(int64) error,
	fnEventLogs func(types.Log) error)

func (*SyncChainLogs) Run

func (obj *SyncChainLogs) Run()

func (*SyncChainLogs) SyncLogsData

func (obj *SyncChainLogs) SyncLogsData(curNumber int64)

type TaskBase

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

func NewTaskBase

func NewTaskBase(_step int, _job ITaskBase) *TaskBase

func (*TaskBase) Run

func (obj *TaskBase) Run()

step int, fuJob func() error

type VlogManager

type VlogManager struct {
	Address       string
	Event         common.Hash
	FunLogHandler func(types.Log)
}