queue

Apr 9, 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)

+ type TestJob struct

+ BytesF func() []byte

+ CantBytes bool

+ CantExecute bool

+ CantHasMissingDependencies bool

+ CantID bool

+ CantMissingDependencies bool

+ ExecuteF func(context.Context) error

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

+ IDF func() ids.ID

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

+ T *testing.T

+ func (j *TestJob) Bytes() []byte

+ func (j *TestJob) Default(cant bool)

+ func (j *TestJob) Execute(ctx context.Context) error

+ func (j *TestJob) HasMissingDependencies(ctx context.Context) (bool, error)

+ func (j *TestJob) ID() ids.ID

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

+ type TestParser struct

+ CantParse bool

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

+ T *testing.T

+ func (p *TestParser) Default(cant bool)

+ func (p *TestParser) Parse(ctx context.Context, b []byte) (Job, error)