processor

Documentation

Index

• Constants
• type GalaxyProcessor
  • func (p *GalaxyProcessor) CancelAnalyses() (err error)
  • func (p *GalaxyProcessor) InitProcessor(url, apikey, boosterid, phymlid, fasttreeid string, galaxyrequestattempts int, ...)
  • func (p *GalaxyProcessor) LaunchAnalysis(a *model.Analysis) (err error)
• type LocalProcessor
  • func (p *LocalProcessor) CancelAnalyses() (err error)
  • func (p *LocalProcessor) InitProcessor(nbrunners, queuesize, timeout, jobthreads int, db database.BoosterwebDB, ...)
  • func (p *LocalProcessor) LaunchAnalysis(a *model.Analysis) (err error)
• type Processor

Constants

const (
	RUNNERS_QUEUESIZE_DEFAULT  = 10
	RUNNERS_NBRUNNERS_DEFAULT  = 1
	RUNNERS_TIMEOUT_DEFAULT    = 0 // unlimited
	RUNNERS_JOBTHREADS_DEFAULT = 1
)

Types

type GalaxyProcessor

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

The Galaxy processor launches jobs on a remote galaxy server

It can launch only booster if analysis input files are

func (*GalaxyProcessor) CancelAnalyses

func (p *GalaxyProcessor) CancelAnalyses() (err error)

func (*GalaxyProcessor) InitProcessor

func (p *GalaxyProcessor) InitProcessor(url, apikey, boosterid, phymlid, fasttreeid string, galaxyrequestattempts int, db database.BoosterwebDB, notifier notification.Notifier, queuesize, timeout, memlimit int)

Initializes the Galaxy Processor

func (*GalaxyProcessor) LaunchAnalysis

func (p *GalaxyProcessor) LaunchAnalysis(a *model.Analysis) (err error)

It will add the Analysis to the Queue and store it in the database

type LocalProcessor

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

func (*LocalProcessor) CancelAnalyses

func (p *LocalProcessor) CancelAnalyses() (err error)

func (*LocalProcessor) InitProcessor

func (p *LocalProcessor) InitProcessor(nbrunners, queuesize, timeout, jobthreads int, db database.BoosterwebDB, notifier notification.Notifier)

func (*LocalProcessor) LaunchAnalysis

func (p *LocalProcessor) LaunchAnalysis(a *model.Analysis) (err error)

type Processor

type Processor interface {
	LaunchAnalysis(a *model.Analysis) error
	CancelAnalyses() error
}