Documentation
¶
Index ¶
Constants ¶
View Source
const (
DefaultBatchSize = 1024
)
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type MySQLWriterJob ¶
type MySQLWriterJob struct {
// contains filtered or unexported fields
}
MySQLWriterJob MySQL写入作业
func NewMySQLWriterJob ¶
func NewMySQLWriterJob() *MySQLWriterJob
func (*MySQLWriterJob) Destroy ¶
func (job *MySQLWriterJob) Destroy() error
func (*MySQLWriterJob) Init ¶
func (job *MySQLWriterJob) Init(config config.Configuration) error
func (*MySQLWriterJob) Post ¶
func (job *MySQLWriterJob) Post() error
func (*MySQLWriterJob) Prepare ¶
func (job *MySQLWriterJob) Prepare() error
func (*MySQLWriterJob) Split ¶
func (job *MySQLWriterJob) Split(mandatoryNumber int) ([]config.Configuration, error)
type MySQLWriterJobFactory ¶
type MySQLWriterJobFactory struct{}
MySQLWriterJobFactory 实现WriterJobFactory接口
func (*MySQLWriterJobFactory) CreateWriterJob ¶
func (f *MySQLWriterJobFactory) CreateWriterJob() plugin.WriterJob
type MySQLWriterTask ¶
type MySQLWriterTask struct {
// contains filtered or unexported fields
}
MySQLWriterTask MySQL写入任务
func NewMySQLWriterTask ¶
func NewMySQLWriterTask() *MySQLWriterTask
func (*MySQLWriterTask) Destroy ¶
func (task *MySQLWriterTask) Destroy() error
func (*MySQLWriterTask) Init ¶
func (task *MySQLWriterTask) Init(config config.Configuration) error
func (*MySQLWriterTask) Post ¶
func (task *MySQLWriterTask) Post() error
func (*MySQLWriterTask) Prepare ¶
func (task *MySQLWriterTask) Prepare() error
func (*MySQLWriterTask) StartWrite ¶
func (task *MySQLWriterTask) StartWrite(recordReceiver plugin.RecordReceiver) error
type MySQLWriterTaskFactory ¶
type MySQLWriterTaskFactory struct{}
MySQLWriterTaskFactory 实现WriterTaskFactory接口
func (*MySQLWriterTaskFactory) CreateWriterTask ¶
func (f *MySQLWriterTaskFactory) CreateWriterTask() plugin.WriterTask
Source Files
Click to show internal directories.
Click to hide internal directories.