queue

package

v0.0.0-...-5d10380 Latest Latest Go to latest Published: Mar 5, 2026 License: BSD-3-Clause Imports: 1 Imported by: 0

Documentation ¶

Overview ¶

Package queue provides a queue interface that can be used for asynchronous scheduling of fetch actions.

Index ¶

Constants
type Options
type Queue

Constants ¶

View Source

const (
	DisableProxyFetchParam = "proxyfetch"
	DisableProxyFetchValue = "off"
	SourceParam            = "source"
	SourceFrontendValue    = "frontend"
	SourceWorkerValue      = "worker"
)

Variables ¶

This section is empty.

Functions ¶

This section is empty.

Types ¶

type Options ¶

type Options struct {
	// DisableProxyFetch reports whether proxyfetch should be set to off when
	// making a fetch request.
	DisableProxyFetch bool

	// Suffix is used to force reprocessing of tasks that would normally be
	// de-duplicated. It is appended to the task name.
	Suffix string

	// Source is the source that requested the task to be queued. It is
	// either "frontend" or the empty string if it is the worker.
	Source string
}

Options is used to provide option arguments for a task queue.

type Queue ¶

type Queue interface {
	ScheduleFetch(ctx context.Context, modulePath, version string, opts *Options) (bool, error)
}

A Queue provides an interface for asynchronous scheduling of fetch actions.

Source Files ¶

View all Source files

queue.go

Directories ¶

Path	Synopsis
gcpqueue Package gcpqueue provides a GCP queue implementation that can be used for asynchronous scheduling of fetch actions.	Package gcpqueue provides a GCP queue implementation that can be used for asynchronous scheduling of fetch actions.
inmemqueue Package inmemqueue provides an in-memory queue implementation that can be used for scheduling of fetch actions.	Package inmemqueue provides an in-memory queue implementation that can be used for scheduling of fetch actions.

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