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