events

Documentation

Index

• Constants
• type Contract
• type NoopSubs
  • func (self *NoopSubs) Err() <-chan error
  • func (self *NoopSubs) Unsubscribe()
• type TrackerEvents
  • func New(ctx context.Context, logger log.Logger, client *ethclient.Client, ...) (*TrackerEvents, chan types.Log, error)
  • func (self *TrackerEvents) Start() error
  • func (self *TrackerEvents) Stop()

Constants

const (
	ComponentName = "trackerEvent"
)

Types

type Contract

type Contract interface {
	Abi() abi.ABI
	WatchLogs(opts *bind.WatchOpts, name string, query ...[]interface{}) (chan types.Log, event.Subscription, error)
	NetID() int64
	Addr() common.Address
}

type NoopSubs

type NoopSubs struct{}

func (*NoopSubs) Err

func (self *NoopSubs) Err() <-chan error

func (*NoopSubs) Unsubscribe

func (self *NoopSubs) Unsubscribe()

type TrackerEvents

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

func New

func New(
	ctx context.Context,
	logger log.Logger,
	client *ethclient.Client,
	contract Contract,
	lookBack time.Duration,
	eventName string,
	reorgWaitPeriod time.Duration,
) (*TrackerEvents, chan types.Log, error)

func (*TrackerEvents) Start

func (self *TrackerEvents) Start() error

func (*TrackerEvents) Stop

func (self *TrackerEvents) Stop()