Versions in this module Expand all Collapse all v0 v0.42.0 Feb 23, 2026 Changes in this version + func FilterPipelineRunByState(ctx context.Context, tekton versioned2.Interface, orderList []string, ...) []string + func PrKey(run *tektonv1.PipelineRun) string + func RepoKey(repo *v1alpha1.Repository) string + type Manager struct + func NewManager(logger *zap.SugaredLogger) *Manager + func (qm *Manager) AddListToRunningQueue(repo *v1alpha1.Repository, list []string) ([]string, error) + func (qm *Manager) AddToPendingQueue(repo *v1alpha1.Repository, list []string) error + func (qm *Manager) InitQueues(ctx context.Context, tekton versioned2.Interface, pac versioned.Interface) error + func (qm *Manager) QueuedPipelineRuns(repo *v1alpha1.Repository) []string + func (qm *Manager) RemoveAndTakeItemFromQueue(repo *v1alpha1.Repository, run *tektonv1.PipelineRun) string + func (qm *Manager) RemoveFromQueue(repoKey, prKey string) bool + func (qm *Manager) RemoveRepository(repo *v1alpha1.Repository) + func (qm *Manager) RunningPipelineRuns(repo *v1alpha1.Repository) []string + type ManagerInterface interface + AddListToRunningQueue func(repo *v1alpha1.Repository, list []string) ([]string, error) + AddToPendingQueue func(repo *v1alpha1.Repository, list []string) error + InitQueues func(ctx context.Context, tekton tektonVersionedClient.Interface, ...) error + QueuedPipelineRuns func(repo *v1alpha1.Repository) []string + RemoveAndTakeItemFromQueue func(repo *v1alpha1.Repository, run *tektonv1.PipelineRun) string + RemoveFromQueue func(repoKey, prKey string) bool + RemoveRepository func(repo *v1alpha1.Repository) + RunningPipelineRuns func(repo *v1alpha1.Repository) []string + type Semaphore interface
Go to main page