runner

Documentation

Index

• Variables
• func NormalizeGODEBUG(value string) string
• type Parser
  • func NewParser() *Parser
  • func (p *Parser) Flush() *domain.GCEvent
  • func (p *Parser) ParseLine(line string) (*domain.GCEvent, error)
• type Runner
  • func NewRunner(target string, args []string, extraEnv map[string]string) *Runner
  • func (r *Runner) Close() error
  • func (r *Runner) Events() <-chan domain.GCEvent
  • func (r *Runner) ParseErrors() <-chan error
  • func (r *Runner) Start(ctx context.Context) error
  • func (r *Runner) Stderr() <-chan string
  • func (r *Runner) Wait() error

Variables

var (
	ErrParseGCLine      = errors.New("failed to parse gc line")
	ErrParsePacerLine   = errors.New("failed to parse pacer line")
	ErrPacerWithoutGC   = errors.New("pacer line without active gc event")
	ErrIncompleteGCLine = errors.New("incomplete gc line")
)

var (
	ErrAlreadyStarted = errors.New("runner already started")
	ErrNotStarted     = errors.New("runner not started")
)

Functions

func NormalizeGODEBUG

func NormalizeGODEBUG(value string) string

Types

type Parser

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

func NewParser

func NewParser() *Parser

func (*Parser) Flush

func (p *Parser) Flush() *domain.GCEvent

func (*Parser) ParseLine

func (p *Parser) ParseLine(line string) (*domain.GCEvent, error)

type Runner

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

func NewRunner

func NewRunner(target string, args []string, extraEnv map[string]string) *Runner

func (*Runner) Close

func (r *Runner) Close() error

func (*Runner) Events

func (r *Runner) Events() <-chan domain.GCEvent

func (*Runner) ParseErrors

func (r *Runner) ParseErrors() <-chan error

func (*Runner) Start

func (r *Runner) Start(ctx context.Context) error

func (*Runner) Stderr

func (r *Runner) Stderr() <-chan string

func (*Runner) Wait

func (r *Runner) Wait() error