watchlog

Documentation

Index

• type Watcher
  • func NewWatcher(db store.DB, client apiclient.ChainHttpClient, delay int) *Watcher
  • func (w *Watcher) Close() (err error)
  • func (w *Watcher) Err() <-chan error
  • func (w *Watcher) Start(ctx context.Context, factoryAddress common.Address) (err error)

Types

type Watcher

type Watcher struct {
	sync.Mutex
	// contains filtered or unexported fields
}

func NewWatcher

func NewWatcher(db store.DB, client apiclient.ChainHttpClient, delay int) *Watcher

NOTE: delay is millisecond

func (*Watcher) Close

func (w *Watcher) Close() (err error)

func (*Watcher) Err

func (w *Watcher) Err() <-chan error

func (*Watcher) Start

func (w *Watcher) Start(ctx context.Context, factoryAddress common.Address) (err error)