queue

package module
v0.3.1 Latest Latest
Warning

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

Go to latest
Published: Oct 6, 2026 License: MIT Imports: 1 Imported by: 0

Documentation

Overview

Package queue is the public facade over the store-contract module (ADR-0016): the Store interface, Filter, the Queue convenience facade, priority bands (ADR-0015), and the sentinel errors. The implementation stays internal; this package pins the names. Store drivers live in the sibling queue/sqlite and queue/postgres modules and satisfy Store here.

Index

Constants

Priority bands (ADR-0015).

View Source
const (
	PriorityAgingDaysPerPoint = internalqueue.PriorityAgingDaysPerPoint
	PriorityAgingMaxBonus     = internalqueue.PriorityAgingMaxBonus
	PrioritySourceUnblock     = internalqueue.PrioritySourceUnblock
	UnblockBumpPriority       = internalqueue.UnblockBumpPriority

	QuestionTypeInfo         = internalqueue.QuestionTypeInfo
	QuestionTypeApproval     = internalqueue.QuestionTypeApproval
	QuestionTypeConfirmation = internalqueue.QuestionTypeConfirmation
	QuestionTypeInput        = internalqueue.QuestionTypeInput
)

Priority aging (ADR-0015), unblock bumps, and owner-question kinds.

View Source
const (
	RequeueClassPreflight = internalqueue.RequeueClassPreflight
	RequeueClassGate      = internalqueue.RequeueClassGate
	RequeueClassRateLimit = internalqueue.RequeueClassRateLimit
	RequeueClassQuestion  = internalqueue.RequeueClassQuestion
	RequeueClassBudget    = internalqueue.RequeueClassBudget
	RequeueClassUnknown   = internalqueue.RequeueClassUnknown
)

Requeue classes: WHICH not-the-task's-fault refusal returned a task to Pending (rides task.requeued fact details; readers normalize a missing class on legacy facts to RequeueClassUnknown).

View Source
const (
	ClaimAnomalyThreshold = internalqueue.ClaimAnomalyThreshold
)

Claim-anomaly detection (loop suspects).

Variables

View Source
var (
	ErrNoTaskDue      = internalqueue.ErrNoTaskDue
	ErrEmptyType      = internalqueue.ErrEmptyType
	ErrEmptyAnswerRef = internalqueue.ErrEmptyAnswerRef
	ErrEmptyAnswer    = internalqueue.ErrEmptyAnswer
	ErrTaskDone       = internalqueue.ErrTaskDone
)

Sentinel errors.

View Source
var (
	New                       = internalqueue.New
	BandOf                    = internalqueue.BandOf
	ClampBacklog              = internalqueue.ClampBacklog
	CountStuckRunning         = internalqueue.CountStuckRunning
	ValidQuestionType         = internalqueue.ValidQuestionType
	ParseReprioritizeEvidence = internalqueue.ParseReprioritizeEvidence
)

Functions.

Functions

This section is empty.

Types

type AnswerRecord added in v0.3.1

type AnswerRecord = internalqueue.AnswerRecord

Contract types.

type Band

type Band = internalqueue.Band

Contract types.

type Claim added in v0.3.1

type Claim = internalqueue.Claim

Contract types.

type EnqueueDetail added in v0.3.1

type EnqueueDetail = internalqueue.EnqueueDetail

Contract types.

type Filter

type Filter = internalqueue.Filter

Contract types.

type PriorityScore

type PriorityScore = internalqueue.PriorityScore

Contract types.

type QuestionAnsweredDetail added in v0.3.1

type QuestionAnsweredDetail = internalqueue.QuestionAnsweredDetail

Contract types.

type QuestionAskedDetail added in v0.3.1

type QuestionAskedDetail = internalqueue.QuestionAskedDetail

Contract types.

type Queue

type Queue = internalqueue.Queue

Contract types.

type ReprioritizeEvidence

type ReprioritizeEvidence = internalqueue.ReprioritizeEvidence

Contract types.

type RequeueEvidence

type RequeueEvidence = internalqueue.RequeueEvidence

Contract types.

type Store

type Store = internalqueue.Store

Contract types.

type UnblockChange

type UnblockChange = internalqueue.UnblockChange

Contract types.

type WatermarkEntry

type WatermarkEntry = internalqueue.WatermarkEntry

Contract types.

Directories

Path Synopsis
postgres module
sqlite module

Jump to

Keyboard shortcuts

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