Documentation ¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
View Source
var SuccessValidateResult = apistructs.PipelineQueueValidateResult{Success: true}
Functions ¶
This section is empty.
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) }
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) }
QueueManager manage all queues and related pipelines.
type QueueValidator ¶
type QueueValidator interface { ValidateCapacity(tryPop *spec.Pipeline) apistructs.PipelineQueueValidateResult ValidateFreeResources(tryPop *spec.Pipeline) apistructs.PipelineQueueValidateResult }
Click to show internal directories.
Click to hide internal directories.