taskqueue

Documentation

Index

• func NewConsumer(cfg *config.Config, wg *sync.WaitGroup, internalJWT core.Session, ...) core.QueueConsumer
• func NewManager(cfg *config.Config, taskQueueStore core.TaskQueueStore, ...) core.TaskQueueManager
• func NewTaskQueueUtils(logger lumber.Logger, taskQueueStore core.TaskQueueStore, ...) core.TaskQueueUtils

Functions

func NewConsumer

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

NewConsumer return a new taskqueue consumer.

func NewManager

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

NewManager return a new task queue manager.

func NewTaskQueueUtils

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

NewTaskQueueUtils returns new taskQueueUtils