ethmonitor

README

ethmonitor

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

Documentation

Index

• Variables
• type Block
• type Blocks
  • func (blocks Blocks) Copy() Blocks
  • func (blocks Blocks) EventExists(block *types.Block, event Event) bool
  • func (b Blocks) FindBlock(hash common.Hash, optEvent ...Event) (*Block, bool)
  • func (b Blocks) LatestBlock() *Block
• type Chain
  • func (c *Chain) Blocks() []*Block
  • func (c *Chain) GetBlock(hash common.Hash) *Block
  • func (c *Chain) GetBlockByNumber(blockNum uint64, event Event) *Block
  • func (c *Chain) GetTransaction(hash common.Hash) *types.Transaction
  • func (c *Chain) Head() *Block
  • func (c *Chain) PrintAllBlocks()
• type Event
• type Monitor
  • func NewMonitor(provider *ethrpc.Provider, opts ...Options) (*Monitor, error)
  • func (m *Monitor) Chain() *Chain
  • func (m *Monitor) GetBlock(hash common.Hash) *Block
  • func (m *Monitor) GetTransaction(hash common.Hash) *types.Transaction
  • func (m *Monitor) IsRunning() bool
  • func (m *Monitor) LatestBlock() *Block
  • func (m *Monitor) Options() Options
  • func (m *Monitor) Provider() *ethrpc.Provider
  • func (m *Monitor) Run(ctx context.Context) error
  • func (m *Monitor) Stop()
  • func (m *Monitor) Subscribe() Subscription
• type Options
• type Subscription

Variables

var (
	ErrUnexpectedParentHash  = fmt.Errorf("unexpected parent hash")
	ErrUnexpectedBlockNumber = fmt.Errorf("unexpected block number")
)

var DefaultOptions = Options{
	Logger:                   log.New(os.Stdout, "", 0),
	PollingInterval:          1 * time.Second,
	PollingTimeout:           120 * time.Second,
	StartBlockNumber:         nil,
	TrailNumBlocksBehindHead: 0,
	BlockRetentionLimit:      100,
	WithLogs:                 true,
	LogTopics:                []common.Hash{},
	DebugLogging:             false,
}

Types

type Block

type Block struct {
	*types.Block
	Event Event
	Logs  []types.Log
	// contains filtered or unexported fields
}

type Blocks

type Blocks []*Block

func (Blocks) Copy

func (blocks Blocks) Copy() Blocks

func (Blocks) EventExists

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

func (Blocks) FindBlock

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

func (Blocks) LatestBlock

func (b Blocks) LatestBlock() *Block

type Chain

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

func (*Chain) Blocks

func (c *Chain) Blocks() []*Block

func (*Chain) GetBlock

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

func (*Chain) GetBlockByNumber

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

func (*Chain) GetTransaction

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

func (*Chain) Head

func (c *Chain) Head() *Block

func (*Chain) PrintAllBlocks

func (c *Chain) PrintAllBlocks()

type Event

type Event uint32

const (
	Added Event = iota
	Removed
	Updated
)

type Monitor

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

func NewMonitor

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

func (*Monitor) Chain

func (m *Monitor) Chain() *Chain

func (*Monitor) GetBlock

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

GetBlock will search the retained blocks for the hash

func (*Monitor) GetTransaction

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

GetBlock will search within the retained blocks for the txn hash

func (*Monitor) IsRunning

func (m *Monitor) IsRunning() bool

func (*Monitor) LatestBlock

func (m *Monitor) LatestBlock() *Block

LatestBlock will return the head block of the retained chain

func (*Monitor) Options

func (m *Monitor) Options() Options

func (*Monitor) Provider

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

func (*Monitor) Run

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                   util.Logger
	PollingInterval          time.Duration
	PollingTimeout           time.Duration
	StartBlockNumber         *big.Int
	TrailNumBlocksBehindHead int
	BlockRetentionLimit      int
	WithLogs                 bool
	LogTopics                []common.Hash
	DebugLogging             bool
}

type Subscription

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