solo

Documentation

Index

• type Solo
  • func NewSolo(jr job.Request, 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.Request
  • func (s Solo) GetStatus() string
  • func (s Solo) Result() job.Request

Types

type Solo

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

Solo - single job execution

func NewSolo

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

NewSolo initializes solo

func (*Solo) Cancel

func (s *Solo) Cancel()

Cancel cancels exec

func (*Solo) Dispatch

func (s *Solo) Dispatch()

Dispatch executes the solo

func (Solo) GetCancelChan

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

GetCancelChan return cancel channel

func (Solo) GetJob

func (s Solo) GetJob() job.Request

GetJob returns job request

func (Solo) GetStatus

func (s Solo) GetStatus() string

GetStatus returns status

func (Solo) Result

func (s Solo) Result() job.Request

Result returns result