coretest

func AssertSinkEqualFile ¶ added in v0.3.0

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

func AssertSinkEqualStdStream ¶ added in v0.3.0

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

func AssertSourceEqualFile ¶ added in v0.3.0

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

func AssertSourceEqualStdStream ¶ added in v0.3.0

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

func DecodeAndValidateT ¶ added in v0.5.22

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

func DecodeT ¶ added in v0.5.22

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 ¶ added in v0.3.0

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 ¶ added in v0.3.0

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

func ExpectScheduleNextsStartAtT ¶ added in v0.5.22

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

func ExpectScheduleNextsT ¶ added in v0.5.22

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

func ParseYAML ¶ added in v0.5.22

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