testutil

Documentation

Index

• func EnsureError(t *testing.T, err, expect error)
• func Int64SlicesEqual(a []int64, b []int64) bool
• func NewScribe(initializer scribe.InitializerFunc) *scribe.Scribe
• func NewScribeMulti(initializer scribe.InitializerFunc) *scribe.Scribe
• func NewTestStep(b chan bool) pipeline.Step
• func ReadersEqual(t *testing.T, value io.Reader, expected io.Reader)
• func RunPipeline(ctx context.Context, t *testing.T, path string, stdout io.Writer, ...)
• func WithTimeout(d time.Duration, f func(t *testing.T)) func(t *testing.T)

Functions

func EnsureError

func EnsureError(t *testing.T, err, expect error)

func Int64SlicesEqual

func Int64SlicesEqual(a []int64, b []int64) bool

func NewScribe

func NewScribe(initializer scribe.InitializerFunc) *scribe.Scribe

func NewScribeMulti

func NewScribeMulti(initializer scribe.InitializerFunc) *scribe.Scribe

func NewTestStep

func NewTestStep(b chan bool) pipeline.Step

NewTestStep creates a new TestStep that emits data into the channel 'b' when the action is ran

func ReadersEqual

func ReadersEqual(t *testing.T, value io.Reader, expected io.Reader)

func RunPipeline

func RunPipeline(ctx context.Context, t *testing.T, path string, stdout io.Writer, stderr io.Writer, args *args.PipelineArgs)

func WithTimeout

func WithTimeout(d time.Duration, f func(t *testing.T)) func(t *testing.T)

WithTimeout adds a timeout to the test function (f). If the `-timeout` flag is provided, then `f` will be called without a timeout and the `go test` command will handle the deadline.