queue

package

v1.16.1-alpha Latest Latest Go to latest Published: Jul 17, 2026 License: MIT Imports: 3 Imported by: 0

Details

This section is empty.

This section is empty.

This section is empty.

type Job struct {
	Run    func() error
	OnFail func(error)
}

type Queue struct {
	// contains filtered or unexported fields
}

prefers users with fewer running jobs, otherwise it's FIFO

func NewQueue(queueSize, numWorkers int) *Queue

func (q *Queue) Enqueue(owner syntax.DID, job Job) bool

todo(dawn): add a per-user cap so a single user can't fill the queue

func (q *Queue) Start()

func (q *Queue) Stop()