concurrency

Documentation

Index

• type TestQMI
  • func (t TestQMI) AddListToRunningQueue(_ *pacv1alpha1.Repository, _ []string) ([]string, error)
  • func (TestQMI) AddToPendingQueue(_ *pacv1alpha1.Repository, _ []string) error
  • func (TestQMI) InitQueues(_ context.Context, _ tektonVersionedClient.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

Types

type TestQMI

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

func (TestQMI) AddListToRunningQueue

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

func (TestQMI) AddToPendingQueue

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

func (TestQMI) InitQueues

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

func (TestQMI) QueuedPipelineRuns

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

func (TestQMI) RemoveAndTakeItemFromQueue

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

func (TestQMI) RemoveFromQueue

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

func (TestQMI) RemoveRepository

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

func (TestQMI) RunningPipelineRuns

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