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 ¶
const ( BandBacklog = internalqueue.BandBacklog BandHot = internalqueue.BandHot BandMachine = internalqueue.BandMachine BacklogMax = internalqueue.BacklogMax HotMin = internalqueue.HotMin HotMax = internalqueue.HotMax MachineMin = internalqueue.MachineMin )
Priority bands (ADR-0015).
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.
const ( RequeueClassPreflight = internalqueue.RequeueClassPreflight RequeueClassGate = internalqueue.RequeueClassGate RequeueClassRateLimit = internalqueue.RequeueClassRateLimit RequeueClassRateLimitGate = internalqueue.RequeueClassRateLimitGate 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).
const (
ClaimAnomalyThreshold = internalqueue.ClaimAnomalyThreshold
)
Claim-anomaly detection (loop suspects).
Variables ¶
var ( ErrNoTaskDue = internalqueue.ErrNoTaskDue ErrEmptyType = internalqueue.ErrEmptyType ErrEmptyAnswerRef = internalqueue.ErrEmptyAnswerRef ErrEmptyAnswer = internalqueue.ErrEmptyAnswer ErrTaskDone = internalqueue.ErrTaskDone )
Sentinel errors.
var ( New = internalqueue.New BandOf = internalqueue.BandOf ClampBacklog = internalqueue.ClampBacklog CountStuckRunning = internalqueue.CountStuckRunning ValidQuestionType = internalqueue.ValidQuestionType ParseReprioritizeEvidence = internalqueue.ParseReprioritizeEvidence )
Functions.
var ClaimCount = internalqueue.ClaimCount
Functions ¶
This section is empty.
Types ¶
type EnqueueDetail ¶ added in v0.3.1
type EnqueueDetail = internalqueue.EnqueueDetail
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 ReprioritizeEvidence ¶
type ReprioritizeEvidence = internalqueue.ReprioritizeEvidence
Contract types.