Documentation
¶
Index ¶
Constants ¶
View Source
const (
DefaultFetchSize = 1024
)
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type MySQLReaderJob ¶
type MySQLReaderJob struct {
// contains filtered or unexported fields
}
MySQLReaderJob MySQL读取作业
func NewMySQLReaderJob ¶
func NewMySQLReaderJob() *MySQLReaderJob
func (*MySQLReaderJob) Destroy ¶
func (job *MySQLReaderJob) Destroy() error
func (*MySQLReaderJob) Init ¶
func (job *MySQLReaderJob) Init(config config.Configuration) error
func (*MySQLReaderJob) Post ¶
func (job *MySQLReaderJob) Post() error
func (*MySQLReaderJob) Split ¶
func (job *MySQLReaderJob) Split(adviceNumber int) ([]config.Configuration, error)
type MySQLReaderJobFactory ¶
type MySQLReaderJobFactory struct{}
MySQLReaderJobFactory 实现ReaderJobFactory接口
func (*MySQLReaderJobFactory) CreateReaderJob ¶
func (f *MySQLReaderJobFactory) CreateReaderJob() plugin.ReaderJob
type MySQLReaderTask ¶
type MySQLReaderTask struct {
// contains filtered or unexported fields
}
MySQLReaderTask MySQL读取任务
func NewMySQLReaderTask ¶
func NewMySQLReaderTask() *MySQLReaderTask
func (*MySQLReaderTask) Destroy ¶
func (task *MySQLReaderTask) Destroy() error
func (*MySQLReaderTask) Init ¶
func (task *MySQLReaderTask) Init(config config.Configuration) error
func (*MySQLReaderTask) Post ¶
func (task *MySQLReaderTask) Post() error
func (*MySQLReaderTask) StartRead ¶
func (task *MySQLReaderTask) StartRead(recordSender plugin.RecordSender) error
type MySQLReaderTaskFactory ¶
type MySQLReaderTaskFactory struct{}
MySQLReaderTaskFactory 实现ReaderTaskFactory接口
func (*MySQLReaderTaskFactory) CreateReaderTask ¶
func (f *MySQLReaderTaskFactory) CreateReaderTask() plugin.ReaderTask
Source Files
Click to show internal directories.
Click to hide internal directories.