qItem

Documentation

Index

• type Item
  • func DeserializeItem(b []byte) Item
  • func NewItem(j job.Job, exec *job.Exec, results chan<- Item, cancel chan<- struct{}) Item
  • func (i Item) GetCancel() chan<- struct{}
  • func (i Item) GetExec() *job.Exec
  • func (i Item) GetID() string
  • func (i Item) GetJob() job.Job
  • func (i Item) ResultsChan() chan<- Item
  • func (i Item) Serialize() []byte
  • func (i *Item) SetExec(ex *job.Exec)

Types

type Item

type Item struct {
	Job  job.Job
	Exec *job.Exec
	// contains filtered or unexported fields
}

func DeserializeItem

func DeserializeItem(b []byte) Item

func NewItem

func NewItem(j job.Job, exec *job.Exec, results chan<- Item, cancel chan<- struct{}) Item

func (Item) GetCancel

func (i Item) GetCancel() chan<- struct{}

func (Item) GetExec

func (i Item) GetExec() *job.Exec

GetExec returns exec

func (Item) GetID

func (i Item) GetID() string

GetID returns id

func (Item) GetJob

func (i Item) GetJob() job.Job

GetJob returns job

func (Item) ResultsChan

func (i Item) ResultsChan() chan<- Item

ResultsChan return result chan

func (Item) Serialize

func (i Item) Serialize() []byte

func (*Item) SetExec

func (i *Item) SetExec(ex *job.Exec)

sets exec