queue

package module

Go to main page

Versions in this module

v0

v0.4.1

Oct 31, 2026

v0.4.0

Oct 30, 2026

Changes in this version

+ const RequeueClassRateLimitGate

type Filter

+ DedupKey string

+ type ParkedDetail struct

+ By string

+ Reason string

+ UntilMS int64

type RequeueEvidence

+ Provider string

type Store

+ ClaimCounts func(ctx context.Context) (map[string]int, error)

+ ClaimDueTypes func(ctx context.Context, owner string, lease time.Duration, types []string) (task.Task, Claim, error)

+ Park func(ctx context.Context, id task.ID, reason string, until time.Time, by string) error

v0.3.4

Oct 11, 2026

v0.3.3

Oct 7, 2026

Changes in this version

+ type Waker interface

+ Notify func() <-chan struct{}

v0.3.2

Oct 6, 2026

v0.3.1

Oct 6, 2026

Changes in this version

+ const ClaimAnomalyThreshold

+ const QuestionTypeApproval

+ const QuestionTypeConfirmation

+ const QuestionTypeInfo

+ const QuestionTypeInput

+ const RequeueClassBudget

+ const RequeueClassGate

+ const RequeueClassPreflight

+ const RequeueClassQuestion

+ const RequeueClassRateLimit

+ const RequeueClassUnknown

+ var ErrEmptyAnswer = errors.New("queue: record answer needs a non-empty answer")

+ var ErrEmptyAnswerRef = errors.New("queue: record answer needs a question ref")

+ var ErrTaskDone = errors.New(...)

+ func ClaimCount(ctx context.Context, s Store, id string) (int, error)

+ func CountStuckRunning(ctx context.Context, store Store, now time.Time) int

+ func ValidQuestionType(t string) bool

+ type AnswerRecord struct

+ Answer string

+ AnsweredAt time.Time

+ PapID string

+ Question string

+ Ref string

+ type Claim string

+ func (c Claim) String() string

+ type EnqueueDetail struct

+ CreatedAt int64

+ DedupKey string

+ Deps []task.ID

+ MaxAttempts int

+ NotBefore int64

+ Payload string

+ Priority *int

+ Project string

+ Rescue string

+ Type string

type Filter

+ PayloadContains string

+ type QuestionAnsweredDetail struct

+ Answer string

+ AnsweredAt int64

+ PapID string

+ Question string

+ Ref string

+ type QuestionAskedDetail struct

+ ExpiresAt int64

+ Options []string

+ Question string

+ Ref string

+ Repo string

+ Type string

type ReprioritizeEvidence

+ func ParseReprioritizeEvidence(detail jsontext.Value) (ReprioritizeEvidence, bool)

type RequeueEvidence

+ Class string

+ ResumeCloseout bool

type Store

+ DeletePriorityScores func(ctx context.Context, itemKeys []string) (int64, error)

+ FactsSince func(ctx context.Context, ftype journal.FactType, since time.Time, limit int) ([]journal.Fact, error)

+ PriorityScores func(ctx context.Context) ([]PriorityScore, error)

+ RecordAnswer func(ctx context.Context, id task.ID, ans AnswerRecord) error

v0.3.0

Sep 13, 2026

Changes in this version

+ const BacklogMax

+ const HotMax

+ const HotMin

+ const MachineMin

+ const PriorityAgingDaysPerPoint

+ const PriorityAgingMaxBonus

+ const PrioritySourceUnblock

+ const UnblockBumpPriority

+ func ClampBacklog(priority int) int

+ type Band string

+ const BandBacklog

+ const BandHot

+ const BandMachine

+ func BandOf(priority int) Band

type Filter

+ Parked *bool

+ PriorityMax *int

+ PriorityMin *int

+ type PriorityScore struct

+ EffortMinutes int

+ ItemKey string

+ Reasoning string

+ Score int

+ ScoredAt int64

+ Source string

+ Tokens int

type Queue

+ func (q *Queue) BumpUnblocked(ctx context.Context, dryRun bool) ([]UnblockChange, error)

+ type ReprioritizeEvidence struct

+ NewPriority int

+ OldPriority int

+ Reason string

+ Source string

type Store

+ DismissDead func(ctx context.Context, id task.ID, reason, by string) error

+ PriorityScore func(ctx context.Context, itemKey string) (PriorityScore, bool, error)

+ SavePriorityScore func(ctx context.Context, score PriorityScore) error

+ UpdatePendingPriority func(ctx context.Context, id task.ID, newPriority int, source, reason string) error

+ type UnblockChange struct

+ CompletedDeps int

+ NewPriority int

+ OldPriority int

+ TaskID task.ID

v0.2.0

Sep 9, 2026

Changes in this version

+ var ErrEmptyType = errors.New("queue: task type must not be empty")

