processor

Documentation

Index

• type Queue
  • func NewQueue(size int) Queue
• type Worker
  • func NewWorker(db *db.Database, cp client.ClientProxy, q Queue) Worker
  • func (w Worker) Start()

Types

type Queue

type Queue chan int64

Queue is a simple type alias for a (buffered) channel of block heights.

func NewQueue

func NewQueue(size int) Queue

type Worker

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

Worker defines a job consumer that is responsible for getting and aggregating block and associated data and exporting it to a database.

func NewWorker

func NewWorker(db *db.Database, cp client.ClientProxy, q Queue) Worker

func (Worker) Start

func (w Worker) Start()

Start starts a worker by listening for new jobs (block heights) from the given worker queue. Any failed job is logged and re-enqueued.