postgresqlwriter

package

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

Details

This section is empty.

This section is empty.

This section is empty.

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

PostgreSQLWriterJob PostgreSQL写入作业，薄包装层委托给通用RDBMS实现

func NewPostgreSQLWriterJob() *PostgreSQLWriterJob

func (job *PostgreSQLWriterJob) Destroy() error

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

func (job *PostgreSQLWriterJob) Post() error

func (job *PostgreSQLWriterJob) Prepare() error

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

type PostgreSQLWriterJobFactory struct{}

PostgreSQLWriterJobFactory 实现WriterJobFactory接口

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

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

PostgreSQLWriterTask PostgreSQL写入任务，薄包装层委托给通用RDBMS实现

func NewPostgreSQLWriterTask() *PostgreSQLWriterTask

func (task *PostgreSQLWriterTask) Destroy() error

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

func (task *PostgreSQLWriterTask) Post() error

func (task *PostgreSQLWriterTask) Prepare() error

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

type PostgreSQLWriterTaskFactory struct{}

PostgreSQLWriterTaskFactory 实现WriterTaskFactory接口

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