testing

Documentation

Index

• Variables
• func SortEvents(events []model.MXPGVKEvent)
• type MockReader
  • func (r *MockReader) Close() error
  • func (r *MockReader) Read(context.Context) (model.MXPGVKEvent, error)
• type MockWindowIterator
  • func (i *MockWindowIterator) More() bool
  • func (i *MockWindowIterator) Next() (event.Reader, time.Range, error)
• type MockWriter
  • func (w *MockWriter) Write(e model.MXPGVKEvent) error
• type ReadResult
• type Window

Variables

var ErrEOF = event.ErrEOF

Functions

func SortEvents

func SortEvents(events []model.MXPGVKEvent)

SortEvents sorts events by their fields.

Types

type MockReader

type MockReader struct {
	Reads []ReadResult
}

func (*MockReader) Close

func (r *MockReader) Close() error

func (*MockReader) Read

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

type MockWindowIterator

type MockWindowIterator struct {
	Windows []Window
}

func (*MockWindowIterator) More

func (i *MockWindowIterator) More() bool

func (*MockWindowIterator) Next

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

type MockWriter

type MockWriter struct {
	Events []model.MXPGVKEvent
}

func (*MockWriter) Write

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().