watcher

Documentation

Index

• type Watcher
  • func NewWatcher(ctx context.Context, blockStream <-chan watcher.Block, ...) *Watcher
  • func (w *Watcher) WatchWithTimeout(ctx context.Context, timeout time.Duration) error

Types

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

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

NewWatcher returns instanciated Watcher

func (*Watcher) WatchWithTimeout

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

WatchWithTimeout is used to receive blocks from Block Stream and send them to Queue