queue

Jul 13, 2024

Changes in this version

+ type Job interface

+ Bytes func() []byte

+ Execute func(context.Context) error

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

+ ID func() ids.ID

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

+ type Jobs struct

+ 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 *snow.ConsensusContext, halter common.Haltable, ...) (int, error)

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

+ func (j *Jobs) PendingJobs() uint64

+ func (j *Jobs) Push(ctx context.Context, job Job) (bool, error)

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

+ type JobsWithMissing struct

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

+ func (jm *JobsWithMissing) AddMissingID(jobIDs ...ids.ID)

+ func (jm *JobsWithMissing) Clear() error

+ func (jm *JobsWithMissing) Commit() error

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

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

+ func (jm *JobsWithMissing) NumMissingIDs() int

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

+ func (jm *JobsWithMissing) RemoveMissingID(jobIDs ...ids.ID)

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

+ type Parser interface

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