postgres

package

v0.0.1-alpha Latest Latest Go to latest Published: Jun 1, 2026 License: MIT Imports: 8 Imported by: 0

Documentation ¶

This section is empty.

This section is empty.

func GetSchema(ctx context.Context, db *pgxpool.Pool, table string) (*schema.Schema, error)

GetSchema introspects the PostgreSQL database to get the schema of a table.

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

func NewPostgresAdapter() *PostgresAdapter

func (a *PostgresAdapter) ApplySchema(ctx context.Context, s *schema.Schema) error

func (a *PostgresAdapter) Close() error

func (a *PostgresAdapter) Connect(ctx context.Context, cfg config.DBConfig) error

func (a *PostgresAdapter) Partitions(ctx context.Context, table string, n int) ([]adapter.Partition, error)

func (a *PostgresAdapter) ReadPartition(ctx context.Context, p adapter.Partition, ch chan<- *record.Record, errCh chan<- error)

func (a *PostgresAdapter) Schema(ctx context.Context, table string) (*schema.Schema, error)

func (a *PostgresAdapter) WriteBatch(ctx context.Context, batch []*record.Record) (int, error)

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

Reader handles parallel reading from PostgreSQL.

func NewReader(db *pgxpool.Pool) *Reader

func (r *Reader) Partitions(ctx context.Context, table string, n int) ([]adapter.Partition, error)

func (r *Reader) ReadPartition(ctx context.Context, p adapter.Partition, ch chan<- *record.Record, errCh chan<- error)

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

Writer handles bulk writing to PostgreSQL using the COPY protocol.

func NewWriter(db *pgxpool.Pool, table string) *Writer

func (w *Writer) ApplySchema(ctx context.Context, s *schema.Schema) error

func (w *Writer) WriteBatch(ctx context.Context, batch []*record.Record) (int, error)