testing

type MockReader ¶

type MockReader struct {
	Reads []ReadResult
}

func (r *MockReader) Close() error

func (r *MockReader) Read(context.Context) (model.MXPGVKEvent, error)

type MockWindowIterator ¶

type MockWindowIterator struct {
	Windows []Window
}

func (i *MockWindowIterator) More() bool

func (i *MockWindowIterator) Next() (event.Reader, time.Range, error)

type MockWriter ¶

type MockWriter struct {
	Events []model.MXPGVKEvent
}

func (w *MockWriter) Write(e model.MXPGVKEvent) error

type ReadResult ¶

type ReadResult struct {
	Event model.MXPGVKEvent
	Err   error
}

ReadResult is a return value of event.Reader.Read().

type Window ¶

type Window struct {
	Reader event.Reader
	Window time.Range
	Err    error
}

Window is a return value of event.WindowIterator.Next().