queue

package
v0.0.1 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Nov 17, 2023 License: Apache-2.0 Imports: 15 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type Args

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

type Enqueuer

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

func NewEnqueuer

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

type Job

type Job struct {
	Name string
	ID   string
	Args Args
}

type Worker

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

func NewWorker

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

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL