eventwatcher

Documentation

Overview

Package eventwatcher provides a client for watching ethereum events

Index

• type EventWatcher
  • func New(bc utils.Blockchain) *EventWatcher
  • func (ew *EventWatcher) BC() utils.Blockchain
  • func (ew *EventWatcher) Close() error
  • func (ew *EventWatcher) NewBindings(addresses map[string]string) (map[string]*sigmacore.Sigmacore, error)
  • func (ew *EventWatcher) NewWatchedContracts(logger *zap.Logger, bindings map[string]*sigmacore.Sigmacore, ...) ([]*WatchedContract, error)
• type WatchedContract
  • func (wc *WatchedContract) Listen(ctx context.Context, db *database.Database, alerter *alerts.Alerter, ...) error
  • func (wc *WatchedContract) Name() string
  • func (wc *WatchedContract) NotifChanSwap() <-chan *sigmacore.SigmacoreLOGSWAP
  • func (wc *WatchedContract) NotifChanToggle() <-chan *sigmacore.SigmacoreLOGPUBLICSWAPTOGGLED

Types

type EventWatcher

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

EventWatcher wraps one or more interfaces to the ethereum blockchain to watch events

func New

func New(bc utils.Blockchain) *EventWatcher

New returns a new EventWatcher implementation

func (*EventWatcher) BC

func (ew *EventWatcher) BC() utils.Blockchain

BC returns the underlying blockchain client

func (*EventWatcher) Close

func (ew *EventWatcher) Close() error

Close is used to terminate the event watcher

func (*EventWatcher) NewBindings

func (ew *EventWatcher) NewBindings(addresses map[string]string) (map[string]*sigmacore.Sigmacore, error)

NewBindings constructs poolbindings for various indices, the input addresses argument is a map of pool name -> pool address

func (*EventWatcher) NewWatchedContracts

func (ew *EventWatcher) NewWatchedContracts(
	logger *zap.Logger,
	bindings map[string]*sigmacore.Sigmacore,
	minimumGwei, gasMultiplier *big.Int,
) ([]*WatchedContract, error)

NewWatchedContracts initializes watched contracts and prepares them for event listening

type WatchedContract

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

WatchedContract is a singular watched contract

func (*WatchedContract) Listen

func (wc *WatchedContract) Listen(ctx context.Context, db *database.Database, alerter *alerts.Alerter, authorizer *utils.Authorizer, breakPercentage float64) error

Listen stars the watche contract listening process waiting for incoming events

func (*WatchedContract) Name

func (wc *WatchedContract) Name() string

Name returns the name of the indexed pool this watcher monitors

func (*WatchedContract) NotifChanSwap

func (wc *WatchedContract) NotifChanSwap() <-chan *sigmacore.SigmacoreLOGSWAP

NotifChanSwap returns events when listened on, this is used to notify any listening goroutines of received events without having to worry about multi channel listeners as if we have multiple listeners on a channel golang will randomly choose 1

func (*WatchedContract) NotifChanToggle

func (wc *WatchedContract) NotifChanToggle() <-chan *sigmacore.SigmacoreLOGPUBLICSWAPTOGGLED

NotifChanToggle returns events when listened on, this is used to notify any listening goroutines of received events without having to worry about multi channel listeners as if we have multiple listeners on a channel golang will randomly choose 1