sync

Documentation

Index

• func FilterPipelineRunByState(ctx context.Context, tekton versioned2.Interface, orderList []string, ...) []string
• func PrKey(run *tektonv1.PipelineRun) string
• func RepoKey(repo *v1alpha1.Repository) string
• type QueueManager
  • func NewQueueManager(logger *zap.SugaredLogger) *QueueManager
  • func (qm *QueueManager) AddListToRunningQueue(repo *v1alpha1.Repository, list []string) ([]string, error)
  • func (qm *QueueManager) AddToPendingQueue(repo *v1alpha1.Repository, list []string) error
  • func (qm *QueueManager) InitQueues(ctx context.Context, tekton versioned2.Interface, pac versioned.Interface) error
  • func (qm *QueueManager) QueuedPipelineRuns(repo *v1alpha1.Repository) []string
  • func (qm *QueueManager) RemoveAndTakeItemFromQueue(repo *v1alpha1.Repository, run *tektonv1.PipelineRun) string
  • func (qm *QueueManager) RemoveFromQueue(repoKey, prKey string) bool
  • func (qm *QueueManager) RemoveRepository(repo *v1alpha1.Repository)
  • func (qm *QueueManager) RunningPipelineRuns(repo *v1alpha1.Repository) []string
• type QueueManagerInterface
• type Semaphore

Functions

func FilterPipelineRunByState

func FilterPipelineRunByState(ctx context.Context, tekton versioned2.Interface, orderList []string, wantedStatus, wantedState string) []string

FilterPipelineRunByInProgress filters the given list of PipelineRun names to only include those that are in a "queued" state and have a pending status. It retrieves the PipelineRun objects from the Tekton API and checks their annotations and status to determine if they should be included.

Returns A list of PipelineRun names that are in a "queued" state and have a pending status.

func PrKey

func PrKey(run *tektonv1.PipelineRun) string

func RepoKey

func RepoKey(repo *v1alpha1.Repository) string

Types

type QueueManager

type QueueManager struct {
	// contains filtered or unexported fields
}

func NewQueueManager

func NewQueueManager(logger *zap.SugaredLogger) *QueueManager

func (*QueueManager) AddListToRunningQueue

func (qm *QueueManager) AddListToRunningQueue(repo *v1alpha1.Repository, list []string) ([]string, error)

AddListToRunningQueue adds the pipelineRun to the waiting queue of the repository and if it is at the top and ready to run which means currently running pipelineRun < limit then move it to running queue This adds the pipelineRuns in the same order as in the list.

func (*QueueManager) AddToPendingQueue

func (qm *QueueManager) AddToPendingQueue(repo *v1alpha1.Repository, list []string) error

func (*QueueManager) InitQueues

func (qm *QueueManager) InitQueues(ctx context.Context, tekton versioned2.Interface, pac versioned.Interface) error

InitQueues rebuild all the queues for all repository if concurrency is defined before reconciler started reconciling them.

func (*QueueManager) QueuedPipelineRuns

func (qm *QueueManager) QueuedPipelineRuns(repo *v1alpha1.Repository) []string

func (*QueueManager) RemoveAndTakeItemFromQueue

func (qm *QueueManager) RemoveAndTakeItemFromQueue(repo *v1alpha1.Repository, run *tektonv1.PipelineRun) string

func (*QueueManager) RemoveFromQueue

func (qm *QueueManager) RemoveFromQueue(repoKey, prKey string) bool

func (*QueueManager) RemoveRepository

func (qm *QueueManager) RemoveRepository(repo *v1alpha1.Repository)

func (*QueueManager) RunningPipelineRuns

func (qm *QueueManager) RunningPipelineRuns(repo *v1alpha1.Repository) []string

type QueueManagerInterface

type QueueManagerInterface interface {
	InitQueues(ctx context.Context, tekton tektonVersionedClient.Interface, pac versioned.Interface) error
	RemoveRepository(repo *v1alpha1.Repository)
	QueuedPipelineRuns(repo *v1alpha1.Repository) []string
	RunningPipelineRuns(repo *v1alpha1.Repository) []string
	AddListToRunningQueue(repo *v1alpha1.Repository, list []string) ([]string, error)
	AddToPendingQueue(repo *v1alpha1.Repository, list []string) error
	RemoveFromQueue(repoKey, prKey string) bool
	RemoveAndTakeItemFromQueue(repo *v1alpha1.Repository, run *tektonv1.PipelineRun) string
}

type Semaphore

type Semaphore interface {
	// contains filtered or unexported methods
}