Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type StreamReaderJob ¶
type StreamReaderJob struct {
// contains filtered or unexported fields
}
StreamReaderJob Stream读取作业，用于生成测试数据
func NewStreamReaderJob ¶
func NewStreamReaderJob() *StreamReaderJob
func (*StreamReaderJob) Destroy ¶
func (job *StreamReaderJob) Destroy() error
func (*StreamReaderJob) Init ¶
func (job *StreamReaderJob) Init(config config.Configuration) error
func (*StreamReaderJob) Post ¶
func (job *StreamReaderJob) Post() error
func (*StreamReaderJob) Split ¶
func (job *StreamReaderJob) Split(adviceNumber int) ([]config.Configuration, error)
type StreamReaderJobFactory ¶
type StreamReaderJobFactory struct{}
StreamReaderJobFactory 实现ReaderJobFactory接口
func (*StreamReaderJobFactory) CreateReaderJob ¶
func (f *StreamReaderJobFactory) CreateReaderJob() plugin.ReaderJob
type StreamReaderTask ¶
type StreamReaderTask struct {
// contains filtered or unexported fields
}
StreamReaderTask Stream读取任务
func NewStreamReaderTask ¶
func NewStreamReaderTask() *StreamReaderTask
func (*StreamReaderTask) Destroy ¶
func (task *StreamReaderTask) Destroy() error
func (*StreamReaderTask) Init ¶
func (task *StreamReaderTask) Init(config config.Configuration) error
func (*StreamReaderTask) Post ¶
func (task *StreamReaderTask) Post() error
func (*StreamReaderTask) StartRead ¶
func (task *StreamReaderTask) StartRead(recordSender plugin.RecordSender) error
type StreamReaderTaskFactory ¶
type StreamReaderTaskFactory struct{}
StreamReaderTaskFactory 实现ReaderTaskFactory接口
func (*StreamReaderTaskFactory) CreateReaderTask ¶
func (f *StreamReaderTaskFactory) CreateReaderTask() plugin.ReaderTask
Source Files
Click to show internal directories.
Click to hide internal directories.