oraclereader

package

v1.4.0 Latest Latest Go to latest Published: Sep 29, 2025 License: MIT Imports: 13 Imported by: 0

Details

View Source

const (
	DefaultBatchSize = 1024
	DefaultFetchSize = 1024
)

This section is empty.

This section is empty.

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

OracleReaderJob Oracle读取作业

func NewOracleReaderJob() *OracleReaderJob

func (job *OracleReaderJob) Destroy() error

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

func (job *OracleReaderJob) Post() error

func (job *OracleReaderJob) Prepare() error

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

type OracleReaderJobFactory struct{}

OracleReaderJobFactory 实现ReaderJobFactory接口

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

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

OracleReaderTask Oracle读取任务

func NewOracleReaderTask() *OracleReaderTask

func (task *OracleReaderTask) Destroy() error

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

func (task *OracleReaderTask) Post() error

func (task *OracleReaderTask) Prepare() error

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

type OracleReaderTaskFactory struct{}

OracleReaderTaskFactory 实现ReaderTaskFactory接口

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