testworker

Documentation

Index

• type JobHandler
• type Linter
  • func NewLinter(dir string) *Linter
  • func (l *Linter) Lint() (problems []lint.Problem, err error)
  • func (l *Linter) Problems() []lint.Problem
• type Option
• type Printer
  • func NewPrinter(bufSize uint32) *Printer
  • func (p Printer) Flush() (data []byte)
  • func (p Printer) Write(data []byte) (n int, err error)
• type ProgressLog
• type RespConsumeJob
• type TestWorker
  • func Instance() *TestWorker
  • func (t *TestWorker) Init(option Option) (err error)
  • func (t *TestWorker) Push(task view.TestTask) error
  • func (t *TestWorker) Start()

Types

type JobHandler

type JobHandler func(task view.TestTask, name string, p json.RawMessage) error

type Linter

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

func NewLinter

func NewLinter(dir string) *Linter

func (*Linter) Lint

func (l *Linter) Lint() (problems []lint.Problem, err error)

func (*Linter) Problems

func (l *Linter) Problems() []lint.Problem

type Option

type Option struct {
	JunoAddress    string
	Token          string
	ParallelWorker int
	RepoStorageDir string
	QueueDir       string
}

type Printer

type Printer struct {
	C chan string
	// contains filtered or unexported fields
}

func NewPrinter

func NewPrinter(bufSize uint32) *Printer

func (Printer) Flush

func (p Printer) Flush() (data []byte)

func (Printer) Write

func (p Printer) Write(data []byte) (n int, err error)

type ProgressLog

type ProgressLog struct {
	ProgressLog bool         `json:"progress_log"` // always true
	Type        progressType `json:"type"`         // "error" | "start"
	Msg         string       `json:"msg"`
}

type RespConsumeJob

type RespConsumeJob struct {
	Code int            `json:"code"`
	Msg  string         `json:"msg"`
	Data *view.TestTask `json:"data"`
}

type TestWorker

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

func Instance

func Instance() *TestWorker

func (*TestWorker) Init

func (t *TestWorker) Init(option Option) (err error)

func (*TestWorker) Push

func (t *TestWorker) Push(task view.TestTask) error

func (*TestWorker) Start

func (t *TestWorker) Start()