mongoreader

Documentation

Index

• type MongoReaderJob
  • func NewMongoReaderJob() *MongoReaderJob
  • func (job *MongoReaderJob) Destroy() error
  • func (job *MongoReaderJob) Init(config config.Configuration) error
  • func (job *MongoReaderJob) Post() error
  • func (job *MongoReaderJob) Prepare() error
  • func (job *MongoReaderJob) Split(adviceNumber int) ([]config.Configuration, error)
• type MongoReaderTask
  • func NewMongoReaderTask() *MongoReaderTask
  • func (task *MongoReaderTask) Destroy() error
  • func (task *MongoReaderTask) Init(config config.Configuration) error
  • func (task *MongoReaderTask) Post() error
  • func (task *MongoReaderTask) Prepare() error
  • func (task *MongoReaderTask) StartRead(recordSender plugin.RecordSender) error
• type UmongoReaderJobFactory
  • func (f *UmongoReaderJobFactory) CreateReaderJob() plugin.ReaderJob
• type UmongoReaderTaskFactory
  • func (f *UmongoReaderTaskFactory) CreateReaderTask() plugin.ReaderTask

Types

type MongoReaderJob

type MongoReaderJob struct {
	// contains filtered or unexported fields
}

MongoReaderJob MongoDB读取作业

func NewMongoReaderJob

func NewMongoReaderJob() *MongoReaderJob

func (*MongoReaderJob) Destroy

func (job *MongoReaderJob) Destroy() error

func (*MongoReaderJob) Init

func (job *MongoReaderJob) Init(config config.Configuration) error

func (*MongoReaderJob) Post

func (job *MongoReaderJob) Post() error

func (*MongoReaderJob) Prepare

func (job *MongoReaderJob) Prepare() error

func (*MongoReaderJob) Split

func (job *MongoReaderJob) Split(adviceNumber int) ([]config.Configuration, error)

type MongoReaderTask

type MongoReaderTask struct {
	// contains filtered or unexported fields
}

MongoReaderTask MongoDB读取任务

func NewMongoReaderTask

func NewMongoReaderTask() *MongoReaderTask

func (*MongoReaderTask) Destroy

func (task *MongoReaderTask) Destroy() error

func (*MongoReaderTask) Init

func (task *MongoReaderTask) Init(config config.Configuration) error

func (*MongoReaderTask) Post

func (task *MongoReaderTask) Post() error

func (*MongoReaderTask) Prepare

func (task *MongoReaderTask) Prepare() error

func (*MongoReaderTask) StartRead

func (task *MongoReaderTask) StartRead(recordSender plugin.RecordSender) error

type UmongoReaderJobFactory

type UmongoReaderJobFactory struct{}

UmongoReaderJobFactory 实现ReaderJobFactory接口

func (*UmongoReaderJobFactory) CreateReaderJob

func (f *UmongoReaderJobFactory) CreateReaderJob() plugin.ReaderJob

type UmongoReaderTaskFactory

type UmongoReaderTaskFactory struct{}

UmongoReaderTaskFactory 实现ReaderTaskFactory接口

func (*UmongoReaderTaskFactory) CreateReaderTask

func (f *UmongoReaderTaskFactory) CreateReaderTask() plugin.ReaderTask