+ var ErrNoTaskDue = errors.New("queue: no due task")

+ type ArchiveStats struct

+ Archived int64

+ Hot int64

+ Watermark int64

+ type Filter struct

+ Limit int

+ Offset int

+ Project *string

+ Query string

+ SeverityOrder bool

+ Since *time.Time

+ Sort string

+ Status *task.Status

+ Type *string

+ type PostgresStore struct

+ func OpenPostgres(ctx context.Context, dsn string, maxConns int32) (*PostgresStore, error)

+ func (s *PostgresStore) Cancel(ctx context.Context, id task.ID, reason string) error

+ func (s *PostgresStore) CancelOwned(ctx context.Context, id task.ID, owner string) error

+ func (s *PostgresStore) CancelRequested(ctx context.Context, id task.ID) (bool, error)

+ func (s *PostgresStore) CancelRunning(ctx context.Context, id task.ID, reason string) error

+ func (s *PostgresStore) ClaimDue(ctx context.Context, owner string, lease time.Duration) (task.Task, error)

+ func (s *PostgresStore) Close() error

+ func (s *PostgresStore) Complete(ctx context.Context, id task.ID, owner string, result json.RawMessage) error

+ func (s *PostgresStore) CountFacts(ctx context.Context, ftype journal.FactType, since time.Time) (int64, error)

+ func (s *PostgresStore) CountTasks(ctx context.Context, f Filter) (int, error)

+ func (s *PostgresStore) Enqueue(ctx context.Context, n task.New) (task.Task, error)

+ func (s *PostgresStore) Facts(ctx context.Context, after int64, limit int) ([]journal.Fact, error)

+ func (s *PostgresStore) FactsForTask(ctx context.Context, id string, limit int) ([]journal.Fact, error)

+ func (s *PostgresStore) Fail(ctx context.Context, id task.ID, owner string, errText string, ...) error

+ func (s *PostgresStore) FailPermanent(ctx context.Context, id task.ID, owner string, errText string, ...) error

+ func (s *PostgresStore) Get(ctx context.Context, id task.ID) (task.Task, error)

+ func (s *PostgresStore) HeadSeq(ctx context.Context) (int64, error)

+ func (s *PostgresStore) Heartbeat(ctx context.Context, id task.ID, owner string, extend time.Duration) error

+ func (s *PostgresStore) LastFacts(ctx context.Context, limit int) ([]journal.Fact, error)

+ func (s *PostgresStore) List(ctx context.Context, f Filter) ([]task.Task, error)

+ func (s *PostgresStore) ListWatermarks(ctx context.Context) ([]WatermarkEntry, error)

+ func (s *PostgresStore) MarkOrphaned(ctx context.Context, cutoff time.Time) (int, error)

+ func (s *PostgresStore) ProjectCounts(ctx context.Context) (map[string]map[task.Status]int, error)

+ func (s *PostgresStore) Requeue(ctx context.Context, id task.ID, owner string, errText string, ...) error

+ func (s *PostgresStore) RescueDead(ctx context.Context, id task.ID, maxAttempts int) error

+ func (s *PostgresStore) SaveWatermark(ctx context.Context, consumer string, seq int64) error

+ func (s *PostgresStore) SetWatermark(ctx context.Context, consumer string, seq int64) error

+ func (s *PostgresStore) StatusCounts(ctx context.Context) (map[task.Status]int, error)

+ func (s *PostgresStore) Watermark(ctx context.Context, consumer string) (int64, bool, error)

+ type Queue struct

+ func New(s Store) *Queue

+ func (q *Queue) Enqueue(ctx context.Context, n task.New) (task.Task, error)

+ type RequeueEvidence struct

+ Reason string

+ RetryIn int64

+ type SQLiteStore struct

+ func OpenSQLite(path string, opts ...StoreOption) (*SQLiteStore, error)

+ func (s *SQLiteStore) ArchiveFactsBefore(ctx context.Context, cutoff int64) (int64, error)

+ func (s *SQLiteStore) ArchiveSummary(ctx context.Context) (ArchiveStats, error)

+ func (s *SQLiteStore) Cancel(ctx context.Context, id task.ID, reason string) error

+ func (s *SQLiteStore) CancelOwned(ctx context.Context, id task.ID, owner string) error

+ func (s *SQLiteStore) CancelRequested(ctx context.Context, id task.ID) (bool, error)

+ func (s *SQLiteStore) CancelRunning(ctx context.Context, id task.ID, reason string) error

+ func (s *SQLiteStore) ClaimDue(ctx context.Context, owner string, lease time.Duration) (task.Task, error)

+ func (s *SQLiteStore) Close() error

+ func (s *SQLiteStore) Complete(ctx context.Context, id task.ID, owner string, result json.RawMessage) error

