oraclewriter

package

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

Details

View Source

const (
	DefaultBatchSize     = 1024
	DefaultInsertTimeout = 30 // seconds
)

This section is empty.

This section is empty.

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

OracleWriterJob Oracle写入Job

func NewOracleWriterJob() *OracleWriterJob

func (job *OracleWriterJob) Destroy() error

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

func (job *OracleWriterJob) Post() error

func (job *OracleWriterJob) Prepare() error

func (job *OracleWriterJob) Split(mandatoryNumber int) ([]config.Configuration, error)

type OracleWriterJobFactory struct{}

OracleWriterJobFactory 实现WriterJobFactory接口

func (f *OracleWriterJobFactory) CreateWriterJob() plugin.WriterJob

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

OracleWriterTask Oracle写入Task

func NewOracleWriterTask() *OracleWriterTask

func (task *OracleWriterTask) Destroy() error

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

func (task *OracleWriterTask) Post() error

func (task *OracleWriterTask) Prepare() error

func (task *OracleWriterTask) StartWrite(recordReceiver plugin.RecordReceiver) error

type OracleWriterTaskFactory struct{}

OracleWriterTaskFactory 实现WriterTaskFactory接口

func (f *OracleWriterTaskFactory) CreateWriterTask() plugin.WriterTask