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