reader

Documentation

Overview

Package reader is a generated GoMock package.

Package reader is a generated GoMock package.

Index

• Constants
• func NewContinueError(err error) error
• func RegistryConvertor(name string, convert Convertor)
• type BatchRecordReader
  • func NewBatchRecordReader(rr RecordReader, c string, opts ...Option) BatchRecordReader
  • func NewSQLBatchRecordReader(s *source.SQLSource, c string, opts ...Option) BatchRecordReader
• type Convertor
  • func GetConvertor(name string) Convertor
• type MockBatchRecordReader
  • func NewMockBatchRecordReader(ctrl *gomock.Controller) *MockBatchRecordReader
  • func (m *MockBatchRecordReader) EXPECT() *MockBatchRecordReaderMockRecorder
  • func (m *MockBatchRecordReader) ReadBatch() (int, spec.Records, error)
  • func (m *MockBatchRecordReader) Size() (int64, error)
  • func (m *MockBatchRecordReader) Source() source.Source
• type MockBatchRecordReaderMockRecorder
  • func (mr *MockBatchRecordReaderMockRecorder) ReadBatch() *gomock.Call
  • func (mr *MockBatchRecordReaderMockRecorder) Size() *gomock.Call
  • func (mr *MockBatchRecordReaderMockRecorder) Source() *gomock.Call
• type MockRecordReader
  • func NewMockRecordReader(ctrl *gomock.Controller) *MockRecordReader
  • func (m *MockRecordReader) EXPECT() *MockRecordReaderMockRecorder
  • func (m *MockRecordReader) Read() (int, spec.Record, error)
  • func (m *MockRecordReader) Size() (int64, error)
  • func (m *MockRecordReader) Source() source.Source
• type MockRecordReaderMockRecorder
  • func (mr *MockRecordReaderMockRecorder) Read() *gomock.Call
  • func (mr *MockRecordReaderMockRecorder) Size() *gomock.Call
  • func (mr *MockRecordReaderMockRecorder) Source() *gomock.Call
• type NoneConvertor
  • func (*NoneConvertor) Apply(values []string) (spec.Records, error)
• type Option
  • func WithBatch(batch int) Option
  • func WithLogger(l logger.Logger) Option
• type RecordReader
  • func NewCSVReader(s source.Source) RecordReader
  • func NewRecordReader(s source.Source) RecordReader

Constants

const (
	DefaultBatchSize = 128
)

Functions

func NewContinueError

func NewContinueError(err error) error

func RegistryConvertor

func RegistryConvertor(name string, convert Convertor)

Types

type BatchRecordReader

type BatchRecordReader interface {
	Source() source.Source
	source.Sizer
	ReadBatch() (int, spec.Records, error)
}

func NewBatchRecordReader

func NewBatchRecordReader(rr RecordReader, c string, opts ...Option) BatchRecordReader

func NewSQLBatchRecordReader

func NewSQLBatchRecordReader(s *source.SQLSource, c string, opts ...Option) BatchRecordReader

type Convertor

type Convertor interface {
	Apply(values []string) (spec.Records, error)
}

func GetConvertor

func GetConvertor(name string) Convertor

type MockBatchRecordReader

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

MockBatchRecordReader is a mock of BatchRecordReader interface.

func NewMockBatchRecordReader

func NewMockBatchRecordReader(ctrl *gomock.Controller) *MockBatchRecordReader

NewMockBatchRecordReader creates a new mock instance.

func (*MockBatchRecordReader) EXPECT

func (m *MockBatchRecordReader) EXPECT() *MockBatchRecordReaderMockRecorder

EXPECT returns an object that allows the caller to indicate expected use.

func (*MockBatchRecordReader) ReadBatch

func (m *MockBatchRecordReader) ReadBatch() (int, spec.Records, error)

ReadBatch mocks base method.

func (*MockBatchRecordReader) Size

func (m *MockBatchRecordReader) Size() (int64, error)

Size mocks base method.

func (*MockBatchRecordReader) Source

func (m *MockBatchRecordReader) Source() source.Source

Source mocks base method.

type MockBatchRecordReaderMockRecorder

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

MockBatchRecordReaderMockRecorder is the mock recorder for MockBatchRecordReader.

func (*MockBatchRecordReaderMockRecorder) ReadBatch

func (mr *MockBatchRecordReaderMockRecorder) ReadBatch() *gomock.Call

ReadBatch indicates an expected call of ReadBatch.

func (*MockBatchRecordReaderMockRecorder) Size

func (mr *MockBatchRecordReaderMockRecorder) Size() *gomock.Call

Size indicates an expected call of Size.

func (*MockBatchRecordReaderMockRecorder) Source

func (mr *MockBatchRecordReaderMockRecorder) Source() *gomock.Call

Source indicates an expected call of Source.

type MockRecordReader

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

MockRecordReader is a mock of RecordReader interface.

func NewMockRecordReader

func NewMockRecordReader(ctrl *gomock.Controller) *MockRecordReader

NewMockRecordReader creates a new mock instance.

func (*MockRecordReader) EXPECT

func (m *MockRecordReader) EXPECT() *MockRecordReaderMockRecorder

EXPECT returns an object that allows the caller to indicate expected use.

func (*MockRecordReader) Read

func (m *MockRecordReader) Read() (int, spec.Record, error)

Read mocks base method.

func (*MockRecordReader) Size

func (m *MockRecordReader) Size() (int64, error)

Size mocks base method.

func (*MockRecordReader) Source

func (m *MockRecordReader) Source() source.Source

Source mocks base method.

type MockRecordReaderMockRecorder

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

MockRecordReaderMockRecorder is the mock recorder for MockRecordReader.

func (*MockRecordReaderMockRecorder) Read

func (mr *MockRecordReaderMockRecorder) Read() *gomock.Call

Read indicates an expected call of Read.

func (*MockRecordReaderMockRecorder) Size

func (mr *MockRecordReaderMockRecorder) Size() *gomock.Call

Size indicates an expected call of Size.

func (*MockRecordReaderMockRecorder) Source

func (mr *MockRecordReaderMockRecorder) Source() *gomock.Call

Source indicates an expected call of Source.

type NoneConvertor

type NoneConvertor struct {
}

func (*NoneConvertor) Apply

func (*NoneConvertor) Apply(values []string) (spec.Records, error)

type Option

type Option func(*options)

func WithBatch

func WithBatch(batch int) Option

func WithLogger

func WithLogger(l logger.Logger) Option

type RecordReader

type RecordReader interface {
	Source() source.Source
	source.Sizer
	Read() (int, spec.Record, error)
}

func NewCSVReader

func NewCSVReader(s source.Source) RecordReader

func NewRecordReader

func NewRecordReader(s source.Source) RecordReader