queue

Documentation

Index

• type Enqueuer
  • func NewEnqueuer(config etc.JobQueue, store persistence.Store) Enqueuer
• type Worker
  • func NewWorker(config etc.JobQueue) Worker

Types

type Enqueuer

type Enqueuer interface {
	Enqueue(request harbor.ScanRequest) (job.ScanJob, error)
}

func NewEnqueuer

func NewEnqueuer(config etc.JobQueue, store persistence.Store) Enqueuer

type Worker

type Worker interface {
	Start()
	Stop()
}

func NewWorker

func NewWorker(config etc.JobQueue) Worker