coretest

Documentation

Index

• func AssertSinkEqualFile(t *testing.T, fs afero.Fs, filename string, sink core.DataSink)
• func AssertSinkEqualStdStream(t *testing.T, expectedPtr **os.File, getSink func() core.DataSink)
• func AssertSourceEqualFile(t *testing.T, fs afero.Fs, filename string, source core.DataSource)
• func AssertSourceEqualStdStream(t *testing.T, expectedPtr **os.File, getSource func() core.DataSource)
• func DecodeAndValidateT(t *testing.T, data string, result interface{})
• func DecodeT(t *testing.T, data string, result interface{})
• func DrainSchedule(t *testing.T, sched core.Schedule) []time.Time
• func DrainScheduleDuration(t *testing.T, sched core.Schedule, startAt time.Time) []time.Duration
• func ExpectScheduleNexts(t *testing.T, sched core.Schedule, nexts ...time.Duration)
• func ExpectScheduleNextsStartAt(t *testing.T, sched core.Schedule, startAt time.Time, nexts ...time.Duration)
• func ExpectScheduleNextsStartAtT(t *testing.T, sched core.Schedule, startAt time.Time, nexts ...time.Duration)
• func ExpectScheduleNextsT(t *testing.T, sched core.Schedule, nexts ...time.Duration)
• func ParseYAML(t *testing.T, data string) map[string]interface{}

Functions

func AssertSinkEqualFile

func AssertSinkEqualFile(t *testing.T, fs afero.Fs, filename string, sink core.DataSink)

func AssertSinkEqualStdStream

func AssertSinkEqualStdStream(t *testing.T, expectedPtr **os.File, getSink func() core.DataSink)

func AssertSourceEqualFile

func AssertSourceEqualFile(t *testing.T, fs afero.Fs, filename string, source core.DataSource)

func AssertSourceEqualStdStream

func AssertSourceEqualStdStream(t *testing.T, expectedPtr **os.File, getSource func() core.DataSource)

func DecodeAndValidateT

func DecodeAndValidateT(t *testing.T, data string, result interface{})

func DecodeT

func DecodeT(t *testing.T, data string, result interface{})

func DrainSchedule

func DrainSchedule(t *testing.T, sched core.Schedule) []time.Time

DrainSchedule takes all tokens from passed schedule. Returns all tokens and finish time.

func DrainScheduleDuration

func DrainScheduleDuration(t *testing.T, sched core.Schedule, startAt time.Time) []time.Duration

DrainSchedule starts schedule and takes all tokens from it. Returns all tokens and finish time relative to start

func ExpectScheduleNexts

func ExpectScheduleNexts(t *testing.T, sched core.Schedule, nexts ...time.Duration)

func ExpectScheduleNextsStartAt

func ExpectScheduleNextsStartAt(t *testing.T, sched core.Schedule, startAt time.Time, nexts ...time.Duration)

func ExpectScheduleNextsStartAtT

func ExpectScheduleNextsStartAtT(t *testing.T, sched core.Schedule, startAt time.Time, nexts ...time.Duration)

func ExpectScheduleNextsT

func ExpectScheduleNextsT(t *testing.T, sched core.Schedule, nexts ...time.Duration)

func ParseYAML

func ParseYAML(t *testing.T, data string) map[string]interface{}