queue

README

Queue

Installation

go get bitbucket.org/amotus/queue

Usage

License

Licensed under Apache License, Version 2.0 LICENSE.

Documentation

Overview

Package queue provide a generic job queue.

Index

• type Job
• type Queue

Types

type Job

type Job = any

Job is a type alias for a generic job.

type Queue

type Queue[J Job] interface {

	// Enqueue adds a job to the queue. Can be blocking until a slot is available.
	Enqueue(J) error

	// Dequeue returns a job from the queue. Blocking until a job is available.
	// The context can be used to set a timeout.
	Dequeue(ctx context.Context) (J, error)
}

Queue is an interface for a generic job queue.