types

Documentation

Index

• Variables
• type Queue
• type QueueManager
• type QueueValidator

Variables

var SuccessValidateResult = apistructs.PipelineQueueValidateResult{Success: true}

Types

type Queue

type Queue interface {
	QueueValidator
	Start(stopCh chan struct{})
	ID() string
	IsStrictMode() bool
	Usage() pb.QueueUsage
	Update(pq *apistructs.PipelineQueue)
	RangePendingQueue()
	AddPipelineIntoQueue(p *spec.Pipeline, doneCh chan struct{})
	PopOutPipeline(p *spec.Pipeline)
	BatchUpdatePipelinePriorityInQueue(pipelines []*spec.Pipeline) error
	snapshot.Snapshot
}

type QueueManager

type QueueManager interface {
	IdempotentAddQueue(pq *apistructs.PipelineQueue) Queue
	QueryQueueUsage(pq *apistructs.PipelineQueue) *pb.QueueUsage
	PutPipelineIntoQueue(pipelineID uint64) (popCh <-chan struct{}, needRetryIfErr bool, err error)
	PopOutPipelineFromQueue(pipelineID uint64)
	BatchUpdatePipelinePriorityInQueue(pq *apistructs.PipelineQueue, pipelineIDs []uint64) error
	Stop()
	SendQueueToEtcd(queueID uint64)
	ListenInputQueueFromEtcd(ctx context.Context)
	SendUpdatePriorityPipelineIDsToEtcd(queueID uint64, pipelineIDS []uint64)
	ListenUpdatePriorityPipelineIDsFromEtcd(ctx context.Context)
	snapshot.Snapshot
}

QueueManager manage all queues and related pipelines.

type QueueValidator

type QueueValidator interface {
	ValidateCapacity(tryPop *spec.Pipeline) apistructs.PipelineQueueValidateResult
	ValidateFreeResources(tryPop *spec.Pipeline) apistructs.PipelineQueueValidateResult
}