queue

Documentation

Index

• type Args
• type Enqueuer
  • func NewEnqueuer(config etc.JobQueue, rdb *redis.Client, store persistence.Store) Enqueuer
• type Job
  • func (s *Job) ID() string
• type Worker
  • func NewWorker(config etc.JobQueue, rdb *redis.Client, controller scan.Controller) Worker

Types

type Args

type Args struct {
	ScanRequest *harbor.ScanRequest `json:",omitempty"`
}

type Enqueuer

type Enqueuer interface {
	Enqueue(ctx context.Context, request harbor.ScanRequest) (string, error)
}

func NewEnqueuer

func NewEnqueuer(config etc.JobQueue, rdb *redis.Client, store persistence.Store) Enqueuer

type Job

type Job struct {
	Name string
	Key  job.ScanJobKey
	Args Args
}

func (*Job) ID

func (s *Job) ID() string

type Worker

type Worker interface {
	Start(ctx context.Context)
	Stop()
}

func NewWorker

func NewWorker(config etc.JobQueue, rdb *redis.Client, controller scan.Controller) Worker