xdelta

Documentation

Index

• type Goroutine
  • func (g *Goroutine) OK()
  • func (g *Goroutine) Panic(err error)
  • func (g *Goroutine) String() string
• type Program
• type Run
  • func (r *Run) Wait() error
• type Runner
  • func NewRunner() (*Runner, error)
  • func (r *Runner) Cleanup()
  • func (r *Runner) RunTest(name string, f func(t *TestGroup))
• type TestGroup
  • func (t *TestGroup) CompareStreams(r1 io.ReadCloser, r2 io.ReadCloser, length int64) *Goroutine
  • func (t *TestGroup) CopyStreams(r io.ReadCloser, w io.WriteCloser, written *int64) *Goroutine
  • func (t *TestGroup) Drain(f io.ReadCloser, desc string) <-chan []byte
  • func (t *TestGroup) Empty(f io.ReadCloser, desc string) *Goroutine
  • func (t *TestGroup) Exec(desc string, p Program, srcfifo bool, flags []string) (*Run, error)
  • func (t *TestGroup) Fail(v ...interface{})
  • func (t *TestGroup) Go(name string, f func(*Goroutine)) *Goroutine
  • func (t *TestGroup) Main() *Goroutine
  • func (t *TestGroup) Panic(err error)
  • func (t *TestGroup) TestWrite(what string, f io.WriteCloser, b []byte) *Goroutine
  • func (t *TestGroup) Wait(procs ...*Run)
  • func (t *TestGroup) WriteRstreams(desc string, seed, offset, len int64, src, tgt io.WriteCloser)

Types

type Goroutine

type Goroutine struct {
	*TestGroup
	// contains filtered or unexported fields
}

func (*Goroutine) OK

func (g *Goroutine) OK()

func (*Goroutine) Panic

func (g *Goroutine) Panic(err error)

func (*Goroutine) String

func (g *Goroutine) String() string

type Program

type Program struct {
	Path string
}

type Run

type Run struct {
	Cmd     exec.Cmd
	Srcfile string
	Stdin   io.WriteCloser
	Srcin   io.WriteCloser
	Stdout  io.ReadCloser
	Stderr  io.ReadCloser
}

func (*Run) Wait

func (r *Run) Wait() error

type Runner

type Runner struct {
	Testdir string
}

func NewRunner

func NewRunner() (*Runner, error)

func (*Runner) Cleanup

func (r *Runner) Cleanup()

func (*Runner) RunTest

func (r *Runner) RunTest(name string, f func(t *TestGroup))

type TestGroup

type TestGroup struct {
	*Runner

	sync.Mutex
	sync.WaitGroup
	// contains filtered or unexported fields
}

func (*TestGroup) CompareStreams

func (t *TestGroup) CompareStreams(r1 io.ReadCloser, r2 io.ReadCloser, length int64) *Goroutine

func (*TestGroup) CopyStreams

func (t *TestGroup) CopyStreams(r io.ReadCloser, w io.WriteCloser, written *int64) *Goroutine

func (*TestGroup) Drain

func (t *TestGroup) Drain(f io.ReadCloser, desc string) <-chan []byte

func (*TestGroup) Empty

func (t *TestGroup) Empty(f io.ReadCloser, desc string) *Goroutine

func (*TestGroup) Exec

func (t *TestGroup) Exec(desc string, p Program, srcfifo bool, flags []string) (*Run, error)

func (*TestGroup) Fail

func (t *TestGroup) Fail(v ...interface{})

func (*TestGroup) Go

func (t *TestGroup) Go(name string, f func(*Goroutine)) *Goroutine

func (*TestGroup) Main

func (t *TestGroup) Main() *Goroutine

func (*TestGroup) Panic

func (t *TestGroup) Panic(err error)

func (*TestGroup) TestWrite

func (t *TestGroup) TestWrite(what string, f io.WriteCloser, b []byte) *Goroutine

func (*TestGroup) Wait

func (t *TestGroup) Wait(procs ...*Run)

func (*TestGroup) WriteRstreams

func (t *TestGroup) WriteRstreams(desc string, seed, offset, len int64,
	src, tgt io.WriteCloser)