sync

Documentation

Index

• type QueueManager
  • func NewQueueManager(logger *zap.SugaredLogger) *QueueManager
  • func (qm *QueueManager) AddToQueue(repo *v1alpha1.Repository, run *v1beta1.PipelineRun) (bool, string, error)
  • func (qm *QueueManager) InitQueues(ctx context.Context, tekton versioned2.Interface, pac versioned.Interface) error
  • func (qm *QueueManager) RemoveFromQueue(repo *v1alpha1.Repository, run *v1beta1.PipelineRun) string
• type Semaphore

Types

type QueueManager

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

func NewQueueManager

func NewQueueManager(logger *zap.SugaredLogger) *QueueManager

func (*QueueManager) AddToQueue

func (qm *QueueManager) AddToQueue(repo *v1alpha1.Repository, run *v1beta1.PipelineRun) (bool, string, error)

AddToQueue 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

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) RemoveFromQueue

func (qm *QueueManager) RemoveFromQueue(repo *v1alpha1.Repository, run *v1beta1.PipelineRun) string

RemoveFromQueue removes the pipelineRun from the queues of the repository It also start the next one which is on top of the waiting queue and return its name if started or returns ""

type Semaphore

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