pull

Documentation

Index

• type Event
• type JSONRowExporter
  • func NewJSONRowExporter(file io.Writer) *JSONRowExporter
  • func (re *JSONRowExporter) Export(r pull.Row) *pull.Error
• type JSONRowReader
  • func NewJSONRowReader(file io.Reader) *JSONRowReader
  • func (jrr *JSONRowReader) Error() *pull.Error
  • func (jrr *JSONRowReader) Next() bool
  • func (jrr *JSONRowReader) Value() pull.Row
• type JSONTraceListener
  • func NewJSONTraceListener(file *os.File) JSONTraceListener
  • func (t JSONTraceListener) TraceStep(s pull.Step, filter pull.Filter) pull.TraceListener
• type MockSQLDialect
  • func (_m *MockSQLDialect) Limit(_a0 uint) string
  • func (_m *MockSQLDialect) Placeholder(_a0 int) string
• type OracleDataSourceFactory
  • func NewOracleDataSourceFactory() *OracleDataSourceFactory
  • func (e *OracleDataSourceFactory) New(url string, schema string) pull.DataSource
• type OracleDialect
  • func (od OracleDialect) Limit(limit uint) string
  • func (od OracleDialect) Placeholder(position int) string
• type PostgresDataSourceFactory
  • func NewPostgresDataSourceFactory() *PostgresDataSourceFactory
  • func (e *PostgresDataSourceFactory) New(url string, schema string) pull.DataSource
• type PostgresDialect
  • func (pd PostgresDialect) Limit(limit uint) string
  • func (pd PostgresDialect) Placeholder(position int) string
• type SQLDataIterator
  • func (di *SQLDataIterator) Error() *pull.Error
  • func (di *SQLDataIterator) Next() bool
  • func (di *SQLDataIterator) Value() pull.Row
• type SQLDataSource
  • func (ds *SQLDataSource) Close() *pull.Error
  • func (ds *SQLDataSource) Open() *pull.Error
  • func (ds *SQLDataSource) RowReader(source pull.Table, filter pull.Filter) (pull.RowReader, *pull.Error)
• type SQLDialect

Types

type Event

type Event struct {
	Duration int64  `json:"duration"`
	Index    uint   `json:"index"`
	Entry    string `json:"entry"`
	Follow   string `json:"follow"`
	Filter   string `json:"filter"`
}

Event is catch by json tracer

type JSONRowExporter

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

JSONRowExporter export rows to JSON format.

func NewJSONRowExporter

func NewJSONRowExporter(file io.Writer) *JSONRowExporter

NewJSONRowExporter creates a new JSONRowExporter.

func (*JSONRowExporter) Export

func (re *JSONRowExporter) Export(r pull.Row) *pull.Error

Export rows in JSON format.

type JSONRowReader

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

JSONRowJSONRowReader read row from JSONLine file

func NewJSONRowReader

func NewJSONRowReader(file io.Reader) *JSONRowReader

NNewJSONRowReader create a new JSONRowReader

func (*JSONRowReader) Error

func (jrr *JSONRowReader) Error() *pull.Error

func (*JSONRowReader) Next

func (jrr *JSONRowReader) Next() bool

Next return true if Next Value is present

func (*JSONRowReader) Value

func (jrr *JSONRowReader) Value() pull.Row

Value return the current Row

type JSONTraceListener

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

JSONTraceListener JSON event tracer

func NewJSONTraceListener

func NewJSONTraceListener(file *os.File) JSONTraceListener

NewJSONTraceListener create JsonTraceListner

func (JSONTraceListener) TraceStep

func (t JSONTraceListener) TraceStep(s pull.Step, filter pull.Filter) pull.TraceListener

TraceStep catch Step event.

type MockSQLDialect

type MockSQLDialect struct {
	mock.Mock
}

MockSQLDialect is an autogenerated mock type for the SQLDialect type

func (*MockSQLDialect) Limit

func (_m *MockSQLDialect) Limit(_a0 uint) string

Limit provides a mock function with given fields: _a0

func (*MockSQLDialect) Placeholder

func (_m *MockSQLDialect) Placeholder(_a0 int) string

Placeholder provides a mock function with given fields: _a0

type OracleDataSourceFactory

type OracleDataSourceFactory struct{}

OracleDataSourceFactory exposes methods to create new Oracle pullers.

func NewOracleDataSourceFactory

func NewOracleDataSourceFactory() *OracleDataSourceFactory

NewOracleDataSourceFactory creates a new oracle datasource factory.

func (*OracleDataSourceFactory) New

func (e *OracleDataSourceFactory) New(url string, schema string) pull.DataSource

New return a Oracle puller

type OracleDialect

type OracleDialect struct{}

PostgresDialect implement postgres SQL variations

func (OracleDialect) Limit

func (od OracleDialect) Limit(limit uint) string

func (OracleDialect) Placeholder

func (od OracleDialect) Placeholder(position int) string

type PostgresDataSourceFactory

type PostgresDataSourceFactory struct{}

PostgresDataSourceFactory exposes methods to create new Postgres pullers.

func NewPostgresDataSourceFactory

func NewPostgresDataSourceFactory() *PostgresDataSourceFactory

NewPostgresDataSourceFactory creates a new postgres datasource factory.

func (*PostgresDataSourceFactory) New

func (e *PostgresDataSourceFactory) New(url string, schema string) pull.DataSource

New return a Postgres puller

type PostgresDialect

type PostgresDialect struct{}

PostgresDialect implement postgres SQL variations

func (PostgresDialect) Limit

func (pd PostgresDialect) Limit(limit uint) string

func (PostgresDialect) Placeholder

func (pd PostgresDialect) Placeholder(position int) string

type SQLDataIterator

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

SQLDataIterator read data from a SQL database.

func (*SQLDataIterator) Error

func (di *SQLDataIterator) Error() *pull.Error

Error returns the iterator error

func (*SQLDataIterator) Next

func (di *SQLDataIterator) Next() bool

Next reads the next rows if it exists.

func (*SQLDataIterator) Value

func (di *SQLDataIterator) Value() pull.Row

Value returns the last read row.

type SQLDataSource

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

SQLDataSource to read in the pull process.

func (*SQLDataSource) Close

func (ds *SQLDataSource) Close() *pull.Error

Close a connection to the SQL DB

func (*SQLDataSource) Open

func (ds *SQLDataSource) Open() *pull.Error

Open a connection to the SQL DB

func (*SQLDataSource) RowReader

func (ds *SQLDataSource) RowReader(source pull.Table, filter pull.Filter) (pull.RowReader, *pull.Error)

RowReader iterate over rows in table with filter

type SQLDialect

type SQLDialect interface {

	// Placeholder format variable in query
	Placeholder(int) string
	// Limit format limitation clause
	Limit(uint) string
}

SQLDialect to inject SQL variations