tasks

package

v0.0.0-...-4f62844 Latest Latest Go to latest Published: Feb 7, 2023 License: MulanPSL-2.0 Imports: 8 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

gitee.com/gavial/misckit

Documentation ¶

Index ¶

type ITaskBase
type SyncChainLogs
- func NewSyncChainLogs(syncStartBlock int64, addressRpc string, fnCurrSyncBlock func() (int64, error), ...) *SyncChainLogs
type TaskBase
- func NewTaskBase(_step int, _job ITaskBase) *TaskBase
- func (obj *TaskBase) Run()
type VlogManager

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

This section is empty.

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)
}

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL