sync

func (*QueueManager) AddListToQueue ¶ added in v0.15.0

func (qm *QueueManager) AddListToQueue(repo *v1alpha1.Repository, list []string) ([]string, error)

AddListToQueue adds the pipelineRun to the waiting queue of the repository and if it is at the top and ready to run which means currently running pipelineRun < limit then move it to running queue This adds the pipelineRuns in the same order as in the list.

func (*QueueManager) InitQueues ¶

func (qm *QueueManager) InitQueues(ctx context.Context, tekton versioned2.Interface, pac versioned.Interface) error

InitQueues rebuild all the queues for all repository if concurrency is defined before reconciler started reconciling them.

func (*QueueManager) QueuedPipelineRuns ¶ added in v0.13.0

func (qm *QueueManager) QueuedPipelineRuns(repo *v1alpha1.Repository) []string

func (*QueueManager) RemoveFromQueue ¶

func (qm *QueueManager) RemoveFromQueue(repo *v1alpha1.Repository, run *tektonv1.PipelineRun) string

RemoveFromQueue removes the pipelineRun from the queues of the repository It also start the next one which is on top of the waiting queue and return its name if started or returns "".

func (*QueueManager) RemoveRepository ¶ added in v0.12.0

func (qm *QueueManager) RemoveRepository(repo *v1alpha1.Repository)

func (*QueueManager) RunningPipelineRuns ¶ added in v0.13.0

func (qm *QueueManager) RunningPipelineRuns(repo *v1alpha1.Repository) []string