Versions in this module Expand all Collapse all v0 v0.4.0 Jun 2, 2022 Changes in this version + type DBJob struct + func NewDBJob(bundle bundle.Bundle, metadata *conflator.BundleMetadata, ...) *DBJob + type DBWorker struct + func NewDBWorker(log logr.Logger, workerID int32, dbWorkersPool chan *DBWorker, ...) *DBWorker + func (worker *DBWorker) RunAsync(job *DBJob) + type DBWorkerPool struct + func NewDBWorkerPool(log logr.Logger, databaseURL string, statistics *statistics.Statistics) (*DBWorkerPool, error) + func (pool *DBWorkerPool) Acquire() *DBWorker + func (pool *DBWorkerPool) Start() error + func (pool *DBWorkerPool) Stop()
Go to main page