db

package

v0.0.0-...-2943bdd Latest Latest Go to latest Published: Feb 23, 2021 License: MIT Imports: 5 Imported by: 1

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/perangel/warp-pipe

Links

Open Source Insights

Documentation ¶

Index ¶

func Prepare(conn *pgx.Conn, schemas []string, includeTables, excludeTables []string) error
func PrepareForDataIntegrityChecks(conn *pgx.Conn) error
func Teardown(conn *pgx.Conn) error
type Table
- func GenerateTablesList(conn *pgx.Conn, schemas, includeTables, excludeTables []string) ([]Table, error)
type Wal2JSONChange
type Wal2JSONMessage
type Wal2JSONOldKeys

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

func Prepare ¶

func Prepare(conn *pgx.Conn, schemas []string, includeTables, excludeTables []string) error

Prepare prepares the database for capturing changesets. This will setup:

new `warp_pipe` schema
new `changesets` table in the `warp_pipe` schema
new TRIGGER function to be fired AFTER an INSERT, UPDATE, or DELETE on a table
registers the trigger with all configured tables in the source schema

func PrepareForDataIntegrityChecks ¶

func PrepareForDataIntegrityChecks(conn *pgx.Conn) error

func Teardown ¶

func Teardown(conn *pgx.Conn) error

Teardown removes the `warp_pipe` schema and all associated tables and functions.

Types ¶

type Table ¶

type Table struct {
	Name       string
	Schema     string
	PKeyName   string
	PKeyFields map[int]string
}

func GenerateTablesList ¶

func GenerateTablesList(conn *pgx.Conn, schemas, includeTables, excludeTables []string) ([]Table, error)

GenerateTablesList using the includes and excludes list. If no tables are specified in the includes list, obtain the complete list from Postgres using the supplied schemas. If any of the included tables are listed as excluded, remove them from the list.

type Wal2JSONChange ¶

type Wal2JSONChange struct {
	ID           int64            `json:"id"`
	Kind         string           `json:"kind"`
	Schema       string           `json:"schema"`
	Table        string           `json:"table"`
	ColumnNames  []string         `json:"columnnames"`
	ColumnTypes  []string         `json:"columntypes"`
	ColumnValues []interface{}    `json:"columnvalues"`
	OldKeys      *Wal2JSONOldKeys `json:"oldkeys"`
}

Wal2JSONChange represents a changeset within a Wal2JSONMessage.

type Wal2JSONMessage ¶

type Wal2JSONMessage struct {
	Changes []*Wal2JSONChange `json:"change"`
	NextLSN string            `json:"nextlsn"`
}

Wal2JSONMessage represents a wal2json message object.

type Wal2JSONOldKeys ¶

type Wal2JSONOldKeys struct {
	KeyNames  []string      `json:"keynames"`
	KeyTypes  []string      `json:"keytypes"`
	KeyValues []interface{} `json:"keyvalues"`
}

Wal2JSONOldKeys represents the `oldkeys` object in a Wal2JSON change

Source Files ¶

View all Source files

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