mocks

Documentation

Index

• func DataBlockEqual(a *datablocks.DataBlock, b *datablocks.DataBlock) bool
• func NewBlockFromSlice(cols []*columns.Column, datas ...[]interface{}) *datablocks.DataBlock
• func NewSourceFromSlice(datas ...interface{}) []interface{}
• type Mock
  • func NewMock() (*Mock, func())
• type MockBlockInputStream
  • func NewMockBlockInputStream(datas []interface{}) *MockBlockInputStream
  • func (stream *MockBlockInputStream) Close()
  • func (stream *MockBlockInputStream) Insert(v *datablocks.DataBlock) error
  • func (stream *MockBlockInputStream) Name() string
  • func (stream *MockBlockInputStream) Read() (*datablocks.DataBlock, error)

Functions

func DataBlockEqual

func DataBlockEqual(a *datablocks.DataBlock, b *datablocks.DataBlock) bool

func NewBlockFromSlice

func NewBlockFromSlice(cols []*columns.Column, datas ...[]interface{}) *datablocks.DataBlock

func NewSourceFromSlice

func NewSourceFromSlice(datas ...interface{}) []interface{}

Types

type Mock

type Mock struct {
	Log     *xlog.Log
	Conf    *config.Config
	Session *sessions.Session
	Ctx     context.Context
	Cancel  context.CancelFunc
}

func NewMock

func NewMock() (*Mock, func())

type MockBlockInputStream

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

func NewMockBlockInputStream

func NewMockBlockInputStream(datas []interface{}) *MockBlockInputStream

func (*MockBlockInputStream) Close

func (stream *MockBlockInputStream) Close()

func (*MockBlockInputStream) Insert

func (stream *MockBlockInputStream) Insert(v *datablocks.DataBlock) error

func (*MockBlockInputStream) Name

func (stream *MockBlockInputStream) Name() string

func (*MockBlockInputStream) Read

func (stream *MockBlockInputStream) Read() (*datablocks.DataBlock, error)