Documentation ¶
Index ¶
- type QueueManager
- func (qm *QueueManager) AddListToQueue(repo *v1alpha1.Repository, list []string) ([]string, error)
- func (qm *QueueManager) InitQueues(ctx context.Context, tekton versioned2.Interface, pac versioned.Interface) error
- func (qm *QueueManager) QueuedPipelineRuns(repo *v1alpha1.Repository) []string
- func (qm *QueueManager) RemoveFromQueue(repo *v1alpha1.Repository, run *tektonv1.PipelineRun) string
- func (qm *QueueManager) RemoveRepository(repo *v1alpha1.Repository)
- func (qm *QueueManager) RunningPipelineRuns(repo *v1alpha1.Repository) []string
- type Semaphore
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type QueueManager ¶
type QueueManager struct {
// contains filtered or unexported fields
}
func NewQueueManager ¶
func NewQueueManager(logger *zap.SugaredLogger) *QueueManager
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
Click to show internal directories.
Click to hide internal directories.