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