watcher

Documentation

Overview

Package watcher provides tools to track events emitted from ethereum contracts.

Index

• type EventFilter
  • func NewEventFilter(ctx context.Context, ec *ethclient.Client, contract ethcommon.Address, ...) *EventFilter
  • func (f *EventFilter) Start() error
  • func (f *EventFilter) Stop()

Types

type EventFilter

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

EventFilter filters the chain for specific events (logs). When it finds a desired log, it puts it into its outbound channel.

func NewEventFilter

func NewEventFilter(
	ctx context.Context,
	ec *ethclient.Client,
	contract ethcommon.Address,
	fromBlock *big.Int,
	topic ethcommon.Hash,
	logCh chan<- ethtypes.Log,
) *EventFilter

NewEventFilter returns a new *EventFilter.

func (*EventFilter) Start

func (f *EventFilter) Start() error

Start starts the EventFilter. It watches the chain for logs.

func (*EventFilter) Stop

func (f *EventFilter) Stop()

Stop stops the EventFilter.