tasker

Documentation

Index

• func AddPRSParserLayout(ldp prsparser.Layout, name string)
• func CreateTasks(inputBucket string, outputBucket string, prsPath string, layout string, ...) error
• type Task
  • func (t *Task) Active() bool
  • func (t *Task) AddLine(id, line int, chromosome string)
  • func (t *Task) Clear()
  • func (t *Task) Count() int
  • func (t *Task) Print(inputBucket, outputBucket, layout, sourceFileName, overrideName string)

Functions

func AddPRSParserLayout

func AddPRSParserLayout(ldp prsparser.Layout, name string)

func CreateTasks

func CreateTasks(
	inputBucket string,
	outputBucket string,
	prsPath string,
	layout string,
	hasHeader bool,
	variantsPerJob int,
	overrideName string,
	customLayout string,
) error

Types

type Task

type Task struct {
	ID         int
	Chromosome string
	FirstLine  int
	LastLine   int
	// contains filtered or unexported fields
}

func (*Task) Active

func (t *Task) Active() bool

func (*Task) AddLine

func (t *Task) AddLine(id, line int, chromosome string)

func (*Task) Clear

func (t *Task) Clear()

func (*Task) Count

func (t *Task) Count() int

func (*Task) Print

func (t *Task) Print(inputBucket, outputBucket, layout, sourceFileName, overrideName string)