ethmonitor

package
v1.18.3 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Jan 25, 2023 License: LGPL-3.0, MIT Imports: 16 Imported by: 1

README

ethmonitor

inspired by the work of the 0x team at github.com/0xProject/0x-mesh

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	ErrFatal                 = errors.New("ethmonitor: fatal error, stopping")
	ErrReorg                 = errors.New("ethmonitor: block reorg")
	ErrUnexpectedParentHash  = errors.New("ethmonitor: unexpected parent hash")
	ErrUnexpectedBlockNumber = errors.New("ethmonitor: unexpected block number")
	ErrQueueFull             = errors.New("ethmonitor: publish queue is full")
	ErrMaxAttempts           = errors.New("ethmonitor: max attempts hit")
)
View Source 
var DefaultOptions = Options{
	Logger:                   logger.NewLogger(logger.LogLevel_WARN),
	PollingInterval:          1000 * time.Millisecond,
	Timeout:                  20 * time.Second,
	StartBlockNumber:         nil,
	TrailNumBlocksBehindHead: 0,
	BlockRetentionLimit:      200,
	WithLogs:                 false,
	LogTopics:                []common.Hash{},
	DebugLogging:             false,
}

Functions

func IsBlockEq added in v1.7.0 

func IsBlockEq(a, b *types.Block) bool

Types

type Block 

type Block struct {
	*types.Block

	// Event type where Block is Added or Removed (ie. reorged)
	Event Event

	// Logs in the block, grouped by transactions:
	// [[txnA logs, ..], [txnB logs, ..], ..]
	// Logs [][]types.Log `json:"logs"`
	Logs []types.Log

	// OK flag which represents the block is ready for broadcasting
	OK bool
}

func (*Block) MarshalJSON added in v1.17.9 

func (b *Block) MarshalJSON() ([]byte, error)

func (*Block) UnmarshalJSON added in v1.17.9 

func (b *Block) UnmarshalJSON(data []byte) error

type Blocks 

type Blocks []*Block

func (Blocks) Copy added in v1.3.0 

func (blocks Blocks) Copy() Blocks

func (Blocks) EventExists added in v1.3.0 

func (blocks Blocks) EventExists(block *types.Block, event Event) bool

func (Blocks) FindBlock 

func (blocks Blocks) FindBlock(hash common.Hash, optEvent ...Event) (*Block, bool)

func (Blocks) Head added in v1.7.0 

func (b Blocks) Head() *Block

func (Blocks) IsOK added in v1.7.0 

func (b Blocks) IsOK() bool

func (Blocks) LatestBlock 

func (b Blocks) LatestBlock() *Block

func (Blocks) Reorg added in v1.7.0 

func (b Blocks) Reorg() bool

func (Blocks) Tail added in v1.7.0 

func (b Blocks) Tail() *Block

type Chain 

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

func (*Chain) Blocks 

func (c *Chain) Blocks() Blocks

func (*Chain) BootstrapFromBlocks added in v1.17.9 

func (c *Chain) BootstrapFromBlocks(blocks []*Block) error

BootstrapFromBlocks will bootstrap the ethmonitor canonical chain from input blocks, while also verifying the chain hashes link together.

func (*Chain) BootstrapFromBlocksJSON added in v1.17.9 

func (c *Chain) BootstrapFromBlocksJSON(data []byte) error

BootstrapFromBlocksJSON is convenience method which accepts json and bootstraps the ethmonitor chain. This method is here mostly for debugging purposes and recommend that you use BootstrapFromBlocks and handle constructing block events outside of ethmonitor.

func (*Chain) GetAverageBlockTime added in v1.14.2 

func (c *Chain) GetAverageBlockTime() float64

func (*Chain) GetBlock 

func (c *Chain) GetBlock(hash common.Hash) *Block

func (*Chain) GetBlockByNumber added in v1.3.2 

func (c *Chain) GetBlockByNumber(blockNum uint64, event Event) *Block

func (*Chain) GetTransaction 

func (c *Chain) GetTransaction(txnHash common.Hash) *types.Transaction

GetTransaction searches our canonical chain of blocks (where each block points at previous), and returns the transaction. Aka, searches our chain for mined transactions. Keep in mind transactions can still be reorged, but you can check the blockNumber and compare it against the head to determine if its final.

