taskqueue

func NewConsumer(cfg *config.Config,
	wg *sync.WaitGroup,
	internalJWT core.Session,
	taskStore core.TaskStore,
	taskUpdateManager core.TaskUpdateManager,
	buildStore core.BuildStore,
	buildMonitor core.BuildMonitor,
	taskQueueStore core.TaskQueueStore,
	taskQueueManager core.TaskQueueManager,
	redisDB core.RedisDB,
	tokenHandler core.GitTokenHandler,
	runner core.K8sRunner,
	gitStatusService core.GitStatusService,
	orgStore core.OrganizationStore,
	taskQueueUtils core.TaskQueueUtils,
	repoStore core.RepoStore,
	taskRunner core.TaskRunner,
	logger lumber.Logger) core.QueueConsumer

func NewManager(cfg *config.Config,
	taskQueueStore core.TaskQueueStore,
	orgStore core.OrganizationStore,
	buildStore core.BuildStore,
	taskStore core.TaskStore,
	gitStatusService core.GitStatusService,
	logger lumber.Logger) core.TaskQueueManager

func NewTaskQueueUtils(logger lumber.Logger,
	taskQueueStore core.TaskQueueStore,
	gitStatusService core.GitStatusService,
	buildMonitor core.BuildMonitor) core.TaskQueueUtils