watcher

type Watcher ¶

type Watcher struct {
	BlockStream <-chan watcher.Block
	Queue       chan<- watcher.Block
}

Watcher is a wrapper around two channels: first one (block stream) for getting and preprocessing blocks second (Queue) for sending them somewhere else for further processing

func NewWatcher(ctx context.Context, blockStream <-chan watcher.Block, rabbitQueue chan<- watcher.Block) *Watcher

func (w *Watcher) WatchWithTimeout(ctx context.Context, timeout time.Duration) error