ethutil

package module

v1.2.0 Latest Latest Go to latest Published: Mar 2, 2023 License: Apache-2.0 Imports: 15 Imported by: 0

Details

concurrent_searchLog在go-ethereum中client.QueryFilter的基础上优化performance,主要优点如下:

View Source

const EmergencyRecovery = 100

View Source

const MaxConcurrentNumber = 8e4

View Source

const MaxQueryBlockSize int64 = 2000

View Source

const MaxWorkNumber = MaxConcurrentNumber / MaxQueryBlockSize

View Source

const Polygon_Node_URL = "https://polygon-mainnet.g.alchemy.com/v2/bG72w682SlQ0uQwUcSfbZmQAB1VPwpZd"

View Source

const SmoothRecoverRatio = 0.25

View Source

var DefaultSmoothRecoverTimes = time.Millisecond * 500

View Source

var TimeLess time.Duration = 1<<63 - 1

func GetClient() *ethclient.Client

func GetCurrentBlockNumber() (uint64, error)

func TestGetLogs(t *testing.T)

type FilterFunc func([]types.Log) error

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

func GetEvent(timeout time.Duration, from int64, to int64, address []common.Address, topics [][]common.Hash) (stream *LogsStream, err error)

func NewLogsStream(log []types.Log) *LogsStream

func (l *LogsStream) Done() (logs []types.Log, err error)

func (l *LogsStream) FilterLog(filter FilterFunc) *LogsStream