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 Decode(data string, result interface{})
• func DecodeAndValidate(data string, result interface{})
• func DrainSchedule(sched core.Schedule) []time.Time
• func DrainScheduleDuration(sched core.Schedule, startAt time.Time) []time.Duration
• func ExpectScheduleNexts(sched core.Schedule, nexts ...time.Duration)
• func ExpectScheduleNextsStartAt(sched core.Schedule, startAt time.Time, nexts ...time.Duration)

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 Decode

func Decode(data string, result interface{})

func DecodeAndValidate

func DecodeAndValidate(data string, result interface{})

func DrainSchedule

func DrainSchedule(sched core.Schedule) []time.Time

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

func DrainScheduleDuration

func DrainScheduleDuration(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(sched core.Schedule, nexts ...time.Duration)

func ExpectScheduleNextsStartAt

func ExpectScheduleNextsStartAt(sched core.Schedule, startAt time.Time, nexts ...time.Duration)