Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type JSONFileWriterJob ¶
type JSONFileWriterJob struct {
// contains filtered or unexported fields
}
JSONFileWriterJob JSON文件写入作业
func NewJSONFileWriterJob ¶
func NewJSONFileWriterJob() *JSONFileWriterJob
func (*JSONFileWriterJob) Destroy ¶
func (job *JSONFileWriterJob) Destroy() error
func (*JSONFileWriterJob) Init ¶
func (job *JSONFileWriterJob) Init(config config.Configuration) error
func (*JSONFileWriterJob) Post ¶
func (job *JSONFileWriterJob) Post() error
func (*JSONFileWriterJob) Prepare ¶
func (job *JSONFileWriterJob) Prepare() error
func (*JSONFileWriterJob) Split ¶
func (job *JSONFileWriterJob) Split(mandatoryNumber int) ([]config.Configuration, error)
type JSONFileWriterJobFactory ¶
type JSONFileWriterJobFactory struct{}
JSONFileWriterJobFactory 实现WriterJobFactory接口
func (*JSONFileWriterJobFactory) CreateWriterJob ¶
func (f *JSONFileWriterJobFactory) CreateWriterJob() plugin.WriterJob
type JSONFileWriterTask ¶
type JSONFileWriterTask struct {
// contains filtered or unexported fields
}
JSONFileWriterTask JSON文件写入任务
func NewJSONFileWriterTask ¶
func NewJSONFileWriterTask() *JSONFileWriterTask
func (*JSONFileWriterTask) Destroy ¶
func (task *JSONFileWriterTask) Destroy() error
func (*JSONFileWriterTask) Init ¶
func (task *JSONFileWriterTask) Init(config config.Configuration) error
func (*JSONFileWriterTask) Post ¶
func (task *JSONFileWriterTask) Post() error
func (*JSONFileWriterTask) Prepare ¶
func (task *JSONFileWriterTask) Prepare() error
func (*JSONFileWriterTask) StartWrite ¶
func (task *JSONFileWriterTask) StartWrite(recordReceiver plugin.RecordReceiver) error
type JSONFileWriterTaskFactory ¶
type JSONFileWriterTaskFactory struct{}
JSONFileWriterTaskFactory 实现WriterTaskFactory接口
func (*JSONFileWriterTaskFactory) CreateWriterTask ¶
func (f *JSONFileWriterTaskFactory) CreateWriterTask() plugin.WriterTask
Source Files
Click to show internal directories.
Click to hide internal directories.