queue

Jul 20, 2025

Changes in this version

type Job

+ Bytes func() []byte

+ HasMissingDependencies func(context.Context) (bool, error)

+ MissingDependencies func(context.Context) (set.Set[ids.ID], error)

type Jobs

+ func New(db database.Database, metricsNamespace string, ...) (*Jobs, error)

+ func (j *Jobs) Clear() error

+ func (j *Jobs) Commit() error

+ func (j *Jobs) ExecuteAll(ctx context.Context, chainCtx *consensus.Context, halter engine.Haltable, ...) (int, error)

+ func (j *Jobs) Has(jobID ids.ID) (bool, error)

+ func (j *Jobs) PendingJobs() uint64

+ func (j *Jobs) SetParser(parser Parser) error

type JobsWithMissing

+ func NewWithMissing(db database.Database, metricsNamespace string, ...) (*JobsWithMissing, error)

+ func (jm *JobsWithMissing) Clear() error

+ func (jm *JobsWithMissing) Commit() error

+ func (jm *JobsWithMissing) Has(jobID ids.ID) (bool, error)

+ func (jm *JobsWithMissing) NumMissingIDs() int

+ func (jm *JobsWithMissing) Push(ctx context.Context, job Job) (bool, error)

+ func (jm *JobsWithMissing) SetParser(ctx context.Context, parser Parser) error

+ type Parser interface

+ Parse func(context.Context, []byte) (Job, error)

Jul 30, 2025

Changes in this version

+ type Job interface

+ Execute func() error

+ ID func() ids.ID

+ Priority func() uint64

+ type Jobs struct

+ func NewJobs() *Jobs

+ func (j *Jobs) Len() int

+ func (j *Jobs) Pop() (Job, bool)

+ func (j *Jobs) Push(job Job)

+ type JobsWithMissing struct

+ func NewJobsWithMissing() *JobsWithMissing

+ func (j *JobsWithMissing) AddMissingID(missingID ids.ID, job Job)

+ func (j *JobsWithMissing) HasMissingIDs() bool

+ func (j *JobsWithMissing) MissingIDs() []ids.ID

+ func (j *JobsWithMissing) RemoveMissingID(id ids.ID) []Job

+ type Queue interface

+ Has func(ids.ID) bool

+ Len func() int

+ Pop func() (Job, bool)

+ Push func(Job)

+ Remove func(ids.ID) bool

+ func NewQueue() Queue