Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type ConflationDispatcher ¶
type ConflationDispatcher struct {
// contains filtered or unexported fields
}
ConflationDispatcher 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 NewConflationDispatcher ¶
func NewConflationDispatcher(log logr.Logger, conflationReadyQueue *conflator.ConflationReadyQueue, dbWorkerPool *workerpool.DBWorkerPool, ) *ConflationDispatcher
NewConflationDispatcher creates a new instance of Dispatcher.
type TransportDispatcher ¶
type TransportDispatcher struct {
// contains filtered or unexported fields
}
Get message from transport, convert it to bundle and forward it to conflation manager.
func NewTransportDispatcher ¶
func NewTransportDispatcher(log logr.Logger, consumer transport.Consumer, conflationManager *conflator.ConflationManager, stats *statistics.Statistics, ) *TransportDispatcher
func (*TransportDispatcher) BundleRegister ¶
func (d *TransportDispatcher) BundleRegister(registration *registration.BundleRegistration)
Source Files
Click to show internal directories.
Click to hide internal directories.