Versions in this module Expand all Collapse all v1 v1.0.0 Jul 21, 2022 Changes in this version + const StatusUpdateFrequency + type Job interface + Bytes func() []byte + Execute func() error + HasMissingDependencies func() (bool, error) + ID func() ids.ID + MissingDependencies func() (ids.Set, 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 *snow.ConsensusContext, halter common.Haltable, restarted bool, ...) (int, error) + func (j *Jobs) Has(jobID ids.ID) (bool, error) + func (j *Jobs) PendingJobs() uint64 + func (j *Jobs) Push(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(job Job) (bool, error) + func (jm *JobsWithMissing) RemoveMissingID(jobIDs ...ids.ID) + func (jm *JobsWithMissing) SetParser(parser Parser) error + type Parser interface + Parse func([]byte) (Job, error) + type TestJob struct + BytesF func() []byte + CantBytes bool + CantExecute bool + CantHasMissingDependencies bool + CantID bool + CantMissingDependencies bool + ExecuteF func() error + HasMissingDependenciesF func() (bool, error) + IDF func() ids.ID + MissingDependenciesF func() (ids.Set, error) + T *testing.T + func (j *TestJob) Bytes() []byte + func (j *TestJob) Default(cant bool) + func (j *TestJob) Execute() error + func (j *TestJob) HasMissingDependencies() (bool, error) + func (j *TestJob) ID() ids.ID + func (j *TestJob) MissingDependencies() (ids.Set, error) + type TestParser struct + CantParse bool + ParseF func([]byte) (Job, error) + T *testing.T + func (p *TestParser) Default(cant bool) + func (p *TestParser) Parse(b []byte) (Job, error) v1.0.0-alpha Nov 22, 2022
Go to main page