queue

Oct 12, 2026

Changes in this version

+ func Finishing(pr *tektonv1.PipelineRun) bool

+ func SplitPrKey(key string) (namespace, name string, ok bool)

+ type Admission struct

+ Candidates []StartCandidate

+ type AdmissionMode int

+ const AdmissionInitial

+ const AdmissionPromotion

+ const AdmissionResume

type Manager

+ func (qm *Manager) AcquireAdmission(repo *v1alpha1.Repository, owner *tektonv1.PipelineRun, list []string, ...) (*Admission, error)

+ func (qm *Manager) FinishAdmission(work *Admission) error

+ func (qm *Manager) ForgetAdmission(repoKey string, owner *tektonv1.PipelineRun)

type ManagerInterface

+ AcquireAdmission func(repo *v1alpha1.Repository, owner *tektonv1.PipelineRun, list []string, ...) (*Admission, error)

+ FinishAdmission func(work *Admission) error

+ ForgetAdmission func(repoKey string, owner *tektonv1.PipelineRun)

+ type StartCandidate struct

+ Attempted bool

+ Key string

+ Outcome StartOutcome

+ UID types.UID

+ type StartOutcome int

+ const StartGone

+ const StartRetry

+ const StartSucceeded

Aug 5, 2026

Changes in this version

+ func DebugHandler() http.HandlerFunc

+ func RegisterForDebug(qm *Manager)

type Manager

+ func (qm *Manager) Snapshot() (map[string]RepoQueue, bool)

+ type RepoQueue struct

+ Limit int

+ Pending []string

+ Running []string

May 25, 2026 GO-2026-6263 +1 more

  GO-2026-6263: Tekton Pipelines-as-Code: Unscoped GitHub App installation token allows unauthorized access to private repositories via remote task resolution in github.com/openshift-pipelines/pipelines-as-code

  GO-2026-6266: Pipelines-as-Code GitHub App token request can be redirected via untrusted Enterprise Host header in github.com/openshift-pipelines/pipelines-as-code

May 6, 2026 GO-2026-6263 +1 more

  GO-2026-6263: Tekton Pipelines-as-Code: Unscoped GitHub App installation token allows unauthorized access to private repositories via remote task resolution in github.com/openshift-pipelines/pipelines-as-code

  GO-2026-6266: Pipelines-as-Code GitHub App token request can be redirected via untrusted Enterprise Host header in github.com/openshift-pipelines/pipelines-as-code

Apr 8, 2026 GO-2026-6263 +1 more

  GO-2026-6263: Tekton Pipelines-as-Code: Unscoped GitHub App installation token allows unauthorized access to private repositories via remote task resolution in github.com/openshift-pipelines/pipelines-as-code

  GO-2026-6266: Pipelines-as-Code GitHub App token request can be redirected via untrusted Enterprise Host header in github.com/openshift-pipelines/pipelines-as-code

Mar 31, 2026 GO-2026-6263 +1 more

  GO-2026-6263: Tekton Pipelines-as-Code: Unscoped GitHub App installation token allows unauthorized access to private repositories via remote task resolution in github.com/openshift-pipelines/pipelines-as-code

  GO-2026-6266: Pipelines-as-Code GitHub App token request can be redirected via untrusted Enterprise Host header in github.com/openshift-pipelines/pipelines-as-code

Mar 11, 2026 GO-2026-6263 +1 more

  GO-2026-6263: Tekton Pipelines-as-Code: Unscoped GitHub App installation token allows unauthorized access to private repositories via remote task resolution in github.com/openshift-pipelines/pipelines-as-code

  GO-2026-6266: Pipelines-as-Code GitHub App token request can be redirected via untrusted Enterprise Host header in github.com/openshift-pipelines/pipelines-as-code

Feb 23, 2026 GO-2026-6263 +1 more

  GO-2026-6263: Tekton Pipelines-as-Code: Unscoped GitHub App installation token allows unauthorized access to private repositories via remote task resolution in github.com/openshift-pipelines/pipelines-as-code

  GO-2026-6266: Pipelines-as-Code GitHub App token request can be redirected via untrusted Enterprise Host header in github.com/openshift-pipelines/pipelines-as-code

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