dispatcher

Documentation

Index

• type Dispatcher
  • func NewDispatcher(log logr.Logger, conflationReadyQueue *conflator.ConflationReadyQueue, ...) *Dispatcher
  • func (dispatcher *Dispatcher) Start(ctx context.Context) error

Types

type Dispatcher

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

Dispatcher abstracts the dispatching of db jobs to db workers. this is done by reading ready CU and getting from them a ready to process bundles.

func NewDispatcher

func NewDispatcher(log logr.Logger, conflationReadyQueue *conflator.ConflationReadyQueue,
	dbWorkerPool *workerpool.DBWorkerPool) *Dispatcher

NewDispatcher creates a new instance of Dispatcher.

func (*Dispatcher) Start

func (dispatcher *Dispatcher) Start(ctx context.Context) error

Start starts the dispatcher.