concurrency

Nov 8, 2024

Changes in this version

+ type TestQMI struct

+ QueuedPrs []string

+ RunningQueue []string

+ func (TestQMI) AddToPendingQueue(_ *pacv1alpha1.Repository, _ []string) error

+ func (TestQMI) InitQueues(_ context.Context, _ tektonVersionedClient.Interface, ...) error

+ func (TestQMI) RemoveAndTakeItemFromQueue(_ *pacv1alpha1.Repository, _ *tektonv1.PipelineRun) string

+ func (TestQMI) RemoveRepository(_ *pacv1alpha1.Repository)

+ func (TestQMI) RunningPipelineRuns(_ *pacv1alpha1.Repository) []string

+ func (t TestQMI) AddListToRunningQueue(_ *pacv1alpha1.Repository, _ []string) ([]string, error)

+ func (t TestQMI) QueuedPipelineRuns(_ *pacv1alpha1.Repository) []string

+ func (t TestQMI) RemoveFromQueue(_, _ string) bool