test

Documentation

Index

• Constants
• func GetMockClock() *clock.Mock
• func ResetClock(t int64)
• type MockSink
  • func NewMockSink() *MockSink
  • func (m *MockSink) Close(ctx api.StreamContext) error
  • func (m *MockSink) Collect(ctx api.StreamContext, item interface{}) error
  • func (m *MockSink) Configure(props map[string]interface{}) error
  • func (m *MockSink) GetResults() [][]byte
  • func (m *MockSink) Open(ctx api.StreamContext) error
• type MockSource
  • func NewMockSource(data []*xsql.Tuple) *MockSource
  • func (m *MockSource) Close(_ api.StreamContext) error
  • func (m *MockSource) Configure(_ string, _ map[string]interface{}) error
  • func (m *MockSource) GetOffset() (interface{}, error)
  • func (m *MockSource) Open(ctx api.StreamContext, consumer chan<- api.SourceTuple, _ chan<- error)
  • func (m *MockSource) Rewind(offset interface{}) error

Constants

const TIMELEAP = 200

Functions

func GetMockClock

func GetMockClock() *clock.Mock

func ResetClock

func ResetClock(t int64)

Types

type MockSink

type MockSink struct {
	// contains filtered or unexported fields
}

func NewMockSink

func NewMockSink() *MockSink

func (*MockSink) Close

func (m *MockSink) Close(ctx api.StreamContext) error

func (*MockSink) Collect

func (m *MockSink) Collect(ctx api.StreamContext, item interface{}) error

func (*MockSink) Configure

func (m *MockSink) Configure(props map[string]interface{}) error

func (*MockSink) GetResults

func (m *MockSink) GetResults() [][]byte

func (*MockSink) Open

func (m *MockSink) Open(ctx api.StreamContext) error

type MockSource

type MockSource struct {
	sync.Mutex
	// contains filtered or unexported fields
}

func NewMockSource

func NewMockSource(data []*xsql.Tuple) *MockSource

func (*MockSource) Close

func (m *MockSource) Close(_ api.StreamContext) error

func (*MockSource) Configure

func (m *MockSource) Configure(_ string, _ map[string]interface{}) error

func (*MockSource) GetOffset

func (m *MockSource) GetOffset() (interface{}, error)

func (*MockSource) Open

func (m *MockSource) Open(ctx api.StreamContext, consumer chan<- api.SourceTuple, _ chan<- error)

func (*MockSource) Rewind

func (m *MockSource) Rewind(offset interface{}) error