queue

Documentation

Index

• Constants
• func New(pq *apistructs.PipelineQueue, ops ...Option) *defaultQueue
• type CapacityValidator
• type Option
  • func WithDBClient(dbClient *dbclient.Client) Option

Constants

const (
	PendingQueueValidate = "PendingQueueValidate"
	FailedQueue          = "FailedQueue"
	SuccessQueue         = "SuccessQueue"
)

Queue event reason list

const (
	EventComponentQueueManager = "QueueManager"
)

Functions

func New

func New(pq *apistructs.PipelineQueue, ops ...Option) *defaultQueue

Types

type CapacityValidator

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

type Option

type Option func(*defaultQueue)

func WithDBClient

func WithDBClient(dbClient *dbclient.Client) Option