Documentation ¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
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 ¶
JSONRowExporter export rows to JSON format.
func NewJSONRowExporter ¶
func NewJSONRowExporter(file io.Writer) *JSONRowExporter
NewJSONRowExporter creates a new JSONRowExporter.
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 ¶
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