func (*Chain) Head 

func (c *Chain) Head() *Block

func (*Chain) PrintAllBlocks 

func (c *Chain) PrintAllBlocks()

func (*Chain) Snapshot added in v1.17.9 

func (c *Chain) Snapshot() ([]byte, error)

func (*Chain) Tail added in v1.7.0 

func (c *Chain) Tail() *Block

type Event added in v1.3.0 

type Event uint32
const (
	Added Event = iota
	Removed
)

type Monitor 

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

func NewMonitor 

func NewMonitor(provider *ethrpc.Provider, options ...Options) (*Monitor, error)

func (*Monitor) Chain 

func (m *Monitor) Chain() *Chain

func (*Monitor) GetAverageBlockTime added in v1.14.2 

func (m *Monitor) GetAverageBlockTime() float64

GetAverageBlockTime returns the average block time in seconds (including fractions)

func (*Monitor) GetBlock 

func (m *Monitor) GetBlock(blockHash common.Hash) *Block

GetBlock will search the retained blocks for the hash

func (*Monitor) GetTransaction 

func (m *Monitor) GetTransaction(txnHash common.Hash) *types.Transaction

GetBlock will search within the retained canonical chain for the txn hash. Passing `optMined true` will only return transaction which have not been removed from the chain via a reorg.

func (*Monitor) IsRunning 

func (m *Monitor) IsRunning() bool

func (*Monitor) LatestBlock 

func (m *Monitor) LatestBlock() *Block

LatestBlock will return the head block of the canonical chain

func (*Monitor) LatestBlockNum added in v1.17.0 

func (m *Monitor) LatestBlockNum() *big.Int

LatestBlockNum returns the latest block number in the canonical chain

func (*Monitor) LatestFinalBlock added in v1.17.2 

func (m *Monitor) LatestFinalBlock(numBlocksToFinality int) *Block

LatestFinalBlock returns the latest block which has reached finality. The argument `numBlocksToFinality` should be a constant value of the number of blocks a particular chain needs to reach finality. Ie. on Polygon this value would be 120 and on Ethereum it would be 20. As the pubsub system publishes new blocks, this value will change, as the chain will progress forward. It's recommend / safe to call this method each time in a <-sub.Blocks() code block.

func (*Monitor) OldestBlockNum added in v1.17.0 

func (m *Monitor) OldestBlockNum() *big.Int

func (*Monitor) Options 

func (m *Monitor) Options() Options

func (*Monitor) Provider added in v1.1.10 

func (m *Monitor) Provider() *ethrpc.Provider

func (*Monitor) PurgeHistory added in v1.17.0 

func (m *Monitor) PurgeHistory()

PurgeHistory clears all but the head of the chain. Useful for tests, but should almost never be used in a normal application.

func (*Monitor) Run added in v1.6.1 

func (m *Monitor) Run(ctx context.Context) error

func (*Monitor) Stop 

func (m *Monitor) Stop()

func (*Monitor) Subscribe 

func (m *Monitor) Subscribe() Subscription

type Options 

type Options struct {
	// Logger used by ethmonitor to log warnings and debug info
	Logger logger.Logger

	// PollingInterval to query the chain for new blocks
	PollingInterval time.Duration

	// Timeout duration used by the rpc client when fetching data from the remote node.
	Timeout time.Duration

	// StartBlockNumber to begin the monitor from.
	StartBlockNumber *big.Int

	// Bootstrap flag which indicates the monitor will expect the monitor's
	// events to be bootstrapped, and will continue from that point. This als
	// takes precedence over StartBlockNumber when set to true.
	Bootstrap bool

	// TrailNumBlocksBehindHead is the number of blocks we trail behind
	// the head of the chain before broadcasting new events to the subscribers.
	TrailNumBlocksBehindHead int

	// BlockRetentionLimit is the number of blocks we keep on the canonical chain
	// cache.
	BlockRetentionLimit int

	// WithLogs will include logs with the blocks if specified true.
	WithLogs bool

	// LogTopics will filter only specific log topics to include.
	LogTopics []common.Hash

	// DebugLogging toggle
	DebugLogging bool
}

type Subscription 

type Subscription interface {
	Blocks() <-chan Blocks
	Done() <-chan struct{}
	Unsubscribe()
}

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.