+ func (s *SQLiteStore) CountFacts(ctx context.Context, ftype journal.FactType, since time.Time) (int64, error)

+ func (s *SQLiteStore) CountTasks(ctx context.Context, f Filter) (int, error)

+ func (s *SQLiteStore) Enqueue(ctx context.Context, n task.New) (task.Task, error)

+ func (s *SQLiteStore) Facts(ctx context.Context, after int64, limit int) ([]journal.Fact, error)

+ func (s *SQLiteStore) FactsForTask(ctx context.Context, id string, limit int) ([]journal.Fact, error)

+ func (s *SQLiteStore) Fail(ctx context.Context, id task.ID, owner string, errText string, ...) error

+ func (s *SQLiteStore) FailPermanent(ctx context.Context, id task.ID, owner string, errText string, ...) error

+ func (s *SQLiteStore) Get(ctx context.Context, id task.ID) (task.Task, error)

+ func (s *SQLiteStore) HeadSeq(ctx context.Context) (int64, error)

+ func (s *SQLiteStore) Heartbeat(ctx context.Context, id task.ID, owner string, extend time.Duration) error

+ func (s *SQLiteStore) LastFacts(ctx context.Context, limit int) ([]journal.Fact, error)

+ func (s *SQLiteStore) List(ctx context.Context, f Filter) ([]task.Task, error)

+ func (s *SQLiteStore) ListWatermarks(ctx context.Context) ([]WatermarkEntry, error)

+ func (s *SQLiteStore) MarkOrphaned(ctx context.Context, cutoff time.Time) (int, error)

+ func (s *SQLiteStore) ProjectCounts(ctx context.Context) (map[string]map[task.Status]int, error)

+ func (s *SQLiteStore) Requeue(ctx context.Context, id task.ID, owner string, errText string, ...) error

+ func (s *SQLiteStore) RescueDead(ctx context.Context, id task.ID, maxAttempts int) error

+ func (s *SQLiteStore) SaveWatermark(ctx context.Context, consumer string, seq int64) error

+ func (s *SQLiteStore) SetWatermark(ctx context.Context, consumer string, seq int64) error

+ func (s *SQLiteStore) StatusCounts(ctx context.Context) (map[task.Status]int, error)

+ func (s *SQLiteStore) Watermark(ctx context.Context, consumer string) (int64, bool, error)

+ type Store interface

+ Cancel func(ctx context.Context, id task.ID, reason string) error

+ CancelOwned func(ctx context.Context, id task.ID, owner string) error

+ CancelRequested func(ctx context.Context, id task.ID) (bool, error)

+ CancelRunning func(ctx context.Context, id task.ID, reason string) error

+ ClaimDue func(ctx context.Context, owner string, lease time.Duration) (task.Task, error)

+ Close func() error

+ Complete func(ctx context.Context, id task.ID, owner string, result json.RawMessage) error

+ CountFacts func(ctx context.Context, ftype journal.FactType, since time.Time) (int64, error)

+ CountTasks func(ctx context.Context, f Filter) (int, error)

+ Enqueue func(ctx context.Context, n task.New) (task.Task, error)

+ Facts func(ctx context.Context, after int64, limit int) ([]journal.Fact, error)

+ FactsForTask func(ctx context.Context, id string, limit int) ([]journal.Fact, error)

+ Fail func(ctx context.Context, id task.ID, owner string, errText string, ...) error

+ FailPermanent func(ctx context.Context, id task.ID, owner string, errText string, ...) error

+ Get func(ctx context.Context, id task.ID) (task.Task, error)

+ HeadSeq func(ctx context.Context) (int64, error)

+ Heartbeat func(ctx context.Context, id task.ID, owner string, extend time.Duration) error

+ LastFacts func(ctx context.Context, limit int) ([]journal.Fact, error)

+ List func(ctx context.Context, f Filter) ([]task.Task, error)

+ MarkOrphaned func(ctx context.Context, cutoff time.Time) (int, error)

+ ProjectCounts func(ctx context.Context) (map[string]map[task.Status]int, error)

+ Requeue func(ctx context.Context, id task.ID, owner string, errText string, ...) error

+ RescueDead func(ctx context.Context, id task.ID, maxAttempts int) error

+ SaveWatermark func(ctx context.Context, consumer string, seq int64) error

+ StatusCounts func(ctx context.Context) (map[task.Status]int, error)

+ Watermark func(ctx context.Context, consumer string) (seq int64, exists bool, err error)

+ type StoreOption func(*storeOptions)

+ func WithProjectExclusivity() StoreOption

+ type WatermarkEntry struct

+ Consumer string

+ Seq int64

+ UpdatedAt int64

Other modules containing this package

github.com/larsartmann/go-taskqueue

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