Retracted: Withdrawn; the module proxy serves these against commits that no longer exist here.

postgres

package

v1.7.4 Latest Latest Go to latest Published: Sep 2, 2026 License: MIT Imports: 20 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/gsoultan/hermod

Links

Open Source Insights

Documentation ¶

Index ¶

Constants
type PostgresSink
- func NewPostgresSink(connString string, tableName string, mappings []sqlutil.ColumnMapping, ...) *PostgresSink

Constants ¶

View Source

const (
	QueryUpsert        = "Upsert"
	QueryDelete        = "Delete"
	QueryListDatabases = "ListDatabases"
	QueryListTables    = "ListTables"
	QueryBrowse        = "Browse"
	QueryCreateTable   = "CreateTable"
	QueryCreateSchema  = "CreateSchema"
	QueryListColumns   = "ListColumns"
	QueryTableExists   = "TableExists"
)

Variables ¶

This section is empty.

Functions ¶

This section is empty.

Types ¶

type PostgresSink ¶

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

PostgresSink implements the hermod.Sink interface for PostgreSQL. All exported methods are safe for concurrent use.

func NewPostgresSink ¶

func NewPostgresSink(connString string, tableName string, mappings []sqlutil.ColumnMapping, useExistingTable bool, deleteStrategy string, softDeleteColumn string, softDeleteValue string, operationMode string, autoTruncate bool, autoSync bool) *PostgresSink

func (*PostgresSink) Begin ¶

func (s *PostgresSink) Begin(ctx context.Context) error

func (*PostgresSink) Browse ¶

func (s *PostgresSink) Browse(ctx context.Context, table string, limit int) ([]hermod.Message, error)

func (*PostgresSink) Close ¶

func (s *PostgresSink) Close() error

func (*PostgresSink) Commit ¶

func (s *PostgresSink) Commit(ctx context.Context) error

func (*PostgresSink) CommitPrepared ¶

func (s *PostgresSink) CommitPrepared(ctx context.Context, txID string) error

func (*PostgresSink) DiscoverColumns ¶

func (s *PostgresSink) DiscoverColumns(ctx context.Context, table string) ([]hermod.ColumnInfo, error)

func (*PostgresSink) DiscoverDatabases ¶

func (s *PostgresSink) DiscoverDatabases(ctx context.Context) ([]string, error)

func (*PostgresSink) DiscoverTables ¶

func (s *PostgresSink) DiscoverTables(ctx context.Context) ([]string, error)

func (*PostgresSink) Ping ¶

func (s *PostgresSink) Ping(ctx context.Context) error

func (*PostgresSink) PreflightTwoPhaseCommit ¶

func (s *PostgresSink) PreflightTwoPhaseCommit(ctx context.Context) error

PreflightTwoPhaseCommit reports whether this sink can genuinely take part in a distributed transaction, and refuses loudly when it cannot.

Two ways it cannot, both of which are silent without this check:

Behind a transaction pooler. A prepared transaction has to be resolved on the backend that created it, which a pooler cannot guarantee, so Prepare degrades to committing locally and returning a sentinel. That is fine for a lone sink and catastrophic inside a group: the coordinator believes it can still roll back, the data is already committed, and a later abort leaves this sink diverged from the others with nothing reporting it.
max_prepared_transactions = 0, which is the PostgreSQL default. PREPARE TRANSACTION then fails outright, so every batch aborts mid-flight instead of failing at start-up where an operator would see it.

func (*PostgresSink) Prepare ¶

func (s *PostgresSink) Prepare(ctx context.Context, txID string) (string, error)

func (*PostgresSink) Rollback ¶

func (s *PostgresSink) Rollback(ctx context.Context) error

func (*PostgresSink) RollbackPrepared ¶

func (s *PostgresSink) RollbackPrepared(ctx context.Context, txID string) error

func (*PostgresSink) Sample ¶

func (s *PostgresSink) Sample(ctx context.Context, table string) (hermod.Message, error)

func (*PostgresSink) SetLogger ¶

func (s *PostgresSink) SetLogger(logger hermod.Logger)

func (*PostgresSink) Write ¶

func (s *PostgresSink) Write(ctx context.Context, msg hermod.Message) error

func (*PostgresSink) WriteBatch ¶

func (s *PostgresSink) WriteBatch(ctx context.Context, msgs []hermod.Message) error

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL