concurrency

package

v0.48.3 Latest Latest Go to latest Published: Oct 22, 2026 License: Apache-2.0 Imports: 5 Imported by: 0

Documentation ¶

This section is empty.

This section is empty.

This section is empty.

type TestQMI struct {
	QueuedPrs    []string
	RunningQueue []string
}

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

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

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

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

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

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

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

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