gcpqueue

package

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

Documentation ¶

Package gcpqueue provides a GCP queue implementation that can be used for asynchronous scheduling of fetch actions.

This section is empty.

This section is empty.

func New(ctx context.Context, cfg *config.Config, queueName string, numWorkers int) (queue.Queue, error)

New creates a new Queue with name queueName based on the configuration in cfg. When running locally, Queue uses numWorkers concurrent workers.

This section is empty.