solo

Documentation

Index

• type Solo
  • func NewSolo(jr job.JobRequestSingle, bc *core.BlockChain, pq *queue.JobPriorityQueue, ...) *Solo
  • func (s *Solo) Cancel()
  • func (s *Solo) Dispatch()
  • func (s Solo) GetCancelChan() chan struct{}
  • func (s Solo) GetJob() job.JobRequestSingle
  • func (s Solo) GetStatus() string
  • func (s Solo) Result() job.JobRequestSingle

Types

type Solo

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

Solo - Jobs executed one after the other

func NewSolo

func NewSolo(jr job.JobRequestSingle, bc *core.BlockChain, pq *queue.JobPriorityQueue, jc *cache.JobCache) *Solo

func (*Solo) Cancel

func (s *Solo) Cancel()

func (*Solo) Dispatch

func (s *Solo) Dispatch()

Dispatch executes the solo

func (Solo) GetCancelChan

func (s Solo) GetCancelChan() chan struct{}

func (Solo) GetJob

func (s Solo) GetJob() job.JobRequestSingle

func (Solo) GetStatus

func (s Solo) GetStatus() string

func (Solo) Result

func (s Solo) Result() job.JobRequestSingle

Result returns result