pipeline

Documentation

Index

• Constants
• type Dispatcher
  • func NewDispatcher(cache *sql.DB, resStore *storage.ResourceStore) *Dispatcher
  • func (pd *Dispatcher) DistributeAndProcess(pReqs []resource.ProcessingReq, fields log.Fields)

Constants

const (
	NumberOfWorkers = 1
	BatchSize       = 1000
)

Types

type Dispatcher

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

func NewDispatcher

func NewDispatcher(cache *sql.DB, resStore *storage.ResourceStore) *Dispatcher

func (*Dispatcher) DistributeAndProcess

func (pd *Dispatcher) DistributeAndProcess(pReqs []resource.ProcessingReq, fields log.Fields)