sync

Documentation

Index

• type QueueManager
  • func NewQueueManager(logger *zap.SugaredLogger) *QueueManager
  • func (qm *QueueManager) AddListToQueue(repo *v1alpha1.Repository, list []string) ([]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) RemoveFromQueue(repo *v1alpha1.Repository, run *tektonv1.PipelineRun) string
  • func (qm *QueueManager) RemoveRepository(repo *v1alpha1.Repository)
  • func (qm *QueueManager) RunningPipelineRuns(repo *v1alpha1.Repository) []string
• type Semaphore

Types

type QueueManager

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

func NewQueueManager

func NewQueueManager(logger *zap.SugaredLogger) *QueueManager

func (*QueueManager) AddListToQueue

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

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

func (qm *QueueManager) RemoveFromQueue(repo *v1alpha1.Repository, run *tektonv1.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 ""

func (*QueueManager) RemoveRepository

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

func (*QueueManager) RunningPipelineRuns

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

type Semaphore

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