queue

Documentation

Index

• type Job
• type Jobs
  • func New(db database.Database) (*Jobs, error)
  • func (j *Jobs) Commit() error
  • func (j *Jobs) Execute(job Job) error
  • func (j *Jobs) HasNext() (bool, error)
  • func (j *Jobs) Pop() (Job, error)
  • func (j *Jobs) Push(job Job) error
  • func (j *Jobs) SetParser(parser Parser)
• type Parser
• type TestJob
  • func (j *TestJob) Bytes() []byte
  • func (j *TestJob) Default(cant bool)
  • func (j *TestJob) Execute()
  • func (j *TestJob) ID() ids.ID
  • func (j *TestJob) MissingDependencies() ids.Set
• type TestParser
  • func (p *TestParser) Default(cant bool)
  • func (p *TestParser) Parse(b []byte) (Job, error)

Types

type Job

type Job interface {
	ID() ids.ID

	MissingDependencies() ids.Set
	Execute()

	Bytes() []byte
}

Job ...

type Jobs

type Jobs struct {
	// contains filtered or unexported fields
}

Jobs ...

func New

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

New ...

func (*Jobs) Commit

func (j *Jobs) Commit() error

Commit ...

func (*Jobs) Execute

func (j *Jobs) Execute(job Job) error

Execute ...

func (*Jobs) HasNext

func (j *Jobs) HasNext() (bool, error)

HasNext ...

func (*Jobs) Pop

func (j *Jobs) Pop() (Job, error)

Pop ...

func (*Jobs) Push

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

Push ...

func (*Jobs) SetParser

func (j *Jobs) SetParser(parser Parser)

SetParser ...

type Parser

type Parser interface {
	Parse([]byte) (Job, error)
}

Parser ...

type TestJob

type TestJob struct {
	T *testing.T

	CantID,
	CantMissingDependencies,
	CantExecute,
	CantBytes bool

	IDF                  func() ids.ID
	MissingDependenciesF func() ids.Set
	ExecuteF             func()
	BytesF               func() []byte
}

TestJob is a test Job

func (*TestJob) Bytes

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

Bytes ...

func (*TestJob) Default

func (j *TestJob) Default(cant bool)

Default ...

func (*TestJob) Execute

func (j *TestJob) Execute()

Execute ...

func (*TestJob) ID

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

ID ...

func (*TestJob) MissingDependencies

func (j *TestJob) MissingDependencies() ids.Set

MissingDependencies ...

type TestParser

type TestParser struct {
	T *testing.T

	CantParse bool

	ParseF func([]byte) (Job, error)
}

TestParser is a test Parser

func (*TestParser) Default

func (p *TestParser) Default(cant bool)

Default ...

func (*TestParser) Parse

func (p *TestParser) Parse(b []byte) (Job, error)

Parse ...