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